static int cur_device = -1;
-static int l2_ioctl(int dev_id, int opc, void *buf)
+int lcfg_ioctl(char *func, int dev_id, struct lustre_cfg *lcfg)
{
- return l_ioctl(dev_id, opc, buf);
-}
-
-int lcfg_ioctl(char * func, int dev_id, struct lustre_cfg *lcfg)
-{
- struct obd_ioctl_data data;
- char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
- int rc;
+ struct obd_ioctl_data data;
+ char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
+ int rc;
- memset(&data, 0, sizeof(data));
- data.ioc_dev = cur_device;
- data.ioc_type = LUSTRE_CFG_TYPE;
- data.ioc_plen1 = lustre_cfg_len(lcfg->lcfg_bufcount,
- lcfg->lcfg_buflens);
- data.ioc_pbuf1 = (void *)lcfg;
- memset(buf, 0, sizeof(rawbuf));
+ memset(&data, 0, sizeof(data));
+ data.ioc_dev = cur_device;
+ data.ioc_type = LUSTRE_CFG_TYPE;
+ data.ioc_plen1 = lustre_cfg_len(lcfg->lcfg_bufcount,
+ lcfg->lcfg_buflens);
+ data.ioc_pbuf1 = (void *)lcfg;
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_ioctl_pack(&data, &buf, sizeof(rawbuf));
- if (rc) {
- fprintf(stderr, "error: %s: invalid ioctl\n",
- jt_cmdname(func));
- return rc;
- }
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n", jt_cmdname(func));
+ return rc;
+ }
- rc = l_ioctl(dev_id, OBD_IOC_PROCESS_CFG, buf);
+ rc = l_ioctl(dev_id, OBD_IOC_PROCESS_CFG, buf);
- return rc;
+ return rc;
}
static int do_device(char *func, char *devname);
/* Returns -1 on error with errno set */
int lcfg_mgs_ioctl(char *func, int dev_id, struct lustre_cfg *lcfg)
{
- struct obd_ioctl_data data;
- char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
- int rc;
+ struct obd_ioctl_data data;
+ char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
+ int rc;
- memset(&data, 0, sizeof(data));
- rc = data.ioc_dev = get_mgs_device();
- if (rc < 0)
- goto out;
- data.ioc_type = LUSTRE_CFG_TYPE;
- data.ioc_plen1 = lustre_cfg_len(lcfg->lcfg_bufcount,
- lcfg->lcfg_buflens);
- data.ioc_pbuf1 = (void *)lcfg;
- memset(buf, 0, sizeof(rawbuf));
+ memset(&data, 0, sizeof(data));
+ rc = data.ioc_dev = get_mgs_device();
+ if (rc < 0)
+ goto out;
+ data.ioc_type = LUSTRE_CFG_TYPE;
+ data.ioc_plen1 = lustre_cfg_len(lcfg->lcfg_bufcount,
+ lcfg->lcfg_buflens);
+ data.ioc_pbuf1 = (void *)lcfg;
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_ioctl_pack(&data, &buf, sizeof(rawbuf));
- if (rc) {
- fprintf(stderr, "error: %s: invalid ioctl\n",
- jt_cmdname(func));
- return rc;
- }
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n", jt_cmdname(func));
+ return rc;
+ }
- rc = l_ioctl(dev_id, OBD_IOC_PARAM, buf);
+ rc = l_ioctl(dev_id, OBD_IOC_PARAM, buf);
out:
- if (rc) {
- if (errno == ENOSYS)
- fprintf(stderr, "Make sure cfg_device is set first.\n");
- }
- return rc;
+ if (rc && errno == ENOSYS)
+ fprintf(stderr, "Make sure cfg_device is set first.\n");
+
+ return rc;
}
char *obdo_print(struct obdo *obd)
static int do_name2dev(char *func, char *name)
{
- struct obd_ioctl_data data;
- char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
- int rc;
+ struct obd_ioctl_data data;
+ char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
+ int rc;
- memset(&data, 0, sizeof(data));
- data.ioc_dev = cur_device;
- data.ioc_inllen1 = strlen(name) + 1;
- data.ioc_inlbuf1 = name;
+ memset(&data, 0, sizeof(data));
+ data.ioc_dev = cur_device;
+ data.ioc_inllen1 = strlen(name) + 1;
+ data.ioc_inlbuf1 = name;
- memset(buf, 0, sizeof(rawbuf));
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_ioctl_pack(&data, &buf, sizeof(rawbuf));
if (rc < 0) {
- fprintf(stderr, "error: %s: invalid ioctl\n",
- jt_cmdname(func));
+ fprintf(stderr, "error: %s: invalid ioctl\n", jt_cmdname(func));
return -rc;
- }
- rc = l2_ioctl(OBD_DEV_ID, OBD_IOC_NAME2DEV, buf);
- if (rc < 0)
- return errno;
+ }
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_NAME2DEV, buf);
+ if (rc < 0)
+ return errno;
rc = llapi_ioctl_unpack(&data, buf, sizeof(rawbuf));
- if (rc) {
- fprintf(stderr, "error: %s: invalid reply\n",
- jt_cmdname(func));
- return rc;
- }
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid reply\n", jt_cmdname(func));
+ return rc;
+ }
- return data.ioc_dev + N2D_OFF;
+ return data.ioc_dev + N2D_OFF;
}
/*
int jt_opt_threads(int argc, char **argv)
{
- static char cmdstr[128];
+ static char cmdstr[129];
sigset_t saveset;
sigset_t sigset;
struct sigaction sigact;
if (verbose != 0) {
snprintf(cmdstr, sizeof(cmdstr), "%s", argv[4]);
for (i = 5; i < argc; i++)
- snprintf(cmdstr + strlen(cmdstr), sizeof(cmdstr),
- " %s", argv[i]);
+ snprintf(cmdstr + strlen(cmdstr),
+ sizeof(cmdstr) - strlen(cmdstr),
+ " %s", argv[i]);
printf("%s: starting %ld threads on device %s running %s\n",
argv[0], threads, argv[3], cmdstr);
int jt_obd_no_transno(int argc, char **argv)
{
- struct obd_ioctl_data data;
- char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
- int rc;
+ struct obd_ioctl_data data;
+ char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
+ int rc;
- memset(&data, 0, sizeof(data));
- data.ioc_dev = cur_device;
+ memset(&data, 0, sizeof(data));
+ data.ioc_dev = cur_device;
- if (argc != 1)
- return CMD_HELP;
+ if (argc != 1)
+ return CMD_HELP;
- memset(buf, 0, sizeof(rawbuf));
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_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_NO_TRANSNO, buf);
- if (rc < 0)
- fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
- strerror(rc = errno));
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_NO_TRANSNO, buf);
+ if (rc < 0)
+ fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
+ strerror(rc = errno));
- return rc;
+ return rc;
}
int jt_obd_set_readonly(int argc, char **argv)
{
- struct obd_ioctl_data data;
- char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
- int rc;
+ struct obd_ioctl_data data;
+ char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
+ int rc;
- memset(&data, 0, sizeof(data));
- data.ioc_dev = cur_device;
+ memset(&data, 0, sizeof(data));
+ data.ioc_dev = cur_device;
- if (argc != 1)
- return CMD_HELP;
+ if (argc != 1)
+ return CMD_HELP;
- memset(buf, 0, sizeof(rawbuf));
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_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_SET_READONLY, buf);
- if (rc < 0)
- fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
- strerror(rc = errno));
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_SET_READONLY, buf);
+ if (rc < 0)
+ fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
+ strerror(rc = errno));
- return rc;
+ return rc;
}
int jt_obd_abort_recovery(int argc, char **argv)
{
- struct obd_ioctl_data data;
- char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
- int rc;
+ struct obd_ioctl_data data;
+ char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
+ int rc;
- memset(&data, 0, sizeof(data));
- data.ioc_dev = cur_device;
+ memset(&data, 0, sizeof(data));
+ data.ioc_dev = cur_device;
- if (argc != 1)
- return CMD_HELP;
+ if (argc != 1)
+ return CMD_HELP;
- memset(buf, 0, sizeof(rawbuf));
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_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_ABORT_RECOVERY, buf);
- if (rc < 0)
- fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
- strerror(rc = errno));
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_ABORT_RECOVERY, buf);
+ if (rc < 0)
+ fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
+ strerror(rc = errno));
- return rc;
+ return rc;
}
int jt_get_version(int argc, char **argv)
data->ioc_inllen1 =
sizeof(rawbuf) - __ALIGN_KERNEL(sizeof(*data), 8);
data->ioc_inlbuf1 = buf + __ALIGN_KERNEL(sizeof(*data), 8);
- data->ioc_len = obd_ioctl_packlen(data);
- data->ioc_count = index;
+ data->ioc_len = obd_ioctl_packlen(data);
+ data->ioc_count = index;
- rc = l2_ioctl(OBD_DEV_ID, OBD_IOC_GETDEVICE, buf);
- if (rc != 0)
- break;
- printf("%s\n", (char *)data->ioc_bulk);
- }
- if (rc != 0) {
- if (errno == ENOENT)
- /* no device or the last device */
- rc = 0;
- else
- fprintf(stderr, "Error getting device list: %s: "
- "check dmesg.\n", strerror(errno));
- }
- return rc;
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_GETDEVICE, buf);
+ if (rc != 0)
+ break;
+ printf("%s\n", (char *)data->ioc_bulk);
+ }
+ if (rc != 0) {
+ if (errno == ENOENT)
+ /* no device or the last device */
+ rc = 0;
+ else
+ fprintf(stderr,
+ "Error getting device list: %s: check dmesg\n",
+ strerror(errno));
+ }
+ return rc;
}
int jt_obd_list(int argc, char **argv)
glob_t path;
FILE *fp;
- if (argc > 2)
- return CMD_HELP;
- else if (argc == 2) {
- if (strcmp(argv[1], "-t") == 0)
- print_obd = 1;
- else
- return CMD_HELP;
- }
+ if (argc > 2)
+ return CMD_HELP;
- if (cfs_get_param_paths(&path, "devices") != 0)
- return -errno;
+ if (argc == 2) {
+ if (strcmp(argv[1], "-t") == 0)
+ print_obd = 1;
+ else
+ return CMD_HELP;
+ }
- fp = fopen(path.gl_pathv[0], "r");
- if (fp == NULL) {
- fprintf(stderr, "error: %s: %s opening %s\n",
- jt_cmdname(argv[0]), strerror(errno), path.gl_pathv[0]);
+ if (cfs_get_param_paths(&path, "devices") ||
+ !(fp = fopen(path.gl_pathv[0], "r"))) {
cfs_free_param_data(&path);
- return jt_obd_list_ioctl(argc, argv);
- }
- while (fgets(buf, sizeof(buf), fp) != NULL)
- if (print_obd)
- print_obd_line(buf);
- else
- printf("%s", buf);
+ return jt_obd_list_ioctl(argc, argv);
+ }
+
+ while (fgets(buf, sizeof(buf), fp) != NULL)
+ if (print_obd)
+ print_obd_line(buf);
+ else
+ printf("%s", buf);
cfs_free_param_data(&path);
- fclose(fp);
- return 0;
+ fclose(fp);
+ return 0;
}
struct jt_fid_space {
};
int jt_obd_alloc_fids(struct jt_fid_space *space, struct lu_fid *fid,
- __u64 *count)
+ __u64 *count)
{
- int rc;
+ int rc;
- if (space->jt_seq == 0 || space->jt_id == space->jt_width) {
- struct obd_ioctl_data data;
- char rawbuf[MAX_IOC_BUFLEN];
- char *buf = rawbuf;
- __u64 seqnr;
- int max_count;
+ if (space->jt_seq == 0 || space->jt_id == space->jt_width) {
+ struct obd_ioctl_data data;
+ char rawbuf[MAX_IOC_BUFLEN];
+ char *buf = rawbuf;
+ __u64 seqnr;
+ int max_count;
- memset(&data, 0, sizeof(data));
- data.ioc_dev = cur_device;
+ memset(&data, 0, sizeof(data));
+ data.ioc_dev = cur_device;
- data.ioc_pbuf1 = (char *)&seqnr;
- data.ioc_plen1 = sizeof(seqnr);
+ data.ioc_pbuf1 = (char *)&seqnr;
+ data.ioc_plen1 = sizeof(seqnr);
- data.ioc_pbuf2 = (char *)&max_count;
- data.ioc_plen2 = sizeof(max_count);
+ data.ioc_pbuf2 = (char *)&max_count;
+ data.ioc_plen2 = sizeof(max_count);
- memset(buf, 0, sizeof(rawbuf));
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_ioctl_pack(&data, &buf, sizeof(rawbuf));
- if (rc) {
- fprintf(stderr, "error: invalid ioctl rc = %d\n", rc);
- return rc;
- }
+ if (rc) {
+ fprintf(stderr, "error: invalid ioctl rc = %d\n", rc);
+ return rc;
+ }
- rc = l2_ioctl(OBD_DEV_ID, OBD_IOC_ECHO_ALLOC_SEQ, buf);
- if (rc) {
- fprintf(stderr, "ioctl error: rc = %d\n", rc);
- return rc;
- }
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_ECHO_ALLOC_SEQ, buf);
+ if (rc) {
+ fprintf(stderr, "ioctl error: rc = %d\n", rc);
+ return rc;
+ }
- space->jt_seq = *(__u64 *)data.ioc_pbuf1;
- space->jt_width = *(int *)data.ioc_pbuf2;
- space->jt_id = 1;
- }
- fid->f_seq = space->jt_seq;
- fid->f_oid = space->jt_id;
- fid->f_ver = 0;
+ space->jt_seq = *(__u64 *)data.ioc_pbuf1;
+ space->jt_width = *(int *)data.ioc_pbuf2;
+ space->jt_id = 1;
+ }
+ fid->f_seq = space->jt_seq;
+ fid->f_oid = space->jt_id;
+ fid->f_ver = 0;
space->jt_id = space->jt_id + *count;
if (space->jt_id > space->jt_width)
return rc;
}
data.ioc_obdo1.o_oi.oi_fid = fid;
- }
+ }
- child_base_id += data.ioc_count;
- count += data.ioc_count;
+ child_base_id += data.ioc_count;
+ count += data.ioc_count;
- memset(buf, 0, sizeof(rawbuf));
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_ioctl_pack(&data, &buf, sizeof(rawbuf));
- if (rc) {
- fprintf(stderr, "error: %s: invalid ioctl %d\n",
- jt_cmdname(argv[0]), rc);
- return rc;
- }
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl %d\n",
+ jt_cmdname(argv[0]), rc);
+ return rc;
+ }
- rc = l2_ioctl(OBD_DEV_ID, OBD_IOC_ECHO_MD, buf);
- if (rc) {
- fprintf(stderr, "error: %s: %s\n",
- jt_cmdname(argv[0]), strerror(rc = errno));
- return rc;
- }
- shmem_bump(data.ioc_count);
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_ECHO_MD, buf);
+ if (rc) {
+ fprintf(stderr, "error: %s: %s\n",
+ jt_cmdname(argv[0]), strerror(rc = errno));
+ return rc;
+ }
+ shmem_bump(data.ioc_count);
gettimeofday(&end_time, NULL);
diff = difftime(&end_time, &start);
OBD_MD_FLGID | OBD_MD_FLGROUP |
OBD_MD_FLPROJID;
- memset(buf, 0, sizeof(rawbuf));
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_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_CREATE, buf);
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_CREATE, buf);
llapi_ioctl_unpack(&data, buf, sizeof(rawbuf));
- shmem_bump(1);
- if (rc < 0) {
- fprintf(stderr, "error: %s: #%d - %s\n",
- jt_cmdname(argv[0]), i, strerror(rc = errno));
- break;
- }
- if (!(data.ioc_obdo1.o_valid & OBD_MD_FLID)) {
+ shmem_bump(1);
+ if (rc < 0) {
+ fprintf(stderr, "error: %s: #%d - %s\n",
+ jt_cmdname(argv[0]), i, strerror(rc = errno));
+ break;
+ }
+ if (!(data.ioc_obdo1.o_valid & OBD_MD_FLID)) {
fprintf(stderr, "error: %s: oid not valid #%d:%#jx\n",
jt_cmdname(argv[0]), i,
(uintmax_t)data.ioc_obdo1.o_valid);
- rc = EINVAL;
- break;
- }
+ rc = EINVAL;
+ break;
+ }
if (be_verbose(verbose, &next_time, i, &next_count, count))
printf("%s: #%d is object id %#jx\n",
jt_cmdname(argv[0]), i,
(uintmax_t) ostid_id(&data.ioc_obdo1.o_oi));
- }
- return rc;
+ }
+
+ return rc;
}
int jt_obd_setattr(int argc, char **argv)
int mode;
int rc;
- memset(&data, 0, sizeof(data));
- data.ioc_dev = cur_device;
- if (argc != 2)
- return CMD_HELP;
-
- objid = strtoull(argv[1], &end, 0);
- if (*end) {
+ memset(&data, 0, sizeof(data));
+ data.ioc_dev = cur_device;
+ if (argc != 2)
+ return CMD_HELP;
+
+ objid = strtoull(argv[1], &end, 0);
+ if (*end) {
fprintf(stderr, "error: %s: objid '%s' is not a number\n",
jt_cmdname(argv[0]), argv[1]);
return CMD_HELP;
}
if (objid >= OBIF_MAX_OID) {
- fprintf(stderr, "error: %s: invalid objid '%s'\n",
- jt_cmdname(argv[0]), argv[1]);
- return CMD_HELP;
- }
+ fprintf(stderr, "error: %s: invalid objid '%s'\n",
+ jt_cmdname(argv[0]), argv[1]);
+ return CMD_HELP;
+ }
mode = strtoul(argv[2], &end, 0);
- if (*end) {
- fprintf(stderr, "error: %s: invalid mode '%s'\n",
- jt_cmdname(argv[0]), argv[2]);
- return CMD_HELP;
- }
+ if (*end) {
+ fprintf(stderr, "error: %s: invalid mode '%s'\n",
+ jt_cmdname(argv[0]), argv[2]);
+ return CMD_HELP;
+ }
ostid_set_seq_echo(&data.ioc_obdo1.o_oi);
data.ioc_obdo1.o_mode = S_IFREG | mode;
data.ioc_obdo1.o_oi.oi_fid.f_oid = objid;
data.ioc_obdo1.o_valid = OBD_MD_FLID | OBD_MD_FLTYPE | OBD_MD_FLMODE;
- memset(buf, 0, sizeof(rawbuf));
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_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_SETATTR, buf);
- if (rc < 0)
- fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
- strerror(rc = errno));
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_SETATTR, buf);
+ if (rc < 0)
+ fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
+ strerror(rc = errno));
- return rc;
+ return rc;
}
int jt_obd_test_setattr(int argc, char **argv)
{
- struct obd_ioctl_data data;
- struct timeval start, next_time;
+ struct obd_ioctl_data data;
+ struct timeval start, next_time;
__u64 i, count, next_count;
- char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
- int verbose = 1;
+ char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
+ int verbose = 1;
__u64 objid = 3;
- char *end;
- int rc = 0;
+ char *end;
+ int rc = 0;
- if (argc < 2 || argc > 4)
- return CMD_HELP;
+ if (argc < 2 || argc > 4)
+ return CMD_HELP;
- memset(&data, 0, sizeof(data));
- data.ioc_dev = cur_device;
- count = strtoull(argv[1], &end, 0);
- if (*end) {
- fprintf(stderr, "error: %s: invalid iteration count '%s'\n",
- jt_cmdname(argv[0]), argv[1]);
- return CMD_HELP;
- }
+ memset(&data, 0, sizeof(data));
+ data.ioc_dev = cur_device;
+ count = strtoull(argv[1], &end, 0);
+ if (*end) {
+ fprintf(stderr, "error: %s: invalid iteration count '%s'\n",
+ jt_cmdname(argv[0]), argv[1]);
+ return CMD_HELP;
+ }
if (argc >= 3) {
verbose = get_verbose(argv[0], argv[2]);
(uintmax_t)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++) {
+ for (i = 1, next_count = verbose; i <= count && shmem_running(); i++) {
if (objid >= OBIF_MAX_OID) {
fprintf(stderr, "errr: %s: invalid objid '%llu'\n",
jt_cmdname(argv[0]), objid);
}
data.ioc_obdo1.o_oi.oi_fid.f_oid = 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));
+ 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));
rc = llapi_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_SETATTR, &data);
- shmem_bump(1);
- if (rc < 0) {
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_SETATTR, &data);
+ shmem_bump(1);
+ if (rc < 0) {
fprintf(stderr, "error: %s: #%jd - %d:%s\n",
jt_cmdname(argv[0]), (uintmax_t)i,
errno, strerror(rc = errno));
- break;
- } else {
- if (be_verbose
- (verbose, &next_time, i, &next_count, count))
- printf("%s: set attr #%jd\n",
- jt_cmdname(argv[0]), (uintmax_t)i);
- }
- }
+ break;
+ }
+ if (be_verbose(verbose, &next_time, i, &next_count, count))
+ printf("%s: set attr #%jd\n",
+ jt_cmdname(argv[0]), (uintmax_t)i);
+ }
if (!rc) {
struct timeval end;
}
printf("%s: %jd objects\n", jt_cmdname(argv[0]), (uintmax_t)count);
- gettimeofday(&next_time, NULL);
- next_time.tv_sec -= verbose;
+ 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++) {
+ for (i = 1, next_count = verbose; i <= count && shmem_running();
+ i++, id++) {
if (id >= OBIF_MAX_OID) {
fprintf(stderr, "errr: %s: invalid objid '%llu'\n",
jt_cmdname(argv[0]), 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));
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_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_DESTROY, buf);
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_DESTROY, buf);
llapi_ioctl_unpack(&data, buf, sizeof(rawbuf));
- shmem_bump(1);
- if (rc < 0) {
+ shmem_bump(1);
+ if (rc < 0) {
fprintf(stderr, "error: %s: objid %#jx: %s\n",
jt_cmdname(argv[0]), (uintmax_t)id,
strerror(rc = errno));
- break;
- }
+ break;
+ }
- if (be_verbose(verbose, &next_time, i, &next_count, count))
+ if (be_verbose(verbose, &next_time, i, &next_count, count))
printf("%s: #%d is object id %#jx\n",
jt_cmdname(argv[0]), i, (uintmax_t)id);
- }
+ }
- return rc;
+ return rc;
}
int jt_obd_getattr(int argc, char **argv)
{
- struct obd_ioctl_data data;
- char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
+ struct obd_ioctl_data data;
+ char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
__u64 objid;
- char *end;
- int rc;
+ char *end;
+ int rc;
- if (argc != 2)
- return CMD_HELP;
+ if (argc != 2)
+ return CMD_HELP;
objid = strtoull(argv[1], &end, 0);
if (*end) {
printf("%s: object id %#jx\n", jt_cmdname(argv[0]),
(uintmax_t)ostid_id(&data.ioc_obdo1.o_oi));
- memset(buf, 0, sizeof(rawbuf));
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_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, buf);
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_GETATTR, buf);
llapi_ioctl_unpack(&data, buf, sizeof(rawbuf));
- if (rc) {
- fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
- strerror(rc = errno));
- } else {
+ if (rc) {
+ fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
+ strerror(rc = errno));
+ } else {
printf("%s: object id %ju, mode %o\n", jt_cmdname(argv[0]),
(uintmax_t)ostid_id(&data.ioc_obdo1.o_oi),
data.ioc_obdo1.o_mode);
- }
- return rc;
+ }
+ return rc;
}
int jt_obd_test_getattr(int argc, char **argv)
{
- struct obd_ioctl_data data;
- struct timeval start, next_time;
- char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
+ struct obd_ioctl_data data;
+ struct timeval start, next_time;
+ char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
__u64 i, count, next_count;
- int verbose = 1;
+ int verbose = 1;
__u64 objid = 3;
- char *end;
- int rc = 0;
+ char *end;
+ int rc = 0;
- if (argc < 2 || argc > 4)
- return CMD_HELP;
+ if (argc < 2 || argc > 4)
+ return CMD_HELP;
- memset(&data, 0, sizeof(data));
- data.ioc_dev = cur_device;
- count = strtoull(argv[1], &end, 0);
- if (*end) {
- fprintf(stderr, "error: %s: invalid iteration count '%s'\n",
- jt_cmdname(argv[0]), argv[1]);
- return CMD_HELP;
- }
+ memset(&data, 0, sizeof(data));
+ data.ioc_dev = cur_device;
+ count = strtoull(argv[1], &end, 0);
+ if (*end) {
+ fprintf(stderr, "error: %s: invalid iteration count '%s'\n",
+ jt_cmdname(argv[0]), argv[1]);
+ return CMD_HELP;
+ }
- if (argc >= 3) {
- verbose = get_verbose(argv[0], argv[2]);
- if (verbose == BAD_VERBOSE)
- return CMD_HELP;
- }
+ if (argc >= 3) {
+ verbose = get_verbose(argv[0], argv[2]);
+ if (verbose == BAD_VERBOSE)
+ return CMD_HELP;
+ }
- if (argc >= 4) {
- if (argv[3][0] == 't') {
- objid = strtoull(argv[3] + 1, &end, 0);
- if (thread)
- objid += thread - 1;
- } else
- objid = strtoull(argv[3], &end, 0);
- if (*end) {
- fprintf(stderr, "error: %s: invalid objid '%s'\n",
- jt_cmdname(argv[0]), argv[3]);
- return CMD_HELP;
- }
- }
+ if (argc >= 4) {
+ if (argv[3][0] == 't') {
+ objid = strtoull(argv[3] + 1, &end, 0);
+ if (thread)
+ objid += thread - 1;
+ } else
+ objid = strtoull(argv[3], &end, 0);
+ if (*end) {
+ fprintf(stderr, "error: %s: invalid objid '%s'\n",
+ jt_cmdname(argv[0]), argv[3]);
+ return CMD_HELP;
+ }
+ }
- gettimeofday(&start, NULL);
- next_time.tv_sec = start.tv_sec - verbose;
- next_time.tv_usec = start.tv_usec;
- if (verbose != 0)
+ gettimeofday(&start, NULL);
+ next_time.tv_sec = start.tv_sec - verbose;
+ next_time.tv_usec = start.tv_usec;
+ if (verbose != 0)
printf("%s: getting %jd attrs (objid %#jx): %s",
- jt_cmdname(argv[0]), (uintmax_t) count,
+ jt_cmdname(argv[0]), (uintmax_t)count,
(uintmax_t)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++) {
+ for (i = 1, next_count = verbose; i <= count && shmem_running(); i++) {
if (objid >= OBIF_MAX_OID) {
fprintf(stderr, "errr: %s: invalid objid '%llu'\n",
jt_cmdname(argv[0]), objid);
jt_cmdname(argv[0]));
return rc;
}
- rc = l2_ioctl(OBD_DEV_ID, OBD_IOC_GETATTR, &data);
- shmem_bump(1);
- if (rc < 0) {
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_GETATTR, &data);
+ shmem_bump(1);
+ if (rc < 0) {
fprintf(stderr, "error: %s: #%jd - %d:%s\n",
jt_cmdname(argv[0]), (uintmax_t)i,
errno, strerror(rc = errno));
- break;
- } else {
- if (be_verbose
- (verbose, &next_time, i, &next_count, count))
- printf("%s: got attr #%jd\n",
- jt_cmdname(argv[0]), (uintmax_t)i);
- }
- }
+ break;
+ }
+ if (be_verbose(verbose, &next_time, i, &next_count, count))
+ printf("%s: got attr #%jd\n",
+ jt_cmdname(argv[0]), (uintmax_t)i);
+ }
- if (!rc) {
- struct timeval end;
- double diff;
+ if (!rc) {
+ struct timeval end;
+ double diff;
- gettimeofday(&end, NULL);
+ gettimeofday(&end, NULL);
- diff = difftime(&end, &start);
+ diff = difftime(&end, &start);
- --i;
- if (verbose != 0)
+ --i;
+ if (verbose != 0)
printf("%s: %jd attrs in %.3fs (%.3f attr/s): %s",
- jt_cmdname(argv[0]), (uintmax_t) i, diff,
+ jt_cmdname(argv[0]), (uintmax_t)i, diff,
i / diff, ctime(&end.tv_sec));
- }
- return rc;
+ }
+
+ return rc;
}
/* test_brw <cnt> count
(uintmax_t)count, pages, (uintmax_t) objid,
(uintmax_t)data.ioc_offset, ctime(&start.tv_sec));
- cmd = write ? OBD_IOC_BRW_WRITE : OBD_IOC_BRW_READ;
- for (i = 1, next_count = verbose; i <= count && shmem_running(); i++) {
- data.ioc_obdo1.o_valid &= ~(OBD_MD_FLBLOCKS|OBD_MD_FLGRANT);
- memset(buf, 0, sizeof(rawbuf));
+ cmd = write ? OBD_IOC_BRW_WRITE : OBD_IOC_BRW_READ;
+ for (i = 1, next_count = verbose; i <= count && shmem_running(); i++) {
+ data.ioc_obdo1.o_valid &= ~(OBD_MD_FLBLOCKS|OBD_MD_FLGRANT);
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_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, cmd, buf);
- shmem_bump(1);
- if (rc) {
- fprintf(stderr, "error: %s: #%d - %s on %s\n",
- jt_cmdname(argv[0]), i, strerror(rc = errno),
- write ? "write" : "read");
- break;
- } else if (be_verbose(verbose, &next_time,i, &next_count,count)) {
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
+ rc = l_ioctl(OBD_DEV_ID, cmd, buf);
+ shmem_bump(1);
+ if (rc) {
+ fprintf(stderr, "error: %s: #%d - %s on %s\n",
+ jt_cmdname(argv[0]), i, strerror(rc = errno),
+ write ? "write" : "read");
+ break;
+ } else if (be_verbose(verbose, &next_time, i,
+ &next_count, count)) {
shmem_lock ();
printf("%s: %s number %d @ %jd:%ju for %d\n",
jt_cmdname(argv[0]), write ? "write" : "read", i,
(uintmax_t)data.ioc_offset,
(int)(pages * getpagesize()));
shmem_unlock ();
- }
+ }
if (!repeat_offset) {
#ifdef MAX_THREADS
data.ioc_inlbuf3 = (char *)obdgens;
if (llapi_ioctl_pack(&data, &buf, sizeof(rawbuf))) {
- fprintf(stderr, "error: %s: invalid ioctl\n",
- jt_cmdname(argv[0]));
- rc = -EINVAL;
- goto out_obdgens;
- }
- rc = ioctl(fd, OBD_IOC_LOV_GET_CONFIG, buf);
- if (rc == -ENOSPC) {
- free(uuidarray);
- free(obdgens);
- goto repeat;
- } else if (rc) {
- fprintf(stderr, "error: %s: ioctl error: %s\n",
- jt_cmdname(argv[0]), strerror(rc = errno));
- } else {
- struct obd_uuid *uuidp;
- __u32 *genp;
- int i;
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ rc = -EINVAL;
+ goto out_obdgens;
+ }
+ rc = ioctl(fd, OBD_IOC_LOV_GET_CONFIG, buf);
+ if (rc == -ENOSPC) {
+ free(uuidarray);
+ free(obdgens);
+ goto repeat;
+ } else if (rc) {
+ fprintf(stderr, "error: %s: ioctl error: %s\n",
+ jt_cmdname(argv[0]), strerror(rc = errno));
+ } else {
+ struct obd_uuid *uuidp;
+ __u32 *genp;
+ int i;
if (llapi_ioctl_unpack(&data, buf, sizeof(rawbuf))) {
fprintf(stderr, "error: %s: invalid reply\n",
static int do_activate(int argc, char **argv, int flag)
{
- struct obd_ioctl_data data;
- char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
- int rc;
+ struct obd_ioctl_data data;
+ char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
+ int rc;
- memset(&data, 0, sizeof(data));
- data.ioc_dev = cur_device;
- if (argc != 1)
- return CMD_HELP;
+ memset(&data, 0, sizeof(data));
+ data.ioc_dev = cur_device;
+ if (argc != 1)
+ return CMD_HELP;
- /* reuse offset for 'active' */
- data.ioc_offset = flag;
+ /* reuse offset for 'active' */
+ data.ioc_offset = flag;
- memset(buf, 0, sizeof(rawbuf));
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_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, IOC_OSC_SET_ACTIVE, buf);
- if (rc)
- fprintf(stderr, "error: %s: failed: %s\n",
- jt_cmdname(argv[0]), strerror(rc = errno));
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
+ rc = l_ioctl(OBD_DEV_ID, IOC_OSC_SET_ACTIVE, buf);
+ if (rc)
+ fprintf(stderr, "error: %s: failed: %s\n",
+ jt_cmdname(argv[0]), strerror(rc = errno));
- return rc;
+ return rc;
}
/**
return rc;
}
- rc = l2_ioctl(OBD_DEV_ID, OBD_IOC_REPLACE_NIDS, buf);
+ rc = l_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));
jt_cmdname(argv[0]));
return rc;
}
-
- rc = l2_ioctl(OBD_DEV_ID, OBD_IOC_CLEAR_CONFIGS, buf);
+
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_CLEAR_CONFIGS, 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);
+}
+
+int jt_obd_activate(int argc, char **argv)
+{
+ return do_activate(argc, argv, 1);
+}
+
+int jt_obd_recover(int argc, char **argv)
+{
+ char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
+ struct obd_ioctl_data data;
+ int rc;
+
+ memset(&data, 0, sizeof(data));
+ data.ioc_dev = cur_device;
+ if (argc > 2)
+ return CMD_HELP;
+
+ if (argc == 2) {
+ data.ioc_inllen1 = strlen(argv[1]) + 1;
+ data.ioc_inlbuf1 = argv[1];
+ }
+
+ memset(buf, 0, sizeof(rawbuf));
+ rc = llapi_ioctl_pack(&data, &buf, sizeof(rawbuf));
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_CLIENT_RECOVER, 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);
-}
-
-int jt_obd_activate(int argc, char **argv)
-{
- return do_activate(argc, argv, 1);
-}
-
-int jt_obd_recover(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 = cur_device;
- if (argc > 2)
- return CMD_HELP;
-
- if (argc == 2) {
- data.ioc_inllen1 = strlen(argv[1]) + 1;
- data.ioc_inlbuf1 = argv[1];
- }
-
- memset(buf, 0, sizeof(rawbuf));
- rc = llapi_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_CLIENT_RECOVER, buf);
- if (rc < 0) {
- fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
- strerror(rc = errno));
- }
-
- return rc;
-}
-
int jt_obd_mdc_lookup(int argc, char **argv)
{
- struct obd_ioctl_data data;
- char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
- char *parent, *child;
- int rc, fd, verbose = 1;
+ struct obd_ioctl_data data;
+ char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
+ char *parent, *child;
+ int rc, fd, verbose = 1;
- if (argc < 3 || argc > 4)
- return CMD_HELP;
+ if (argc < 3 || argc > 4)
+ return CMD_HELP;
- parent = argv[1];
- child = argv[2];
- if (argc == 4)
- verbose = get_verbose(argv[0], argv[3]);
+ parent = argv[1];
+ child = argv[2];
+ if (argc == 4)
+ verbose = get_verbose(argv[0], argv[3]);
- memset(&data, 0, sizeof(data));
- data.ioc_dev = cur_device;
+ memset(&data, 0, sizeof(data));
+ data.ioc_dev = cur_device;
- data.ioc_inllen1 = strlen(child) + 1;
- data.ioc_inlbuf1 = child;
+ data.ioc_inllen1 = strlen(child) + 1;
+ data.ioc_inlbuf1 = child;
- memset(buf, 0, sizeof(rawbuf));
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_ioctl_pack(&data, &buf, sizeof(rawbuf));
- if (rc) {
- fprintf(stderr, "error: %s: invalid ioctl\n",
- jt_cmdname(argv[0]));
- return rc;
- }
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
- fd = open(parent, O_RDONLY);
- if (fd < 0) {
- fprintf(stderr, "open \"%s\" failed: %s\n", parent,
- strerror(errno));
- return -1;
- }
+ fd = open(parent, O_RDONLY);
+ if (fd < 0) {
+ fprintf(stderr, "open \"%s\" failed: %s\n", parent,
+ strerror(errno));
+ return -1;
+ }
- rc = ioctl(fd, IOC_MDC_LOOKUP, buf);
- if (rc < 0) {
- fprintf(stderr, "error: %s: ioctl error: %s\n",
- jt_cmdname(argv[0]), strerror(rc = errno));
- }
- close(fd);
+ rc = ioctl(fd, IOC_MDC_LOOKUP, buf);
+ if (rc < 0) {
+ fprintf(stderr, "error: %s: ioctl error: %s\n",
+ jt_cmdname(argv[0]), strerror(rc = errno));
+ }
+ close(fd);
- if (verbose) {
+ if (verbose) {
rc = llapi_ioctl_unpack(&data, buf, sizeof(rawbuf));
if (rc) {
fprintf(stderr, "error: %s: invalid reply\n",
memset(&data, 0, sizeof(data));
data.ioc_dev = cur_device;
data.ioc_inllen1 = sizeof(rawbuf) - __ALIGN_KERNEL(sizeof(data), 8);
- memset(buf, 0, sizeof(rawbuf));
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_ioctl_pack(&data, &buf, sizeof(rawbuf));
- if (rc) {
- fprintf(stderr, "error: %s: invalid ioctl\n",
- jt_cmdname(argv[0]));
- return rc;
- }
- rc = l_ioctl(OBD_DEV_ID, OBD_IOC_CATLOGLIST, buf);
- if (rc == 0)
- fprintf(stdout, "%s", ((struct obd_ioctl_data*)buf)->ioc_bulk);
- else
- fprintf(stderr, "OBD_IOC_CATLOGLIST failed: %s\n",
- strerror(errno));
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(argv[0]));
+ return rc;
+ }
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_CATLOGLIST, buf);
+ if (rc == 0)
+ fprintf(stdout, "%s", ((struct obd_ioctl_data *)buf)->ioc_bulk);
+ else
+ fprintf(stderr, "OBD_IOC_CATLOGLIST failed: %s\n",
+ strerror(errno));
- return rc;
+ return rc;
}
int jt_llog_info(int argc, char **argv)
return 0;
}
+static int
+llog_process_records(int (record_cb)(const char *record, void *private),
+ const char *record, void *private, bool reverse)
+{
+ char *ptr = NULL;
+ char *tmp = NULL;
+ int rc = 0;
+
+ if (!reverse) {
+ do {
+ ptr = strchr(record, '\n');
+ if (ptr)
+ *ptr = '\0';
+ rc = record_cb(record, private);
+ if (rc)
+ goto out;
+ if (ptr)
+ record = ptr + 1;
+ } while (ptr && *(ptr + 1));
+ } else {
+ tmp = (char *)record;
+
+ ptr = strrchr(record, '\n');
+ if (ptr)
+ *ptr = '\0';
+ else
+ goto out;
+ while ((ptr = strrchr(record, '\n'))) {
+ tmp = ptr + 1;
+ *ptr = '\0';
+ rc = record_cb(tmp, private);
+ if (rc)
+ goto out;
+ };
+ rc = record_cb(record, private);
+ if (rc)
+ goto out;
+ }
+out:
+ return rc;
+}
+
/**
* Iterate over llog records, typically YAML-formatted configuration logs
*
* \param end[in] last record to process (inclusive)
* \param cb[in] callback for records. Return -ve error, or +ve abort.
* \param private[in,out] private data passed to the \a record_cb function
+ * \param reverse[in] print the llog records from the beginning or the end
+ *
+ * \retval 0 on success
+ * others handled by the caller
*/
int jt_llog_print_iter(char *logname, long start, long end,
int (record_cb)(const char *record, void *private),
- void *private)
+ void *private, bool reverse)
{
struct obd_ioctl_data data = { 0 };
char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf;
*/
for (rec = start; rec < end; rec += inc) {
char *record = ((struct obd_ioctl_data *)buf)->ioc_bulk;
- char *ptr;
retry:
snprintf(startbuf, sizeof(startbuf), "%lu", rec);
if (strcmp(record, logname) == 0)
break;
- do {
- ptr = strchr(record, '\n');
- if (ptr)
- *ptr = '\0';
- rc = record_cb(record, private);
- if (rc) {
- if (rc > 0)
- rc = 0;
- goto out;
- }
-
- if (ptr)
- record = ptr + 1;
- } while (ptr && *(ptr + 1));
+ rc = llog_process_records(record_cb, record, private, reverse);
+ if (rc)
+ goto out;
}
out:
if (rc)
return rc;
- rc = jt_llog_print_iter(catalog, start, end, jt_llog_print_cb, NULL);
+ rc = jt_llog_print_iter(catalog, start, end, jt_llog_print_cb,
+ NULL, false);
return rc;
}
static void signal_server(int sig)
{
- if (sig == SIGINT) {
- do_disconnect("sigint", 1);
- exit(1);
- } else
- fprintf(stderr, "%s: got signal %d\n", jt_cmdname("sigint"), sig);
+ if (sig == SIGINT) {
+ do_disconnect("sigint", 1);
+ exit(1);
+ } else {
+ fprintf(stderr, "%s: got signal %d\n", jt_cmdname("sigint"),
+ sig);
+ }
}
int obd_initialize(int argc, char **argv)
do_disconnect(argv[0], 1);
}
+/**
+ * Get the index of the last llog record
+ *
+ * logid: [0x3:0xa:0x0]:0
+ * flags: 4 (plain)
+ * records_count: 57
+ * last_index: 57
+ *
+ * \param logname[in] pointer to config log name
+ *
+ * \retval > 0 on success
+ * <= 0 on error
+ */
+static long llog_last_index(char *logname)
+{
+ struct obd_ioctl_data data = { 0 };
+ char rawbuf[MAX_IOC_BUFLEN] = "", *buf = rawbuf;
+ char *last_index;
+ long rc;
+
+ data.ioc_dev = cur_device;
+ data.ioc_inllen1 = strlen(logname) + 1;
+ data.ioc_inlbuf1 = logname;
+ data.ioc_inllen2 = sizeof(rawbuf) - __ALIGN_KERNEL(sizeof(data), 8) -
+ __ALIGN_KERNEL(data.ioc_inllen1, 8);
+ rc = llapi_ioctl_pack(&data, &buf, sizeof(rawbuf));
+ if (rc) {
+ fprintf(stderr, "%s: ioctl_pack failed for catalog '%s': %s\n",
+ __func__, logname, strerror(-rc));
+ return rc;
+ }
+
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_LLOG_INFO, buf);
+ if (rc == 0) {
+ last_index = strstr(((struct obd_ioctl_data *)buf)->ioc_bulk,
+ "last_index:");
+ return strtol(last_index + 11, NULL, 10);
+ } else {
+ rc = -errno;
+ }
+
+ return rc;
+}
+
+/**
+ * Callback to search ostname in llog
+ * - { index: 23, event: attach, device: lustre-OST0000-osc, type: osc,
+ * UUID: lustre-clilov_UUID }
+ * - { index: 24, event: setup, device: lustre-OST0000-osc,
+ * UUID: lustre-OST0000_UUID, node: 192.168.0.120@tcp }
+ * - { index: 25, event: add_osc, device: lustre-clilov,
+ * ost: lustre-OST0000_UUID, index: 0, gen: 1 }
+ *
+ * \param record[in] pointer to llog record
+ * \param data[in] pointer to ostname
+ *
+ * \retval 1 if ostname is found
+ * 0 if ostname is not found
+ * -ENOENT if ostname is deleted
+ */
+static int llog_search_ost_cb(const char *record, void *data)
+{
+ char *ostname = data;
+ char ost_filter[MAX_STRING_SIZE] = {'\0'};
+
+ if (ostname && ostname[0])
+ snprintf(ost_filter, sizeof(ost_filter), " %s,", ostname);
+
+ if (strstr(record, ost_filter)) {
+ if (strstr(record, "event: add_osc, ") ||
+ strstr(record, "event: setup, "))
+ return 1;
+ if (strstr(record, "event: del_osc, ") ||
+ strstr(record, "event: cleanup, "))
+ return -ENOENT;
+ }
+
+ return 0;
+}
+
+/**
+ * Search ost in llog
+ *
+ * \param logname[in] pointer to config log name
+ * \param last_index[in] the index of the last llog record
+ * \param ostname[in] pointer to ost name
+ *
+ * \retval 1 if ostname is found
+ * 0 if ostname is not found
+ */
+static int llog_search_ost(char *logname, long last_index, char *ostname)
+{
+ long start, end, inc = MAX_IOC_BUFLEN / 128;
+ int rc = 0;
+
+ for (end = last_index; end > 1; end -= inc) {
+ start = end - inc > 0 ? end - inc : 1;
+ rc = jt_llog_print_iter(logname, start, end, llog_search_ost_cb,
+ ostname, true);
+ if (rc)
+ break;
+ }
+
+ return (rc == 1 ? 1 : 0);
+}
+
+struct llog_pool_data {
+ char lpd_fsname[LUSTRE_MAXFSNAME + 1];
+ char lpd_poolname[LOV_MAXPOOLNAME + 1];
+ char lpd_ostname[MAX_OBD_NAME + 1];
+ enum lcfg_command_type lpd_cmd_type;
+ bool lpd_pool_exists;
+ int lpd_ost_num;
+};
+
+/**
+ * Called for each formatted line in the config log (within range).
+ *
+ * - { index: 74, event: new_pool, device: tfs-clilov, fsname: tfs, pool: tmp }
+ * - { index: 77, event: add_pool, device: tfs-clilov, fsname: tfs, pool: tmp,
+ * ost: tfs-OST0000_UUID }
+ * - { index: 224, event: remove_pool, device: tfs-clilov, fsname: tfs,
+ * pool: tmp, ost: tfs-OST0003_UUID }
+ * - { index: 227, event: del_pool, device: tfs-clilov, fsname: tfs, pool: tmp }
+ *
+ * \param record[in] pointer to llog record
+ * \param data[in] pointer to llog_pool_data
+ *
+ * \retval 1 if pool or OST is found
+ * 0 if pool or OST is not found
+ * -ENOENT if pool or OST is removed
+ */
+static int llog_search_pool_cb(const char *record, void *data)
+{
+ struct llog_pool_data *lpd = data;
+ char pool_filter[MAX_STRING_SIZE] = "";
+ char *found = NULL;
+ int fs_pool_len = 0;
+
+ fs_pool_len = 16 + strlen(lpd->lpd_fsname) + strlen(lpd->lpd_poolname);
+ snprintf(pool_filter, fs_pool_len + 1, "fsname: %s, pool: %s",
+ lpd->lpd_fsname, lpd->lpd_poolname);
+
+ /* search poolname */
+ found = strstr(record, pool_filter);
+ if (found &&
+ (found[fs_pool_len] == ' ' || found[fs_pool_len] == ',')) {
+ if (strstr(record, "event: new_pool,")) {
+ lpd->lpd_pool_exists = true;
+ return 1;
+ }
+ if (strstr(record, "event: del_pool,")) {
+ lpd->lpd_pool_exists = false;
+ return -ENOENT;
+ }
+
+ if (lpd->lpd_cmd_type == LCFG_POOL_NEW ||
+ lpd->lpd_cmd_type == LCFG_POOL_DEL) {
+ if (strstr(record, "event: add_pool,"))
+ lpd->lpd_ost_num++;
+ if (strstr(record, "event: remove_pool,"))
+ lpd->lpd_ost_num--;
+ } else if (lpd->lpd_ostname && lpd->lpd_ostname[0]) {
+ if (strstr(record, lpd->lpd_ostname)) {
+ lpd->lpd_pool_exists = true;
+ if (strstr(record, "event: add_pool,")) {
+ lpd->lpd_ost_num = 1;
+ return 1;
+ }
+ if (strstr(record, "event: remove_pool,")) {
+ lpd->lpd_ost_num = 0;
+ return -ENOENT;
+ }
+ }
+ }
+ }
+
+ return 0;
+}
+
+/* Search pool and its ost in llog
+ *
+ * \param logname[in] pointer to config log name
+ * \param last_index[in] the index of the last llog record
+ * \param fsname[in] pointer to filesystem name
+ * \param poolname[in] pointer pool name
+ * \param ostname[in] pointer to OST name(OSTnnnn-UUID)
+ * \param cmd[in] pool command type
+ *
+ * \retval < 0 on error
+ * 0 if pool is empty or OST is not found
+ * 1 if pool is not empty or OST is found
+ */
+static int llog_search_pool(char *logname, long last_index, char *fsname,
+ char *poolname, char *ostname,
+ enum lcfg_command_type cmd)
+{
+ struct llog_pool_data lpd;
+ long start, end, inc = MAX_IOC_BUFLEN / 128;
+ int rc = 0;
+
+ memset(&lpd, 0, sizeof(lpd));
+ lpd.lpd_cmd_type = cmd;
+ lpd.lpd_pool_exists = false;
+ lpd.lpd_ost_num = 0;
+ strncpy(lpd.lpd_fsname, fsname, sizeof(lpd.lpd_fsname) - 1);
+ if (poolname && poolname[0])
+ strncpy(lpd.lpd_poolname, poolname,
+ sizeof(lpd.lpd_poolname) - 1);
+ if (ostname && ostname[0])
+ strncpy(lpd.lpd_ostname, ostname, sizeof(lpd.lpd_ostname) - 1);
+
+ for (end = last_index; end > 1; end -= inc) {
+ start = end - inc > 0 ? end - inc : 1;
+ rc = jt_llog_print_iter(logname, start, end,
+ llog_search_pool_cb, &lpd, true);
+ if (rc) {
+ if (rc == 1 && lpd.lpd_pool_exists)
+ rc = lpd.lpd_ost_num ? 1 : 0;
+ else if (rc == -ENOENT && lpd.lpd_pool_exists &&
+ !lpd.lpd_ost_num)
+ rc = 0;
+ goto out;
+ }
+ }
+
+ rc = -ENOENT;
+out:
+ return rc;
+}
+
+static bool combined_mgs_mds(char *fsname)
+{
+ glob_t path;
+ int rc;
+
+ rc = cfs_get_param_paths(&path, "mdt/%s-MDT0000", fsname);
+ if (!rc)
+ cfs_free_param_data(&path);
+
+ if (get_mgs_device() > 0 && !rc)
+ return true;
+
+ return false;
+}
+
+/*
+ * if pool is NULL, search ostname in target_obd
+ * if pool is not NULL:
+ * - if pool not found returns errno < 0
+ * - if ostname is NULL, returns 1 if pool is not empty and 0 if pool empty
+ * - if ostname is not NULL, returns 1 if OST is in pool and 0 if not
+ */
+int lctl_search_ost(char *fsname, char *poolname, char *ostname,
+ enum lcfg_command_type cmd)
+{
+ char logname[MAX_OBD_NAME] = {'\0'};
+ long last_index;
+
+ if (fsname && fsname[0] == '\0')
+ fsname = NULL;
+ if (!fsname)
+ return -EINVAL;
+
+ if (combined_mgs_mds(fsname))
+ return llapi_search_ost(fsname, poolname, ostname);
+
+ /* fetch the last_index of llog record */
+ snprintf(logname, sizeof(logname), "%s-client", fsname);
+ last_index = llog_last_index(logname);
+ if (last_index < 0)
+ return last_index;
+
+ /* if pool is NULL, search ostname in target_obd */
+ if (!poolname && ostname)
+ return llog_search_ost(logname, last_index, ostname);
+
+ return llog_search_pool(logname, last_index, fsname, poolname,
+ ostname, cmd);
+}
+
static int check_pool_cmd(enum lcfg_command_type cmd,
char *fsname, char *poolname,
char *ostname)
{
int rc;
- rc = llapi_search_ost(fsname, poolname, ostname);
+ rc = lctl_search_ost(fsname, poolname, ostname, cmd);
if (rc < 0 && (cmd != LCFG_POOL_NEW)) {
fprintf(stderr, "Pool %s.%s not found\n",
fsname, poolname);
ostname, fsname, poolname);
return -EEXIST;
}
- rc = llapi_search_ost(fsname, NULL, ostname);
+ rc = lctl_search_ost(fsname, NULL, ostname, cmd);
if (rc == 0) {
fprintf(stderr, "OST %s is not part of the '%s' fs.\n",
ostname, fsname);
switch (cmd) {
case LCFG_POOL_NEW: {
do {
- rc = llapi_search_ost(fsname, poolname, NULL);
+ rc = lctl_search_ost(fsname, poolname, NULL, cmd);
if (rc == -ENODEV)
return rc;
if (rc < 0)
}
case LCFG_POOL_DEL: {
do {
- rc = llapi_search_ost(fsname, poolname, NULL);
+ rc = lctl_search_ost(fsname, poolname, NULL, cmd);
if (rc == -ENODEV)
return rc;
if (rc >= 0)
}
case LCFG_POOL_ADD: {
do {
- rc = llapi_search_ost(fsname, poolname, ostname);
+ rc = lctl_search_ost(fsname, poolname, ostname, cmd);
if (rc == -ENODEV)
return rc;
if (rc != 1)
}
case LCFG_POOL_REM: {
do {
- rc = llapi_search_ost(fsname, poolname, ostname);
+ rc = lctl_search_ost(fsname, poolname, ostname, cmd);
if (rc == -ENODEV)
return rc;
if (rc == 1)
return -ENOMEM;
lustre_cfg_init(lcfg, cmd, &bufs);
- memset(&data, 0, sizeof(data));
- rc = data.ioc_dev = get_mgs_device();
- if (rc < 0)
- goto out;
+ memset(&data, 0, sizeof(data));
+ rc = data.ioc_dev = get_mgs_device();
+ if (rc < 0)
+ goto out;
- data.ioc_type = LUSTRE_CFG_TYPE;
- data.ioc_plen1 = lustre_cfg_len(lcfg->lcfg_bufcount,
- lcfg->lcfg_buflens);
- data.ioc_pbuf1 = (void *)lcfg;
+ data.ioc_type = LUSTRE_CFG_TYPE;
+ data.ioc_plen1 = lustre_cfg_len(lcfg->lcfg_bufcount,
+ lcfg->lcfg_buflens);
+ data.ioc_pbuf1 = (void *)lcfg;
- memset(buf, 0, sizeof(rawbuf));
+ memset(buf, 0, sizeof(rawbuf));
rc = llapi_ioctl_pack(&data, &buf, sizeof(rawbuf));
- if (rc) {
- fprintf(stderr, "error: %s: invalid ioctl\n",
- jt_cmdname(cmdname));
+ if (rc) {
+ fprintf(stderr, "error: %s: invalid ioctl\n",
+ jt_cmdname(cmdname));
free(lcfg);
- return rc;
- }
- rc = l_ioctl(OBD_DEV_ID, OBD_IOC_POOL, buf);
+ return rc;
+ }
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_POOL, buf);
out:
- if (rc)
- rc = -errno;
+ if (rc)
+ rc = -errno;
switch (rc) {
case -ENAMETOOLONG:
fprintf(stderr, "error: %s: either the pool or file "
data.ioc_inlbuf2 = (char *) &version;
data.ioc_inllen2 = sizeof version;
- memset(buf, 0, sizeof *buf);
- rc = llapi_ioctl_pack(&data, &buf, sizeof rawbuf);
- if (rc) {
- fprintf(stderr, "error: %s: packing ioctl arguments: %s\n",
- jt_cmdname(argv[0]), strerror(-rc));
- return rc;
- }
+ memset(buf, 0, sizeof *buf);
+ rc = llapi_ioctl_pack(&data, &buf, sizeof(rawbuf));
+ if (rc) {
+ fprintf(stderr, "error: %s: packing ioctl arguments: %s\n",
+ jt_cmdname(argv[0]), strerror(-rc));
+ return rc;
+ }
- rc = l2_ioctl(OBD_DEV_ID, OBD_IOC_GET_OBJ_VERSION, buf);
- if (rc == -1) {
- fprintf(stderr, "error: %s: ioctl: %s\n",
- jt_cmdname(argv[0]), strerror(errno));
- return -errno;
- }
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_GET_OBJ_VERSION, buf);
+ if (rc == -1) {
+ fprintf(stderr, "error: %s: ioctl: %s\n",
+ jt_cmdname(argv[0]), strerror(errno));
+ return -errno;
+ }
llapi_ioctl_unpack(&data, buf, sizeof rawbuf);
printf("%#jx\n", (uintmax_t)version);
- return 0;
+
+ return 0;
}
int jt_changelog_register(int argc, char **argv)
return rc;
}
- rc = l2_ioctl(OBD_DEV_ID, OBD_IOC_CHANGELOG_REG, buf);
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_CHANGELOG_REG, buf);
if (rc < 0) {
rc = -errno;
fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
return rc;
}
- rc = l2_ioctl(OBD_DEV_ID, OBD_IOC_CHANGELOG_DEREG, buf);
+ rc = l_ioctl(OBD_DEV_ID, OBD_IOC_CHANGELOG_DEREG, buf);
if (rc < 0) {
fprintf(stderr, "error: %s: %s\n", jt_cmdname(argv[0]),
strerror(rc = errno));