X-Git-Url: https://git.whamcloud.com/?p=fs%2Flustre-release.git;a=blobdiff_plain;f=lustre%2Futils%2Flustre_lfsck.c;h=b6bef2a8c3ed3611c837cbaf827d39f7121a61db;hp=4f04f0241ef9fce17771f4f25ec724c43440228c;hb=cd1faa0124f21e12a5ecd83c709c13918264fc86;hpb=a44f229bcfd8636517460788753070f8af2b0ebf diff --git a/lustre/utils/lustre_lfsck.c b/lustre/utils/lustre_lfsck.c index 4f04f02..b6bef2a 100644 --- a/lustre/utils/lustre_lfsck.c +++ b/lustre/utils/lustre_lfsck.c @@ -20,7 +20,7 @@ * GPL HEADER END */ /* - * Copyright (c) 2012, 2013, Intel Corporation. + * Copyright (c) 2012, 2017, Intel Corporation. */ /* * lustre/utils/lustre_lfsck.c @@ -36,100 +36,150 @@ #include #include #include +#include #include #include "obdctl.h" +#include "lustreapi_internal.h" -#include -#include -#include -#include +#include +#include +#include +/* Needs to be last to avoid clashes */ +#include +#include static struct option long_opt_start[] = { - {"device", required_argument, 0, 'M'}, - {"all", no_argument, 0, 'A'}, - {"create_ostobj", optional_argument, 0, 'c'}, - {"error", required_argument, 0, 'e'}, - {"help", no_argument, 0, 'h'}, - {"dryrun", optional_argument, 0, 'n'}, - {"orphan", no_argument, 0, 'o'}, - {"reset", no_argument, 0, 'r'}, - {"speed", required_argument, 0, 's'}, - {"type", required_argument, 0, 't'}, - {"windows", required_argument, 0, 'w'}, - {0, 0, 0, 0 } -}; +{ .val = 'A', .name = "all", .has_arg = no_argument }, +{ .val = 'c', .name = "create_ostobj", .has_arg = optional_argument }, +{ .val = 'c', .name = "create-ostobj", .has_arg = optional_argument }, +{ .val = 'C', .name = "create_mdtobj", .has_arg = optional_argument }, +{ .val = 'C', .name = "create-mdtobj", .has_arg = optional_argument }, +{ .val = 'd', .name = "delay_create_ostobj", .has_arg = optional_argument }, +{ .val = 'd', .name = "delay-create-ostobj", .has_arg = optional_argument }, +{ .val = 'e', .name = "error", .has_arg = required_argument }, +{ .val = 'h', .name = "help", .has_arg = no_argument }, +{ .val = 'M', .name = "device", .has_arg = required_argument }, +{ .val = 'n', .name = "dryrun", .has_arg = optional_argument }, +{ .val = 'o', .name = "orphan", .has_arg = no_argument }, +{ .val = 'r', .name = "reset", .has_arg = no_argument }, +{ .val = 's', .name = "speed", .has_arg = required_argument }, +{ .val = 't', .name = "type", .has_arg = required_argument }, +{ .val = 'w', .name = "window_size", .has_arg = required_argument }, +{ .val = 'w', .name = "window-size", .has_arg = required_argument }, +{ .name = NULL } }; static struct option long_opt_stop[] = { - {"device", required_argument, 0, 'M'}, - {"all", no_argument, 0, 'A'}, - {"help", no_argument, 0, 'h'}, - {0, 0, 0, 0} -}; + { .val = 'A', .name = "all", .has_arg = no_argument }, + { .val = 'h', .name = "help", .has_arg = no_argument }, + { .val = 'M', .name = "device", .has_arg = required_argument }, + { .name = NULL } }; + +static struct option long_opt_query[] = { + { .val = 'h', .name = "help", .has_arg = no_argument }, + { .val = 'M', .name = "device", .has_arg = required_argument }, + { .val = 't', .name = "type", .has_arg = required_argument }, + { .val = 'w', .name = "wait", .has_arg = no_argument }, + { .name = NULL } }; struct lfsck_type_name { - char *name; - int namelen; - enum lfsck_type type; + char *ltn_name; + enum lfsck_type ltn_type; }; +/* Note types must be in order of increasing value so we can iterate through + * this correctly. See enum lfsck_type for values. LU-9894. */ static struct lfsck_type_name lfsck_types_names[] = { - { "layout", 6, LT_LAYOUT }, - { "namespace", 9, LT_NAMESPACE}, - { 0, 0, 0 } -}; + { .ltn_name = "layout", .ltn_type = LFSCK_TYPE_LAYOUT }, + { .ltn_name = "namespace", .ltn_type = LFSCK_TYPE_NAMESPACE }, + { .ltn_name = "scrub", .ltn_type = LFSCK_TYPE_SCRUB }, + { .ltn_name = "all", .ltn_type = LFSCK_TYPES_SUPPORTED }, + { .ltn_name = "default", .ltn_type = LFSCK_TYPES_DEF }, + { .ltn_name = NULL } }; + +static enum lfsck_type lfsck_name2type(const char *name) +{ + int i; -static inline int lfsck_name2type(const char *name, int namelen) + for (i = 0; lfsck_types_names[i].ltn_name != NULL; i++) { + if (strcmp(lfsck_types_names[i].ltn_name, name) == 0) + return lfsck_types_names[i].ltn_type; + } + return -1; +} + +static const char *lfsck_type2name(__u16 type) { - int i = 0; + int i; - while (lfsck_types_names[i].name != NULL) { - if (namelen == lfsck_types_names[i].namelen && - strncmp(lfsck_types_names[i].name, name, namelen) == 0) - return lfsck_types_names[i].type; - i++; + for (i = 0; lfsck_types_names[i].ltn_name != NULL; i++) { + if (type == lfsck_types_names[i].ltn_type) + return lfsck_types_names[i].ltn_name; } - return 0; + + return NULL; } static void usage_start(void) { - fprintf(stderr, "Start LFSCK.\n" - "SYNOPSIS:\n" - "lfsck_start <-M | --device [MDT,OST]_device>\n" - " [-A | --all] [-c | --create_ostobj [swtich]]\n" - " [-e | --error error_handle] [-h | --help]\n" - " [-n | --dryrun [switch]] [-o | --orphan]\n" - " [-r | --reset] [-s | --speed speed_limit]\n" - " [-t | --type lfsck_type[,lfsck_type...]]\n" - " [-w | --windows win_size]\n" - "OPTIONS:\n" - "-M: The device to start LFSCK/scrub on.\n" - "-A: Start LFSCK on all MDT devices.\n" - "-c: create the lost OST-object for dangling LOV EA. " - "'off'(default) or 'on'.\n" - "-e: Error handle, 'continue'(default) or 'abort'.\n" - "-h: Help information.\n" - "-n: Check without modification. 'off'(default) or 'on'.\n" - "-o: handle orphan objects.\n" - "-r: Reset scanning start position to the device beginning.\n" - "-s: How many items can be scanned at most per second. " - "'%d' means no limit (default).\n" - "-t: The LFSCK type(s) to be started.\n" - "-w: The windows size for async requests pipeline.\n", + fprintf(stdout, "start LFSCK\n" + "usage:\n" + "lfsck_start [-M | --device {MDT,OST}_device]\n" + " [-A | --all] [-c | --create_ostobj [on | off]]\n" + " [-C | --create_mdtobj [on | off]]\n" + " [-d | --delay_create_ostobj [on | off]]\n" + " [-e | --error {continue | abort}] [-h | --help]\n" + " [-n | --dryrun [on | off]] [-o | --orphan]\n" + " [-r | --reset] [-s | --speed ops_per_sec_limit]\n" + " [-t | --type check_type[,check_type...]]\n" + " [-w | --window_size size]\n" + "options:\n" + "-M: device to start LFSCK/scrub on\n" + "-A: start LFSCK on all nodes via the specified MDT device " + "(see \"-M\" option) by single LFSCK command\n" + "-c: create the lost OST-object for dangling LOV EA " + "(default 'off', or 'on')\n" + "-C: create the lost MDT-object for dangling name entry " + "(default 'off', or 'on')\n" + "-d: delay create the lost OST-object for dangling LOV EA " + "until orphan OST-objects handled (default 'off', or 'on')\n" + "-e: error handle mode (default 'continue', or 'abort')\n" + "-h: this help message\n" + "-n: check with no modification (default 'off', or 'on')\n" + "-o: repair orphan OST-objects\n" + "-r: reset scanning to the start of the device\n" + "-s: maximum items to be scanned per second " + "(default '%d' = no limit)\n" + "-t: check type(s) to be performed (default all)\n" + "-w: window size for async requests pipeline\n", LFSCK_SPEED_NO_LIMIT); } static void usage_stop(void) { - fprintf(stderr, "Stop LFSCK.\n" - "SYNOPSIS:\n" - "lfsck_stop <-M | --device [MDT,OST]_device>\n" - "[-A | --all] [-h | --help]\n" - "OPTIONS:\n" - "-M: The device to stop LFSCK/scrub on.\n" - "-A: Stop LFSCK on all MDT devices.\n" - "-h: Help information.\n"); + fprintf(stdout, "stop LFSCK\n" + "usage:\n" + "lfsck_stop [-M | --device {MDT,OST}_device]\n" + " [-A | --all] [-h | --help]\n" + "options:\n" + "-M: device to stop LFSCK/scrub on\n" + "-A: stop LFSCK on all nodes via the specified MDT device " + "(see \"-M\" option) by single LFSCK command\n" + "-h: this help message\n"); +} + +static void usage_query(void) +{ + fprintf(stdout, "check the LFSCK global status\n" + "usage:\n" + "lfsck_query [-M | --device MDT_device] [-h | --help]\n" + " [-t | --type check_type[,check_type...]]\n" + " [-t | --wait]\n" + "options:\n" + "-M: device to query LFSCK on\n" + "-t: LFSCK type(s) to be queried (default is all)\n" + "-h: this help message\n" + "-w: do not return until LFSCK not running\n"); } static int lfsck_pack_dev(struct obd_ioctl_data *data, char *device, char *arg) @@ -149,32 +199,115 @@ static int lfsck_pack_dev(struct obd_ioctl_data *data, char *device, char *arg) return 0; } +static int lfsck_get_dev_name(struct obd_ioctl_data *data, char *device, + int types, bool multipe_devices) +{ + glob_t param = { 0 }; + size_t count = 0; + char *ptr; + int rc; + int i; + + rc = cfs_get_param_paths(¶m, "mdd/*-MDT*"); + if (rc) { + if (multipe_devices || errno != ENOENT || + types & LFSCK_TYPE_NAMESPACE) { + fprintf(stderr, "Fail to get device name: rc = %d\n." + "You can specify the device explicitly " + "via '-M' option.\n", rc); + return rc; + } + + rc = cfs_get_param_paths(¶m, "obdfilter/*-OST*"); + if (rc) { + fprintf(stderr, "Fail to get device name: rc = %d\n." + "You can specify the device explicitly " + "via '-M' option.\n", rc); + return rc; + } + } + + /* we have both sysfs and debugfs entries so to get the correct number + * of devices only count the entries in the sysfs tree + */ + for (i = 0; i < param.gl_pathc; i++) { + if (strstr(param.gl_pathv[i], "/sys/kernel/debug/lustre")) + continue; + count++; + } + + if (count == 1) + goto pack; + + if (!multipe_devices) { + fprintf(stderr, + "Detect multiple devices on current node. " + "Please specify the device explicitly " + "via '-M' option or '-A' option for all.\n"); + rc = -EINVAL; + goto out; + } + + ptr = strrchr(param.gl_pathv[0], '-'); + if (ptr == NULL) { + rc = -EINVAL; + goto out; + } + + for (i = 1; i < param.gl_pathc; i++) { + char *ptr2; + + if (strstr(param.gl_pathv[i], "/sys/kernel/debug/lustre")) + continue; + + ptr2 = strrchr(param.gl_pathv[i], '-'); + if (ptr2 == NULL) { + rc = -EINVAL; + goto out; + } + + if ((ptr - param.gl_pathv[0]) != (ptr2 - param.gl_pathv[i]) || + strncmp(param.gl_pathv[0], param.gl_pathv[i], + (ptr - param.gl_pathv[0])) != 0) { + fprintf(stderr, + "Detect multiple filesystems on current node. " + "Please specify the device explicitly " + "via '-M' option.\n"); + rc = -EINVAL; + goto out; + } + } + +pack: + rc = lfsck_pack_dev(data, device, basename(param.gl_pathv[0])); + +out: + cfs_free_param_data(¶m); + + return rc; +} + int jt_lfsck_start(int argc, char **argv) { struct obd_ioctl_data data; char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf; char device[MAX_OBD_NAME]; struct lfsck_start start; - char *optstring = "M:Ac::e:hn::ors:t:w:"; - int opt, index, rc, val, i, type; + char *short_opts = "Ac::C::d::e:hM:n::ors:t:w:"; + int opt, index, rc, val, i; memset(&data, 0, sizeof(data)); memset(&start, 0, sizeof(start)); memset(device, 0, MAX_OBD_NAME); start.ls_version = LFSCK_VERSION_V1; - start.ls_active = LFSCK_TYPES_DEF; + start.ls_active = LFSCK_TYPES_ALL; /* Reset the 'optind' for the case of getopt_long() called multiple * times under the same lctl. */ optind = 0; - while ((opt = getopt_long(argc, argv, optstring, long_opt_start, + while ((opt = getopt_long(argc, argv, short_opts, long_opt_start, &index)) != EOF) { switch (opt) { - case 'M': - rc = lfsck_pack_dev(&data, device, optarg); - if (rc != 0) - return rc; - break; case 'A': start.ls_flags |= LPF_ALL_TGT | LPF_BROADCAST; break; @@ -182,22 +315,48 @@ int jt_lfsck_start(int argc, char **argv) if (optarg == NULL || strcmp(optarg, "on") == 0) { start.ls_flags |= LPF_CREATE_OSTOBJ; } else if (strcmp(optarg, "off") != 0) { - fprintf(stderr, "Invalid switch: %s. " - "The valid switch should be: 'on' " - "or 'off' (default) without blank, " - "or empty. For example: '-non' or " - "'-noff' or '-n'.\n", optarg); + fprintf(stderr, "invalid switch: -c '%s'. " + "valid switches are:\n" + "empty ('on'), or 'off' without space. " + "For example:\n" + "'-c', '-con', '-coff'\n", optarg); return -EINVAL; } start.ls_valid |= LSV_CREATE_OSTOBJ; break; + case 'C': + if (optarg == NULL || strcmp(optarg, "on") == 0) { + start.ls_flags |= LPF_CREATE_MDTOBJ; + } else if (strcmp(optarg, "off") != 0) { + fprintf(stderr, "invalid switch: -C '%s'. " + "valid switches are:\n" + "empty ('on'), or 'off' without space. " + "For example:\n" + "'-C', '-Con', '-Coff'\n", optarg); + return -EINVAL; + } + start.ls_valid |= LSV_CREATE_MDTOBJ; + break; + case 'd': + if (optarg == NULL || strcmp(optarg, "on") == 0) { + start.ls_flags |= LPF_DELAY_CREATE_OSTOBJ; + } else if (strcmp(optarg, "off") != 0) { + fprintf(stderr, "invalid switch: -c '%s'. " + "valid switches are:\n" + "empty ('on'), or 'off' without space. " + "For example:\n" + "'-c', '-con', '-coff'\n", optarg); + return -EINVAL; + } + start.ls_valid |= LSV_DELAY_CREATE_OSTOBJ; + break; case 'e': if (strcmp(optarg, "abort") == 0) { start.ls_flags |= LPF_FAILOUT; } else if (strcmp(optarg, "continue") != 0) { - fprintf(stderr, "Invalid error handler: %s. " - "The valid value should be: 'continue'" - "(default) or 'abort'.\n", optarg); + fprintf(stderr, "invalid error mode: -e '%s'." + "valid modes are: " + "'continue' or 'abort'.\n", optarg); return -EINVAL; } start.ls_valid |= LSV_ERROR_HANDLE; @@ -205,22 +364,27 @@ int jt_lfsck_start(int argc, char **argv) case 'h': usage_start(); return 0; + case 'M': + rc = lfsck_pack_dev(&data, device, optarg); + if (rc != 0) + return rc; + break; case 'n': if (optarg == NULL || strcmp(optarg, "on") == 0) { start.ls_flags |= LPF_DRYRUN; } else if (strcmp(optarg, "off") != 0) { - fprintf(stderr, "Invalid switch: %s. " - "The valid switch should be: 'on' " - "or 'off' (default) without blank, " - "or empty. For example: '-non' or " - "'-noff' or '-n'.\n", optarg); + fprintf(stderr, "invalid switch: -n '%s'. " + "valid switches are:\n" + "empty ('on'), or 'off' without space. " + "For example:\n" + "'-n', '-non', '-noff'\n", optarg); return -EINVAL; } start.ls_valid |= LSV_DRYRUN; break; case 'o': start.ls_flags |= LPF_ALL_TGT | LPF_BROADCAST | - LPF_ORPHAN; + LPF_OST_ORPHAN; break; case 'r': start.ls_flags |= LPF_RESET; @@ -231,55 +395,35 @@ int jt_lfsck_start(int argc, char **argv) start.ls_valid |= LSV_SPEED_LIMIT; break; case 't': { - char *str = optarg, *p, c; - - start.ls_active = 0; - while (*str) { - while (*str == ' ' || *str == ',') - str++; - - if (*str == 0) - break; - - p = str; - while (*p != 0 && *p != ' ' && *p != ',') - p++; - - c = *p; - *p = 0; - type = lfsck_name2type(str, strlen(str)); - if (type == 0) { - fprintf(stderr, "Invalid type (%s).\n" - "The valid value should be " - "'layout' or 'namespace'.\n", - str); - *p = c; - return -EINVAL; - } - - *p = c; - str = p; + char *typename; + + if (start.ls_active == LFSCK_TYPES_ALL) + start.ls_active = 0; + while ((typename = strsep(&optarg, ",")) != NULL) { + enum lfsck_type type; + type = lfsck_name2type(typename); + if (type == -1) + goto bad_type; start.ls_active |= type; } - if (start.ls_active == 0) { - fprintf(stderr, "Miss LFSCK type(s).\n" - "The valid value should be " - "'layout' or 'namespace'.\n"); - return -EINVAL; - } break; +bad_type: + fprintf(stderr, "invalid check type -t '%s'. " + "valid types are:\n", typename); + for (i = 0; lfsck_types_names[i].ltn_name != NULL; i++) + fprintf(stderr, "%s%s", i != 0 ? "," : "", + lfsck_types_names[i].ltn_name); + fprintf(stderr, "\n"); + return -EINVAL; } case 'w': val = atoi(optarg); - if (val < 0 || val > LFSCK_ASYNC_WIN_MAX) { + if (val < 1 || val > LFSCK_ASYNC_WIN_MAX) { fprintf(stderr, - "Too large async windows size, " - "which may cause memory issues. " - "The valid range is [0 - %u]. " - "If you do not want to restrict " - "the windows size for async reqeusts " - "pipeline, just set it as 0.\n", + "Invalid async window size that " + "may cause memory issues. The valid " + "range is [1 - %u].\n", LFSCK_ASYNC_WIN_MAX); return -EINVAL; } @@ -293,23 +437,21 @@ int jt_lfsck_start(int argc, char **argv) } } + if (start.ls_active == LFSCK_TYPES_ALL) + start.ls_active = LFSCK_TYPES_DEF; + if (data.ioc_inlbuf4 == NULL) { - if (lcfg_get_devname() != NULL) { - rc = lfsck_pack_dev(&data, device, lcfg_get_devname()); - if (rc != 0) - return rc; - } else { - fprintf(stderr, - "Must specify device to start LFSCK.\n"); - return -EINVAL; - } + rc = lfsck_get_dev_name(&data, device, start.ls_active, + start.ls_flags & LPF_ALL_TGT); + if (rc != 0) + return rc; } data.ioc_inlbuf1 = (char *)&start; data.ioc_inllen1 = sizeof(start); memset(buf, 0, sizeof(rawbuf)); - rc = obd_ioctl_pack(&data, &buf, sizeof(rawbuf)); - if (rc) { + rc = llapi_ioctl_pack(&data, &buf, sizeof(rawbuf)); + if (rc != 0) { fprintf(stderr, "Fail to pack ioctl data: rc = %d.\n", rc); return rc; } @@ -320,23 +462,18 @@ int jt_lfsck_start(int argc, char **argv) return rc; } - obd_ioctl_unpack(&data, buf, sizeof(rawbuf)); - if (start.ls_active == 0) { - printf("Started LFSCK on the device %s", device); - } else { - printf("Started LFSCK on the device %s:", device); - i = 0; - while (lfsck_types_names[i].name != NULL) { - if (start.ls_active & lfsck_types_names[i].type) { - printf(" %s", lfsck_types_names[i].name); - start.ls_active &= ~lfsck_types_names[i].type; - } - i++; + llapi_ioctl_unpack(&data, buf, sizeof(rawbuf)); + printf("Started LFSCK on the device %s: scrub", device); + for (i = 0; lfsck_types_names[i].ltn_name != NULL; i++) { + if (start.ls_active & lfsck_types_names[i].ltn_type) { + printf(" %s", lfsck_types_names[i].ltn_name); + start.ls_active &= ~lfsck_types_names[i].ltn_type; } - if (start.ls_active != 0) - printf(" unknown(0x%x)", start.ls_active); } - printf(".\n"); + if (start.ls_active != 0) + printf(" unknown(0x%x)", start.ls_active); + printf("\n"); + return 0; } @@ -346,7 +483,7 @@ int jt_lfsck_stop(int argc, char **argv) char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf; char device[MAX_OBD_NAME]; struct lfsck_stop stop; - char *optstring = "M:Ah"; + char *short_opts = "AhM:"; int opt, index, rc; memset(&data, 0, sizeof(data)); @@ -356,20 +493,20 @@ int jt_lfsck_stop(int argc, char **argv) /* Reset the 'optind' for the case of getopt_long() called multiple * times under the same lctl. */ optind = 0; - while ((opt = getopt_long(argc, argv, optstring, long_opt_stop, + while ((opt = getopt_long(argc, argv, short_opts, long_opt_stop, &index)) != EOF) { switch (opt) { - case 'M': - rc = lfsck_pack_dev(&data, device, optarg); - if (rc != 0) - return rc; - break; case 'A': stop.ls_flags |= LPF_ALL_TGT | LPF_BROADCAST; break; case 'h': usage_stop(); return 0; + case 'M': + rc = lfsck_pack_dev(&data, device, optarg); + if (rc != 0) + return rc; + break; default: fprintf(stderr, "Invalid option, '-h' for help.\n"); return -EINVAL; @@ -377,22 +514,17 @@ int jt_lfsck_stop(int argc, char **argv) } if (data.ioc_inlbuf4 == NULL) { - if (lcfg_get_devname() != NULL) { - rc = lfsck_pack_dev(&data, device, lcfg_get_devname()); - if (rc != 0) - return rc; - } else { - fprintf(stderr, - "Must specify device to stop LFSCK.\n"); - return -EINVAL; - } + rc = lfsck_get_dev_name(&data, device, 0, + stop.ls_flags & LPF_ALL_TGT); + if (rc != 0) + return rc; } data.ioc_inlbuf1 = (char *)&stop; data.ioc_inllen1 = sizeof(stop); memset(buf, 0, sizeof(rawbuf)); - rc = obd_ioctl_pack(&data, &buf, sizeof(rawbuf)); - if (rc) { + rc = llapi_ioctl_pack(&data, &buf, sizeof(rawbuf)); + if (rc != 0) { fprintf(stderr, "Fail to pack ioctl data: rc = %d.\n", rc); return rc; } @@ -406,3 +538,99 @@ int jt_lfsck_stop(int argc, char **argv) printf("Stopped LFSCK on the device %s.\n", device); return 0; } + +int jt_lfsck_query(int argc, char **argv) +{ + struct obd_ioctl_data data = { 0 }; + char rawbuf[MAX_IOC_BUFLEN], *buf = rawbuf; + char device[MAX_OBD_NAME] = ""; + struct lfsck_query query = { .lu_types = LFSCK_TYPES_ALL }; + int opt, index, rc, i; + enum lfsck_type type; + + while ((opt = getopt_long(argc, argv, "hM:t:w", long_opt_query, + &index)) != EOF) { + switch (opt) { + case 'h': + usage_query(); + return 0; + case 'M': + rc = lfsck_pack_dev(&data, device, optarg); + if (rc != 0) + return rc; + break; + case 't': { + char *typename; + + if (query.lu_types == LFSCK_TYPES_ALL) + query.lu_types = 0; + while ((typename = strsep(&optarg, ",")) != NULL) { + type = lfsck_name2type(typename); + if (type == -1) + goto bad_type; + query.lu_types |= type; + } + break; + +bad_type: + fprintf(stderr, "invalid LFSCK type -t '%s'. " + "valid types are:\n", typename); + for (i = 0; lfsck_types_names[i].ltn_name != NULL; i++) + fprintf(stderr, "%s%s", i != 0 ? "," : "", + lfsck_types_names[i].ltn_name); + fprintf(stderr, "\n"); + return -EINVAL; + } + case 'w': + query.lu_flags |= LPF_WAIT; + break; + default: + fprintf(stderr, "Invalid option, '-h' for help.\n"); + usage_query(); + return -EINVAL; + } + } + + if (data.ioc_inlbuf4 == NULL) { + rc = lfsck_get_dev_name(&data, device, 0, true); + if (rc != 0) + return rc; + } + + data.ioc_inlbuf1 = (char *)&query; + data.ioc_inllen1 = sizeof(query); + memset(buf, 0, sizeof(rawbuf)); + rc = llapi_ioctl_pack(&data, &buf, sizeof(rawbuf)); + if (rc != 0) { + fprintf(stderr, "Fail to pack ioctl data: rc = %d.\n", rc); + return rc; + } + + rc = l_ioctl(OBD_DEV_ID, OBD_IOC_QUERY_LFSCK, buf); + if (rc < 0) { + perror("Fail to query LFSCK"); + return rc; + } + + llapi_ioctl_unpack(&data, buf, sizeof(rawbuf)); + for (i = 0, type = 1 << i; i < LFSCK_TYPE_BITS; i++, type = 1 << i) { + const char *name; + int j; + + if (!(query.lu_types & type)) + continue; + + name = lfsck_type2name(type); + for (j = 0; j <= LS_MAX; j++) + printf("%s_mdts_%s: %d\n", name, + lfsck_status2name(j), query.lu_mdts_count[i][j]); + + for (j = 0; j <= LS_MAX; j++) + printf("%s_osts_%s: %d\n", name, + lfsck_status2name(j), query.lu_osts_count[i][j]); + + printf("%s_repaired: %llu\n", name, query.lu_repaired[i]); + } + + return 0; +}