-/* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
- * vim:expandtab:shiftwidth=8:tabstop=8:
- *
+/*
* GPL HEADER START
*
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
/*
* Copyright (c) 2002, 2010, Oracle and/or its affiliates. All rights reserved.
* Use is subject to license terms.
+ *
+ * Copyright (c) 2011, 2013, Intel Corporation.
*/
/*
* This file is part of Lustre, http://www.lustre.org/
#include <obd.h> /* for struct lov_stripe_md */
#include <lustre/lustre_build_version.h>
-#include <obd_class.h>
#include <lnet/lnetctl.h>
#include <libcfs/libcfsutil.h>
-#include <lustre/liblustreapi.h>
+#include <lustre/lustreapi.h>
#define MAX_STRING_SIZE 128
#define DEVICES_LIST "/proc/fs/lustre/devices"
const int nthreads = 1;
#endif
-#define MAX_IOC_BUFLEN 8192
-
static int cur_device = -1;
struct lov_oinfo lov_oinfos[LOV_MAX_STRIPE_COUNT];
char *obdo_print(struct obdo *obd)
{
- char buf[1024];
+ char buf[1024];
- sprintf(buf, "id: "LPX64"\ngrp: "LPX64"\natime: "LPU64"\nmtime: "LPU64
- "\nctime: "LPU64"\nsize: "LPU64"\nblocks: "LPU64
- "\nblksize: %u\nmode: %o\nuid: %d\ngid: %d\nflags: %x\n"
- "misc: %x\nnlink: %d,\nvalid "LPX64"\n",
- obd->o_id, obd->o_seq, obd->o_atime, obd->o_mtime, obd->o_ctime,
- obd->o_size, obd->o_blocks, obd->o_blksize, obd->o_mode,
- obd->o_uid, obd->o_gid, obd->o_flags, obd->o_misc,
- obd->o_nlink, obd->o_valid);
- return strdup(buf);
+ sprintf(buf, "id: "LPX64"\ngrp: "LPX64"\natime: "LPU64"\nmtime: "LPU64
+ "\nctime: "LPU64"\nsize: "LPU64"\nblocks: "LPU64
+ "\nblksize: %u\nmode: %o\nuid: %d\ngid: %d\nflags: %x\n"
+ "misc: %x\nnlink: %d,\nvalid "LPX64"\n",
+ ostid_id(&obd->o_oi), ostid_seq(&obd->o_oi), obd->o_atime,
+ obd->o_mtime, obd->o_ctime,
+ obd->o_size, obd->o_blocks, obd->o_blksize, obd->o_mode,
+ obd->o_uid, obd->o_gid, obd->o_flags, obd->o_misc,
+ obd->o_nlink, obd->o_valid);
+ return strdup(buf);
}
memset(buf, 0, sizeof(rawbuf));
rc = obd_ioctl_pack(&data, &buf, sizeof(rawbuf));
- if (rc) {
+ if (rc < 0) {
fprintf(stderr, "error: %s: invalid ioctl\n",
jt_cmdname(func));
- return rc;
+ return -rc;
}
rc = l2_ioctl(OBD_DEV_ID, OBD_IOC_NAME2DEV, buf);
if (rc < 0)
reset_lsmb (lsmb);
- lsm->lsm_object_id = strtoull (string, &end, 0);
- if (end == string)
- return (-1);
- string = end;
+ ostid_set_id(&lsm->lsm_oi, strtoull(string, &end, 0));
+ if (end == string)
+ return -1;
+ string = end;
if (*string == 0)
return (0);
if (*string == 0) /* don't have to specify obj ids */
return (0);
- for (i = 0; i < lsm->lsm_stripe_count; i++) {
- if (*string != '@')
- return (-1);
- string++;
- lsm->lsm_oinfo[i]->loi_ost_idx = strtoul(string, &end, 0);
- if (*end != ':')
- return (-1);
- string = end + 1;
- lsm->lsm_oinfo[i]->loi_id = strtoull(string, &end, 0);
- string = end;
- }
+ for (i = 0; i < lsm->lsm_stripe_count; i++) {
+ if (*string != '@')
+ return (-1);
+ string++;
+ lsm->lsm_oinfo[i]->loi_ost_idx = strtoul(string, &end, 0);
+ if (*end != ':')
+ return (-1);
+ string = end + 1;
+ ostid_set_id(&lsm->lsm_oinfo[i]->loi_oi,
+ strtoull(string, &end, 0));
+ string = end;
+ }
if (*string != 0)
return (-1);
&shared_data->body.start_time);
shmem_unlock();
- printf("Total: total %llu threads %d sec %f %f/second\n", total,
- total_threads, secs, total / secs);
+ printf("Total: total "LPU64" threads %d sec %f %f/second\n",
+ total, total_threads, secs, total / secs);
return;
}
gettimeofday(&start, NULL);
while (shmem_running()) {
- struct lu_fid fid;
+ struct lu_fid fid = { 0 };
- data.ioc_obdo2.o_id = child_base_id;
+ ostid_set_id(&data.ioc_obdo2.o_oi, child_base_id);
data.ioc_obdo2.o_mode = mode | create_mode;
data.ioc_obdo2.o_valid = OBD_MD_FLID | OBD_MD_FLTYPE |
OBD_MD_FLMODE | OBD_MD_FLFLAGS |
data.ioc_count = MD_STEP_COUNT;
}
- child_base_id += data.ioc_count;
- count += data.ioc_count;
if (cmd == ECHO_MD_CREATE || cmd == ECHO_MD_MKDIR) {
/*Allocate fids for the create */
rc = jt_obd_alloc_fids(&fid_space, &fid,
fprintf(stderr, "Allocate fids error %d.\n",rc);
return rc;
}
- data.ioc_obdo1.o_seq = fid.f_seq;
- data.ioc_obdo1.o_id = fid.f_oid;
+ fid_to_ostid(&fid, &data.ioc_obdo1.o_oi);
}
+
+ child_base_id += data.ioc_count;
+ count += data.ioc_count;
+
memset(buf, 0, sizeof(rawbuf));
rc = obd_ioctl_pack(&data, &buf, sizeof(rawbuf));
if (rc) {
char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
struct obd_ioctl_data data;
struct timeval next_time;
- __u64 count = 1, next_count, base_id = 0;
+ __u64 count = 1, next_count, base_id = 1;
int verbose = 1, mode = 0100644, rc = 0, i, valid_lsm = 0;
char *end;
return CMD_HELP;
}
- if (argc < 5) {
- reset_lsmb (&lsm_buffer); /* will set default */
- } else {
- rc = parse_lsm (&lsm_buffer, argv[4]);
- if (rc != 0) {
- fprintf(stderr, "error: %s: invalid lsm '%s'\n",
- jt_cmdname(argv[0]), argv[4]);
- return CMD_HELP;
- }
- base_id = lsm_buffer.lsm.lsm_object_id;
- valid_lsm = 1;
- }
+ if (argc < 5) {
+ reset_lsmb(&lsm_buffer); /* will set default */
+ } else {
+ rc = parse_lsm(&lsm_buffer, argv[4]);
+ if (rc != 0) {
+ fprintf(stderr, "error: %s: invalid lsm '%s'\n",
+ jt_cmdname(argv[0]), argv[4]);
+ return CMD_HELP;
+ }
+ base_id = ostid_id(&lsm_buffer.lsm.lsm_oi);
+ valid_lsm = 1;
+ }
printf("%s: "LPD64" objects\n", jt_cmdname(argv[0]), count);
gettimeofday(&next_time, NULL);
next_time.tv_sec -= verbose;
+ ostid_set_seq_echo(&data.ioc_obdo1.o_oi);
for (i = 1, next_count = verbose; i <= count && shmem_running(); i++) {
- data.ioc_obdo1.o_mode = mode;
- data.ioc_obdo1.o_id = base_id;
- data.ioc_obdo1.o_uid = 0;
- data.ioc_obdo1.o_gid = 0;
- data.ioc_obdo1.o_valid = OBD_MD_FLTYPE | OBD_MD_FLMODE |
- OBD_MD_FLID | OBD_MD_FLUID | OBD_MD_FLGID;
-
- if (valid_lsm) {
- data.ioc_plen1 = sizeof lsm_buffer;
- data.ioc_pbuf1 = (char *)&lsm_buffer;
- }
+ data.ioc_obdo1.o_mode = mode;
+ ostid_set_id(&data.ioc_obdo1.o_oi, base_id);
+ data.ioc_obdo1.o_uid = 0;
+ data.ioc_obdo1.o_gid = 0;
+ data.ioc_obdo1.o_valid = OBD_MD_FLTYPE | OBD_MD_FLMODE |
+ OBD_MD_FLID | OBD_MD_FLUID |
+ OBD_MD_FLGID | OBD_MD_FLGROUP;
+ if (valid_lsm) {
+ data.ioc_plen1 = sizeof lsm_buffer;
+ data.ioc_pbuf1 = (char *)&lsm_buffer;
+ }
memset(buf, 0, sizeof(rawbuf));
rc = obd_ioctl_pack(&data, &buf, sizeof(rawbuf));
break;
}
- if (be_verbose(verbose, &next_time, i, &next_count, count))
- printf("%s: #%d is object id "LPX64"\n",
- jt_cmdname(argv[0]), i, data.ioc_obdo1.o_id);
+ if (be_verbose(verbose, &next_time, i, &next_count, count))
+ printf("%s: #%d is object id "LPX64"\n",
+ jt_cmdname(argv[0]), i,
+ ostid_id(&data.ioc_obdo1.o_oi));
}
return rc;
}
if (argc != 2)
return CMD_HELP;
- data.ioc_obdo1.o_id = strtoull(argv[1], &end, 0);
+ ostid_set_seq_echo(&data.ioc_obdo1.o_oi);
+ ostid_set_id(&data.ioc_obdo1.o_oi, strtoull(argv[1], &end, 0));
if (*end) {
fprintf(stderr, "error: %s: invalid objid '%s'\n",
jt_cmdname(argv[0]), argv[1]);
printf("%s: setting "LPD64" attrs (objid "LPX64"): %s",
jt_cmdname(argv[0]), count, objid, ctime(&start.tv_sec));
+ ostid_set_seq_echo(&data.ioc_obdo1.o_oi);
for (i = 1, next_count = verbose; i <= count && shmem_running(); i++) {
- data.ioc_obdo1.o_id = objid;
+ ostid_set_id(&data.ioc_obdo1.o_oi, objid);
data.ioc_obdo1.o_mode = S_IFREG;
data.ioc_obdo1.o_valid = OBD_MD_FLID | OBD_MD_FLTYPE | OBD_MD_FLMODE;
memset(buf, 0, sizeof(rawbuf));
gettimeofday(&next_time, NULL);
next_time.tv_sec -= verbose;
+ ostid_set_seq_echo(&data.ioc_obdo1.o_oi);
for (i = 1, next_count = verbose; i <= count && shmem_running(); i++, id++) {
- data.ioc_obdo1.o_id = id;
- data.ioc_obdo1.o_mode = S_IFREG | 0644;
- data.ioc_obdo1.o_valid = OBD_MD_FLID | OBD_MD_FLMODE;
+ ostid_set_id(&data.ioc_obdo1.o_oi, id);
+ data.ioc_obdo1.o_mode = S_IFREG | 0644;
+ data.ioc_obdo1.o_valid = OBD_MD_FLID | OBD_MD_FLMODE;
memset(buf, 0, sizeof(rawbuf));
rc = obd_ioctl_pack(&data, &buf, sizeof(rawbuf));
if (argc != 2)
return CMD_HELP;
- memset(&data, 0, sizeof(data));
- data.ioc_dev = cur_device;
- data.ioc_obdo1.o_id = strtoull(argv[1], &end, 0);
- if (*end) {
- fprintf(stderr, "error: %s: invalid objid '%s'\n",
- jt_cmdname(argv[0]), argv[1]);
- return CMD_HELP;
- }
- /* to help obd filter */
- data.ioc_obdo1.o_mode = 0100644;
- data.ioc_obdo1.o_valid = 0xffffffff;
- printf("%s: object id "LPX64"\n", jt_cmdname(argv[0]),data.ioc_obdo1.o_id);
+ memset(&data, 0, sizeof(data));
+ data.ioc_dev = cur_device;
+ ostid_set_seq_echo(&data.ioc_obdo1.o_oi);
+ ostid_set_id(&data.ioc_obdo1.o_oi, strtoull(argv[1], &end, 0));
+ if (*end) {
+ fprintf(stderr, "error: %s: invalid objid '%s'\n",
+ jt_cmdname(argv[0]), argv[1]);
+ return CMD_HELP;
+ }
+ /* to help obd filter */
+ data.ioc_obdo1.o_mode = 0100644;
+ data.ioc_obdo1.o_valid = 0xffffffff;
+ printf("%s: object id "LPX64"\n", jt_cmdname(argv[0]),
+ ostid_id(&data.ioc_obdo1.o_oi));
memset(buf, 0, sizeof(rawbuf));
rc = obd_ioctl_pack(&data, &buf, sizeof(rawbuf));
fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
strerror(rc = errno));
} else {
- printf("%s: object id "LPX64", mode %o\n", jt_cmdname(argv[0]),
- data.ioc_obdo1.o_id, data.ioc_obdo1.o_mode);
+ printf("%s: object id "LPU64", mode %o\n", jt_cmdname(argv[0]),
+ ostid_id(&data.ioc_obdo1.o_oi), data.ioc_obdo1.o_mode);
}
return rc;
}
printf("%s: getting "LPD64" attrs (objid "LPX64"): %s",
jt_cmdname(argv[0]), count, objid, ctime(&start.tv_sec));
+ ostid_set_seq_echo(&data.ioc_obdo1.o_oi);
for (i = 1, next_count = verbose; i <= count && shmem_running(); i++) {
- data.ioc_obdo1.o_id = objid;
- data.ioc_obdo1.o_mode = S_IFREG;
- data.ioc_obdo1.o_valid = 0xffffffff;
- memset(buf, 0, sizeof(rawbuf));
- rc = obd_ioctl_pack(&data, &buf, sizeof(rawbuf));
- if (rc) {
- fprintf(stderr, "error: %s: invalid ioctl\n",
- jt_cmdname(argv[0]));
- return rc;
- }
+ ostid_set_id(&data.ioc_obdo1.o_oi, objid);
+ data.ioc_obdo1.o_mode = S_IFREG;
+ data.ioc_obdo1.o_valid = 0xffffffff;
+ memset(buf, 0, sizeof(rawbuf));
+ rc = obd_ioctl_pack(&data, &buf, sizeof(rawbuf));
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
rc = l2_ioctl(OBD_DEV_ID, OBD_IOC_GETATTR, &data);
shmem_bump(1);
if (rc < 0) {
}
#endif
- data.ioc_obdo1.o_id = objid;
- data.ioc_obdo1.o_mode = S_IFREG;
- data.ioc_obdo1.o_valid = OBD_MD_FLID | OBD_MD_FLTYPE | OBD_MD_FLMODE | OBD_MD_FLFLAGS;
- data.ioc_obdo1.o_flags = (verify ? OBD_FL_DEBUG_CHECK : 0);
- data.ioc_count = len;
- data.ioc_offset = (repeat_offset ? 0 : thr_offset);
+ ostid_set_seq_echo(&data.ioc_obdo1.o_oi);
+ ostid_set_id(&data.ioc_obdo1.o_oi, objid);
+ data.ioc_obdo1.o_mode = S_IFREG;
+ data.ioc_obdo1.o_valid = OBD_MD_FLID | OBD_MD_FLTYPE | OBD_MD_FLMODE |
+ OBD_MD_FLFLAGS | OBD_MD_FLGROUP;
+ data.ioc_obdo1.o_flags = (verify ? OBD_FL_DEBUG_CHECK : 0);
+ data.ioc_count = len;
+ data.ioc_offset = (repeat_offset ? 0 : thr_offset);
gettimeofday(&start, NULL);
next_time.tv_sec = start.tv_sec - verbose;
write ? "write" : "read");
break;
} else if (be_verbose(verbose, &next_time,i, &next_count,count)) {
- shmem_lock ();
- printf("%s: %s number %d @ "LPD64":"LPU64" for %d\n",
- jt_cmdname(argv[0]), write ? "write" : "read", i,
- data.ioc_obdo1.o_id, data.ioc_offset,
- (int)(pages * getpagesize()));
- shmem_unlock ();
+ shmem_lock ();
+ printf("%s: %s number %d @ "LPD64":"LPU64" for %d\n",
+ jt_cmdname(argv[0]), write ? "write" : "read", i,
+ ostid_id(&data.ioc_obdo1.o_oi), data.ioc_offset,
+ (int)(pages * getpagesize()));
+ shmem_unlock ();
}
if (!repeat_offset) {
return rc;
}
+/**
+ * Replace nids for given device.
+ * lctl replace_nids <devicename> <nid1>[,nid2,nid3]
+ * Command should be started on MGS server.
+ * Only MGS server should be started (command execution
+ * returns error in another cases). Command mount
+ * -t lustre <MDT partition> -o nosvc <mount point>
+ * can be used for that.
+ *
+ * llogs for MDTs and clients are processed. All
+ * records copied as is except add_uuid and setup. This records
+ * are skipped and recorded with new nids and uuid.
+ *
+ * \see mgs_replace_nids
+ * \see mgs_replace_nids_log
+ * \see mgs_replace_handler
+ */
+int jt_replace_nids(int argc, char **argv)
+{
+ int rc;
+ char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
+ struct obd_ioctl_data data;
+
+ memset(&data, 0, sizeof(data));
+ data.ioc_dev = get_mgs_device();
+ if (argc != 3)
+ return CMD_HELP;
+
+ data.ioc_inllen1 = strlen(argv[1]) + 1;
+ data.ioc_inlbuf1 = argv[1];
+
+ data.ioc_inllen2 = strlen(argv[2]) + 1;
+ data.ioc_inlbuf2 = argv[2];
+ memset(buf, 0, sizeof(rawbuf));
+ rc = obd_ioctl_pack(&data, &buf, sizeof(rawbuf));
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
+
+ rc = l2_ioctl(OBD_DEV_ID, OBD_IOC_REPLACE_NIDS, buf);
+ if (rc < 0) {
+ fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
+ strerror(rc = errno));
+ }
+
+ return rc;
+}
+
int jt_obd_deactivate(int argc, char **argv)
{
return do_activate(argc, argv, 0);
{
struct sigaction sigact;
+ /* sigact initialization */
sigact.sa_handler = signal_server;
sigfillset(&sigact.sa_mask);
sigact.sa_flags = SA_RESTART;
+ /* coverity[uninit_use_in_call] */
sigaction(SIGINT, &sigact, NULL);
shmem_cleanup();
int jt_get_obj_version(int argc, char **argv)
{
- struct lu_fid fid;
- struct obd_ioctl_data data;
- __u64 version;
- char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf, *fidstr;
- int rc;
-
- if (argc != 2)
- return CMD_HELP;
-
- fidstr = argv[1];
- while (*fidstr == '[')
- fidstr++;
- sscanf(fidstr, SFID, RFID(&fid));
- if (!fid_is_sane(&fid)) {
- fprintf(stderr, "bad FID format [%s], should be "DFID"\n",
- fidstr, (__u64)1, 2, 0);
- return -EINVAL;
- }
-
- memset(&data, 0, sizeof data);
- data.ioc_dev = cur_device;
- data.ioc_inlbuf1 = (char *) &fid;
- data.ioc_inllen1 = sizeof fid;
- data.ioc_inlbuf2 = (char *) &version;
- data.ioc_inllen2 = sizeof version;
+ struct lu_fid fid;
+ struct obd_ioctl_data data;
+ __u64 version, id = ULLONG_MAX, group = ULLONG_MAX;
+ char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf, *fidstr;
+ int rc, c;
+
+ while ((c = getopt(argc, argv, "i:g:")) != -1) {
+ switch (c) {
+ case 'i':
+ id = strtoull(optarg, NULL, 0);
+ break;
+ case 'g':
+ group = strtoull(optarg, NULL, 0);
+ break;
+ default:
+ return CMD_HELP;
+ }
+ }
+
+ argc -= optind;
+ argv += optind;
+
+ if (!(id != ULLONG_MAX && group != ULLONG_MAX && argc == 0) &&
+ !(id == ULLONG_MAX && group == ULLONG_MAX && argc == 1))
+ return CMD_HELP;
+
+ memset(&data, 0, sizeof data);
+ data.ioc_dev = cur_device;
+ if (argc == 1) {
+ fidstr = *argv;
+ while (*fidstr == '[')
+ fidstr++;
+ sscanf(fidstr, SFID, RFID(&fid));
+
+ data.ioc_inlbuf1 = (char *) &fid;
+ data.ioc_inllen1 = sizeof fid;
+ } else {
+ data.ioc_inlbuf3 = (char *) &id;
+ data.ioc_inllen3 = sizeof id;
+ data.ioc_inlbuf4 = (char *) &group;
+ data.ioc_inllen4 = sizeof group;
+ }
+ data.ioc_inlbuf2 = (char *) &version;
+ data.ioc_inllen2 = sizeof version;
memset(buf, 0, sizeof *buf);
rc = obd_ioctl_pack(&data, &buf, sizeof rawbuf);