static int lfs_project(int argc, char **argv);
#endif
static int lfs_flushctx(int argc, char **argv);
-static int lfs_cp(int argc, char **argv);
-static int lfs_ls(int argc, char **argv);
static int lfs_poollist(int argc, char **argv);
static int lfs_changelog(int argc, char **argv);
static int lfs_changelog_clear(int argc, char **argv);
static int lfs_mv(int argc, char **argv);
static int lfs_ladvise(int argc, char **argv);
static int lfs_getsom(int argc, char **argv);
+static int lfs_heat_get(int argc, char **argv);
+static int lfs_heat_set(int argc, char **argv);
static int lfs_mirror(int argc, char **argv);
static int lfs_mirror_list_commands(int argc, char **argv);
static int lfs_list_commands(int argc, char **argv);
static inline int lfs_mirror_verify(int argc, char **argv);
static inline int lfs_mirror_read(int argc, char **argv);
static inline int lfs_mirror_write(int argc, char **argv);
+static inline int lfs_mirror_copy(int argc, char **argv);
enum setstripe_origin {
SO_SETSTRIPE,
#define MIGRATE_USAGE \
SSM_CMD_COMMON("migrate ") \
- " [--block|-b]\n" \
- " [--non-block|-n]\n" \
- " [--non-direct|-D]\n" \
+ " [--block|-b] [--non-block|-n]\n" \
+ " [--non-direct|-D] [--verbose|-v]\n" \
" <filename>\n" \
SSM_HELP_COMMON \
"\n" \
"\tblock: Block file access during data migration (default)\n" \
"\tnon-block: Abort migrations if concurrent access is detected\n" \
- "\tnon-direct: Do not use direct I/O to copy file contents\n" \
+ "\tnon-direct: Do not use direct I/O to copy file contents\n" \
+ "\tverbose: Print each filename as it is migrated\n" \
#define SETDIRSTRIPE_USAGE \
" [--mdt-count|-c stripe_count>\n" \
- " [--mdt-index|-i mdt_index[,mdt_index,...]\n" \
" [--mdt-hash|-H mdt_hash]\n" \
- " [--default|-D] [--mode|-m mode] <dir>\n" \
+ " [--mdt-index|-i mdt_index[,mdt_index,...]\n" \
+ " [--default|-D] [--mode|-o mode] <dir>\n" \
"\tstripe_count: stripe count of the striped directory\n" \
"\tmdt_index: MDT index of first stripe\n" \
"\tmdt_hash: hash type of the striped directory. mdt types:\n" \
" fnv_1a_64 FNV-1a hash algorithm (default)\n" \
" all_char sum of characters % MDT_COUNT (not recommended)\n" \
"\tdefault_stripe: set default dirstripe of the directory\n" \
- "\tmode: the mode of the directory\n"
+ "\tmode: the file access permission of the directory (octal)\n"
/**
* command_t mirror_cmdlist - lfs mirror commands.
.pc_help = "Write to a specified mirror of a file.\n"
"usage: lfs mirror write <--mirror-id|-N <mirror_id> "
"[--inputfile|-i <input_file>] <mirrored_file>\n" },
+ { .pc_name = "copy", .pc_func = lfs_mirror_copy,
+ .pc_help = "Copy a specified mirror to other mirror(s) of a file.\n"
+ "usage: lfs mirror copy <--read-mirror|-i <id0>> "
+ "<--write-mirror|-o <id1,id2>> <mirrored_file>\n" },
{ .pc_name = "resync", .pc_func = lfs_mirror_resync,
.pc_help = "Resynchronizes out-of-sync mirrored file(s).\n"
"usage: lfs mirror resync [--only <mirror_id[,...]>] "
{"find", lfs_find, 0,
"find files matching given attributes recursively in directory tree.\n"
"usage: find <directory|filename> ...\n"
- " [[!] --atime|-A [+-]N] [[!] --ctime|-C [+-]N]\n"
- " [[!] --mtime|-M [+-]N] [--maxdepth|-D N] [[!] --blocks|-b N]\n"
- " [[!] --mdt-index|--mdt|-m <uuid|index,...>]\n"
+ " [[!] --atime|-A [+-]N[smhdwy]] [[!] --ctime|-C [+-]N[smhdwy]]\n"
+ " [[!] --mtime|-M [+-]N[smhdwy]] [[!] --blocks|-b N]\n"
+ " [--maxdepth|-D N] [[!] --mdt-index|--mdt|-m <uuid|index,...>]\n"
" [[!] --name|-n <pattern>] [[!] --ost|-O <uuid|index,...>]\n"
" [--print|-P] [--print0|-0] [[!] --size|-s [+-]N[bkMGTPE]]\n"
" [[!] --stripe-count|-c [+-]<stripes>]\n"
" [[!] --mirror-state <[^]state>]\n"
" [[!] --mdt-count|-T [+-]<stripes>]\n"
" [[!] --mdt-hash|-H <hashtype>\n"
+ " [[!] --mdt-index|-m <uuid|index,...>]\n"
"\t !: used before an option indicates 'NOT' requested attribute\n"
"\t -: used before a value indicates less than requested value\n"
"\t +: used before a value indicates more than requested value\n"
#endif
{"flushctx", lfs_flushctx, 0, "Flush security context for current user.\n"
"usage: flushctx [-k] [mountpoint...]"},
- {"cp", lfs_cp, 0,
- "Remote user copy files and directories.\n"
- "usage: cp [OPTION]... [-T] SOURCE DEST\n\tcp [OPTION]... SOURCE... DIRECTORY\n\tcp [OPTION]... -t DIRECTORY SOURCE..."},
- {"ls", lfs_ls, 0,
- "Remote user list directory contents.\n"
- "usage: ls [OPTION]... [FILE]..."},
{"changelog", lfs_changelog, 0,
"Show the metadata changes on an MDT."
"\nusage: changelog <mdtname> [startrec [endrec]]"},
"usage: swap_layouts <path1> <path2>"},
{"migrate", lfs_setstripe_migrate, 0,
"migrate a directory between MDTs.\n"
- "usage: migrate [--mdt|-m] <start_mdt_index>\n"
- " [--mdt-count|-c] <stripe_count>\n"
+ "usage: migrate [--mdt-count|-c] <stripe_count>\n"
" [--mdt-hash|-H] <hash_type>\n"
+ " [--mdt-index|-m] <start_mdt_index>\n"
" [--verbose|-v]\n"
" <directory>\n"
"\tmdt: MDTs to stripe over, if only one MDT is specified\n"
"\tstripe_size: number of bytes to store before moving to the next OST\n"
"\tpool_name: name of the predefined pool of OSTs\n"
"\tost_indices: OSTs to stripe over, in order\n"
- "\tblock: wait for the operation to return before continuing\n"
- "\tnon-block: do not wait for the operation to return\n"
+ "\tblock: Block file access during data migration (default)\n"
+ "\tnon-block: Abort migrations if concurrent access is detected\n"
"\tnon-direct: do not use direct I/O to copy file contents.\n"},
{"mv", lfs_mv, 0,
"To move directories between MDTs. This command is deprecated, "
"lfs mirror resync - resynchronize out-of-sync mirrored file(s)\n"
"lfs mirror read - read a mirror content of a mirrored file\n"
"lfs mirror write - write to a mirror of a mirrored file\n"
+ "lfs mirror copy - copy a mirror to other mirror(s) of a file\n"
"lfs mirror verify - verify mirrored file(s)\n"},
{"getsom", lfs_getsom, 0, "To list the SOM info for a given file.\n"
"usage: getsom [-s] [-b] [-f] <path>\n"
"\t-s: Only show the size value of the SOM data for a given file\n"
"\t-b: Only show the blocks value of the SOM data for a given file\n"
"\t-f: Only show the flags value of the SOM data for a given file\n"},
+ {"heat_get", lfs_heat_get, 0,
+ "To get heat of files.\n"
+ "usage: heat_get <file> ...\n"},
+ {"heat_set", lfs_heat_set, 0,
+ "To set heat flags of files.\n"
+ "usage: heat_set [--clear|-c] [--off|-o] [--on|-O] <file> ...\n"
+ "\t--clear|-c: Clear file heat for given files\n"
+ "\t--off|-o: Turn off file heat for given files\n"
+ "\t--on|-O: Turn on file heat for given files\n"},
{"help", Parser_help, 0, "help"},
{"exit", Parser_quit, 0, "quit"},
{"quit", Parser_quit, 0, "quit"},
static const char *error_loc = "syserror";
enum {
- MIGRATION_NONBLOCK = 1 << 0,
- MIGRATION_MIRROR = 1 << 1,
- MIGRATION_NONDIRECT = 1 << 2,
+ MIGRATION_NONBLOCK = 0x0001,
+ MIGRATION_MIRROR = 0x0002,
+ MIGRATION_NONDIRECT = 0x0004,
+ MIGRATION_VERBOSE = 0x0008,
};
static int lfs_component_create(char *fname, int open_flags, mode_t open_mode,
if (rc < 0)
fprintf(stderr, "error: %s: %s: %s: %s\n",
progname, name, error_loc, strerror(-rc));
+ else if (migration_flags & MIGRATION_VERBOSE)
+ printf("%s\n", name);
+
return rc;
}
} else if (!strcmp(string, "pattern")) {
if (!strcmp(node->cy_valuestring, "mdt"))
lsa->lsa_pattern = LLAPI_LAYOUT_MDT;
+ } else if (!strcmp(string, "lcme_flags")) {
+ rc = comp_str2flags(node->cy_valuestring,
+ &lsa->lsa_comp_flags,
+ &lsa->lsa_comp_neg_flags);
+ if (rc)
+ return rc;
+ /* Only template flags have meaning in
+ * the layout for a new file
+ */
+ lsa->lsa_comp_flags &= LCME_TEMPLATE_FLAGS;
}
} else if (node->cy_type == CYAML_TYPE_NUMBER) {
if (!strcmp(string, "lcm_mirror_count")) {
case 'm':
if (!migrate_mode) {
fprintf(stderr,
- "%s %s: -m|--mdt is valid only for migrate command\n",
+ "%s %s: -m|--mdt-index is valid only for migrate command\n",
progname, argv[0]);
goto usage_error;
}
goto usage_error;
}
migrate_mdt_param.fp_verbose = VERBOSE_DETAIL;
+ migration_flags = MIGRATION_VERBOSE;
break;
case 'y':
from_yaml = true;
return llapi_poollist(argv[1]);
}
-static int set_time(time_t *time, time_t *set, char *str)
+static time_t set_time(struct find_param *param, time_t *time, time_t *set,
+ char *str)
{
- time_t t;
+ long long t = 0;
int res = 0;
- char *endptr;
+ char *endptr = "AD";
+ char *timebuf;
if (str[0] == '+')
res = 1;
if (res)
str++;
- t = strtol(str, &endptr, 0);
- if (*endptr != '\0') {
- fprintf(stderr,
- "%s find: bad time '%s': %s\n",
- progname, str, strerror(EINVAL));
- return INT_MAX;
+ for (timebuf = str; *endptr && *(endptr + 1); timebuf = endptr + 1) {
+ long long val = strtoll(timebuf, &endptr, 0);
+ int unit = 1;
+
+ switch (*endptr) {
+ case 'y':
+ unit *= 52; /* 52 weeks + 1 day below */
+ case 'w': /* fallthrough */
+ unit *= 7;
+ case '\0': /* days are default unit if none used */
+ case 'd': /* fallthrough */
+ unit = (unit + (*endptr == 'y')) * 24;
+ case 'h': /* fallthrough */
+ unit *= 60;
+ case 'm': /* fallthrough */
+ unit *= 60;
+ case 's': /* fallthrough */
+ break;
+ /* don't need to multiply by 1 for seconds */
+ default:
+ fprintf(stderr,
+ "%s find: bad time string '%s': %s\n",
+ progname, timebuf, strerror(EINVAL));
+ return LONG_MAX;
+ }
+
+ if (param->fp_time_margin == 0 ||
+ (*endptr && unit < param->fp_time_margin))
+ param->fp_time_margin = unit;
+
+ t += val * unit;
}
- if (*time < t * 24 * 60 * 60) {
+ if (*time < t) {
if (res != 0)
str--;
- fprintf(stderr,
- "%s find: bad time '%s': too large\n",
+ fprintf(stderr, "%s find: bad time '%s': too large\n",
progname, str);
- return INT_MAX;
+ return LONG_MAX;
}
- *set = *time - t * 24 * 60 * 60;
+ *set = *time - t;
+
return res;
}
struct find_param param = {
.fp_max_depth = -1,
.fp_quiet = 1,
+ .fp_time_margin = 24 * 60 * 60,
};
struct option long_opts[] = {
{ .val = 'A', .name = "atime", .has_arg = required_argument },
{ .val = 'U', .name = "user", .has_arg = required_argument },
/* getstripe { .val = 'v', .name = "verbose", .has_arg = no_argument }, */
/* getstripe { .val = 'y', .name = "yaml", .has_arg = no_argument }, */
+ { .val = 'z', .name = "lazy", .has_arg = no_argument },
{ .name = NULL } };
int pathstart = -1;
int pathend = -1;
/* when getopt_long_only() hits '!' it returns 1, puts "!" in optarg */
while ((c = getopt_long_only(argc, argv,
- "-0A:b:c:C:D:E:g:G:H:i:L:m:M:n:N:O:Ppqrs:S:t:T:u:U:v",
+ "-0A:b:c:C:D:E:g:G:H:i:L:m:M:n:N:O:Ppqrs:S:t:T:u:U:vz",
long_opts, NULL)) >= 0) {
xtime = NULL;
xsign = NULL;
xsign = ¶m.fp_msign;
param.fp_exclude_mtime = !!neg_opt;
}
- rc = set_time(&t, xtime, optarg);
- if (rc == INT_MAX) {
+ rc = set_time(¶m, &t, xtime, optarg);
+ if (rc == LONG_MAX) {
ret = -1;
goto err;
}
param.fp_check_mdt_count = 1;
param.fp_exclude_mdt_count = !!neg_opt;
break;
+ case 'z':
+ param.fp_lazy = 1;
+ break;
default:
ret = CMD_HELP;
goto err;
{ .val = 'D', .name = "default", .has_arg = no_argument },
{ .val = 'D', .name = "default_stripe", .has_arg = no_argument },
{ .val = 'H', .name = "mdt-hash", .has_arg = required_argument },
+#if LUSTRE_VERSION_CODE < OBD_OCD_VERSION(2, 17, 53, 0)
{ .val = 'i', .name = "mdt-index", .has_arg = required_argument },
+ { .val = 'i', .name = "mdt", .has_arg = required_argument },
+#else
+ { .val = 'm', .name = "mdt-index", .has_arg = required_argument },
+ { .val = 'm', .name = "mdt", .has_arg = required_argument },
+#endif
#if LUSTRE_VERSION_CODE < OBD_OCD_VERSION(3, 0, 53, 0)
{ .val = 'i', .name = "index", .has_arg = required_argument },
#endif
}
break;
case 'i':
+#if LUSTRE_VERSION_CODE >= OBD_OCD_VERSION(2, 17, 53, 0)
+ case 'm':
+#endif
#if LUSTRE_VERSION_CODE < OBD_OCD_VERSION(3, 0, 53, 0)
if (strcmp(argv[optind - 1], "--index") == 0)
fprintf(stderr,
if (lsa.lsa_stripe_off == LLAPI_LAYOUT_DEFAULT)
lsa.lsa_stripe_off = mdts[0];
break;
-#if LUSTRE_VERSION_CODE < OBD_OCD_VERSION(2, 16, 53, 0)
+#if LUSTRE_VERSION_CODE < OBD_OCD_VERSION(2, 15, 53, 0)
case 'm':
fprintf(stderr, "warning: '-m' is deprecated, "
"use '--mode' or '-o' instead\n");
int c;
int rc = 0;
struct option long_opts[] = {
+ { .val = 'm', .name = "mdt", .has_arg = required_argument },
{ .val = 'm', .name = "mdt-index", .has_arg = required_argument },
{ .val = 'v', .name = "verbose", .has_arg = no_argument },
{ .name = NULL } };
return rc;
}
-static int lfs_cp(int argc, char **argv)
-{
- fprintf(stderr, "remote client copy file(s).\n"
- "obsolete, does not support it anymore.\n");
- return 0;
-}
-
-static int lfs_ls(int argc, char **argv)
-{
- fprintf(stderr, "remote client lists directory contents.\n"
- "obsolete, does not support it anymore.\n");
- return 0;
-}
-
static int lfs_changelog(int argc, char **argv)
{
void *changelog_priv;
return rc;
}
+
+static const char *const heat_names[] = LU_HEAT_NAMES;
+
+static int lfs_heat_get(int argc, char **argv)
+{
+ struct lu_heat *heat;
+ int rc = 0, rc2;
+ char *path;
+ int fd;
+ int i;
+
+ if (argc <= 1)
+ return CMD_HELP;
+
+ heat = calloc(sizeof(*heat) + sizeof(__u64) * OBD_HEAT_COUNT, 1);
+ if (!heat) {
+ fprintf(stderr, "%s: memory allocation failed\n", argv[0]);
+ return -ENOMEM;
+ }
+
+ optind = 1;
+ while (optind < argc) {
+ path = argv[optind++];
+
+ fd = open(path, O_RDONLY);
+ if (fd < 0) {
+ fprintf(stderr, "%s: cannot open file '%s': %s\n",
+ argv[0], path, strerror(errno));
+ rc2 = -errno;
+ goto next;
+ }
+
+ heat->lh_count = OBD_HEAT_COUNT;
+ rc2 = llapi_heat_get(fd, heat);
+ close(fd);
+ if (rc2 < 0) {
+ fprintf(stderr, "%s: cannot get heat of file '%s'"
+ ": %s\n", argv[0], path, strerror(errno));
+ goto next;
+ }
+
+ printf("flags: %x\n", heat->lh_flags);
+ for (i = 0; i < heat->lh_count; i++)
+ printf("%s: %llu\n", heat_names[i], heat->lh_heat[i]);
+next:
+ if (rc == 0 && rc2 < 0)
+ rc = rc2;
+ }
+
+ free(heat);
+ return rc;
+}
+
+static int lfs_heat_set(int argc, char **argv)
+{
+ struct option long_opts[] = {
+ {"clear", no_argument, 0, 'c'},
+ {"off", no_argument, 0, 'o'},
+ {"on", no_argument, 0, 'O'},
+ {0, 0, 0, 0}
+ };
+ char short_opts[] = "coO";
+ int rc = 0, rc2;
+ char *path;
+ int fd;
+ __u64 flags = 0;
+ int c;
+
+ if (argc <= 1)
+ return CMD_HELP;
+
+ optind = 0;
+ while ((c = getopt_long(argc, argv, short_opts,
+ long_opts, NULL)) != -1) {
+ switch (c) {
+ case 'c':
+ flags |= LU_HEAT_FLAG_CLEAR;
+ break;
+ case 'o':
+ flags |= LU_HEAT_FLAG_CLEAR;
+ flags |= LU_HEAT_FLAG_OFF;
+ break;
+ case 'O':
+ flags &= ~LU_HEAT_FLAG_OFF;
+ break;
+ case '?':
+ return CMD_HELP;
+ default:
+ fprintf(stderr, "%s: option '%s' unrecognized\n",
+ argv[0], argv[optind - 1]);
+ return CMD_HELP;
+ }
+ }
+
+ if (argc <= optind) {
+ fprintf(stderr, "%s: please give one or more file names\n",
+ argv[0]);
+ return CMD_HELP;
+ }
+
+ while (optind < argc) {
+ path = argv[optind++];
+
+ fd = open(path, O_RDONLY);
+ if (fd < 0) {
+ fprintf(stderr, "%s: cannot open file '%s': %s\n",
+ argv[0], path, strerror(errno));
+ rc2 = -errno;
+ goto next;
+ }
+
+ rc2 = llapi_heat_set(fd, flags);
+ close(fd);
+ if (rc2 < 0) {
+ fprintf(stderr, "%s: cannot setflags heat of file '%s'"
+ ": %s\n", argv[0], path, strerror(errno));
+ goto next;
+ }
+next:
+ if (rc == 0 && rc2 < 0)
+ rc = rc2;
+ }
+ return rc;
+}
+
/** The input string contains a comma delimited list of component ids and
* ranges, for example "1,2-4,7".
*/
return rc;
}
+struct collect_ids_data {
+ __u16 *cid_ids;
+ int cid_count;
+ __u16 cid_exclude;
+};
+
+static int collect_mirror_id(struct llapi_layout *layout, void *cbdata)
+{
+ struct collect_ids_data *cid = cbdata;
+ uint32_t id;
+ int rc;
+
+ rc = llapi_layout_mirror_id_get(layout, &id);
+ if (rc < 0)
+ return rc;
+
+ if ((__u16)id != cid->cid_exclude) {
+ int i;
+
+ for (i = 0; i < cid->cid_count; i++) {
+ /* already collected the mirror id */
+ if (id == cid->cid_ids[i])
+ return LLAPI_LAYOUT_ITER_CONT;
+ }
+ cid->cid_ids[cid->cid_count] = id;
+ cid->cid_count++;
+ }
+
+ return LLAPI_LAYOUT_ITER_CONT;
+}
+
+static inline int get_other_mirror_ids(int fd, __u16 *ids, __u16 exclude_id)
+{
+ struct llapi_layout *layout;
+ struct collect_ids_data cid = { .cid_ids = ids,
+ .cid_count = 0,
+ .cid_exclude = exclude_id, };
+ int rc;
+
+ layout = llapi_layout_get_by_fd(fd, 0);
+ if (layout == NULL) {
+ fprintf(stderr, "could not get layout\n");
+ return -EINVAL;
+ }
+
+ rc = llapi_layout_comp_iterate(layout, collect_mirror_id, &cid);
+ if (rc < 0) {
+ fprintf(stderr, "failed to iterate layout\n");
+ llapi_layout_free(layout);
+
+ return rc;
+ }
+ llapi_layout_free(layout);
+
+ return cid.cid_count;
+}
+
+static inline int lfs_mirror_copy(int argc, char **argv)
+{
+ int rc = CMD_HELP;
+ __u16 read_mirror_id = 0;
+ __u16 ids[128] = { 0 };
+ int count = 0;
+ struct llapi_layout *layout = NULL;
+ struct llapi_resync_comp comp_array[1024] = { { 0 } };
+ int comp_size = 0;
+ char *fname;
+ int fd = 0;
+ int c;
+ int i;
+ ssize_t copied;
+ struct ll_ioc_lease *ioc = NULL;
+ struct ll_ioc_lease_id *resync_ioc;
+
+ struct option long_opts[] = {
+ { .val = 'i', .name = "read-mirror", .has_arg = required_argument },
+ { .val = 'o', .name = "write-mirror", .has_arg = required_argument },
+ { .name = NULL } };
+
+ while ((c = getopt_long(argc, argv, "i:o:", long_opts, NULL)) >= 0) {
+ char *end;
+
+ switch (c) {
+ case 'i':
+ read_mirror_id = strtoul(optarg, &end, 0);
+ if (*end != '\0' || read_mirror_id == 0) {
+ fprintf(stderr,
+ "%s %s: invalid read mirror ID '%s'\n",
+ progname, argv[0], optarg);
+ return rc;
+ }
+ break;
+ case 'o':
+ if (!strcmp(optarg, "-1")) {
+ /* specify all other mirrors */
+ ids[0] = (__u16)-1;
+ count = 1;
+ } else {
+ count = parse_mirror_ids((__u16 *)ids,
+ ARRAY_SIZE(ids),
+ optarg);
+ if (count < 0)
+ return rc;
+ }
+ break;
+ default:
+ fprintf(stderr, "%s: option '%s' unrecognized\n",
+ progname, argv[optind - 1]);
+ return -EINVAL;
+ }
+ }
+
+ if (argc == optind) {
+ fprintf(stderr, "%s %s: no mirrored file provided\n",
+ progname, argv[0]);
+ return rc;
+ } else if (argc > optind + 1) {
+ fprintf(stderr, "%s %s: too many files\n", progname, argv[0]);
+ return rc;
+ }
+
+ if (read_mirror_id == 0) {
+ fprintf(stderr,
+ "%s %s: no valid read mirror ID %d is provided\n",
+ progname, argv[0], read_mirror_id);
+ return rc;
+ }
+
+ if (count == 0) {
+ fprintf(stderr,
+ "%s %s: no write mirror ID is provided\n",
+ progname, argv[0]);
+ return rc;
+ }
+
+ for (i = 0; i < count; i++) {
+ if (read_mirror_id == ids[i]) {
+ fprintf(stderr,
+ "%s %s: read and write mirror ID cannot be the same\n",
+ progname, argv[0]);
+ return rc;
+ }
+ }
+
+ /* open mirror file */
+ fname = argv[optind];
+
+ fd = open(fname, O_DIRECT | O_RDWR);
+ if (fd < 0) {
+ fprintf(stderr, "%s %s: cannot open '%s': %s\n",
+ progname, argv[0], fname, strerror(errno));
+ return rc;
+ }
+
+ /* write to all other mirrors */
+ if (ids[0] == (__u16)-1) {
+ count = get_other_mirror_ids(fd, ids, read_mirror_id);
+ if (count <= 0) {
+ rc = count;
+ fprintf(stderr,
+ "%s %s: failed to get other mirror ids in '%s': %d\n",
+ progname, argv[0], fname, rc);
+ goto close_fd;
+ }
+ }
+
+ /* verify mirror id */
+ rc = verify_mirror_id_by_fd(fd, read_mirror_id);
+ if (rc) {
+ fprintf(stderr,
+ "%s %s: cannot find mirror with ID %u in '%s'\n",
+ progname, argv[0], read_mirror_id, fname);
+ goto close_fd;
+ }
+
+ for (i = 0; i < count; i++) {
+ rc = verify_mirror_id_by_fd(fd, ids[i]);
+ if (rc) {
+ fprintf(stderr,
+ "%s %s: cannot find mirror with ID %u in '%s'\n",
+ progname, argv[0], ids[i], fname);
+ goto close_fd;
+ }
+ }
+
+ ioc = calloc(sizeof(*ioc) + sizeof(__u32) * 4096, 1);
+ if (ioc == NULL) {
+ fprintf(stderr,
+ "%s %s: cannot alloc comp id array for ioc: %s\n",
+ progname, argv[0], strerror(errno));
+ rc = -errno;
+ goto close_fd;
+ }
+
+ /* get stale component info */
+ layout = llapi_layout_get_by_fd(fd, 0);
+ if (layout == NULL) {
+ fprintf(stderr, "%s %s: failed to get layout of '%s': %s\n",
+ progname, argv[0], fname, strerror(errno));
+ rc = -errno;
+ goto free_ioc;
+ }
+ comp_size = llapi_mirror_find_stale(layout, comp_array,
+ ARRAY_SIZE(comp_array),
+ ids, count);
+ llapi_layout_free(layout);
+ if (comp_size < 0) {
+ rc = comp_size;
+ goto free_ioc;
+ }
+
+ /* prepare target mirror components instantiation */
+ resync_ioc = (struct ll_ioc_lease_id *)ioc;
+ resync_ioc->lil_mode = LL_LEASE_WRLCK;
+ resync_ioc->lil_flags = LL_LEASE_RESYNC;
+ if (count == 1)
+ resync_ioc->lil_mirror_id = ids[0];
+ else
+ resync_ioc->lil_mirror_id = read_mirror_id | MIRROR_ID_NEG;
+ rc = llapi_lease_set(fd, ioc);
+ if (rc < 0) {
+ fprintf(stderr,
+ "%s %s: '%s' llapi_lease_get_ext failed: %s\n",
+ progname, argv[0], fname, strerror(errno));
+ goto free_ioc;
+ }
+
+ copied = llapi_mirror_copy_many(fd, read_mirror_id, ids, count);
+ if (copied < 0) {
+ rc = copied;
+ fprintf(stderr, "%s %s: copy error: %d\n",
+ progname, argv[0], rc);
+ goto free_ioc;
+ }
+
+ fprintf(stdout, "mirror copied successfully: ");
+ for (i = 0; i < copied; i++)
+ fprintf(stdout, "%d ", ids[i]);
+ fprintf(stdout, "\n");
+
+ ioc->lil_mode = LL_LEASE_UNLCK;
+ ioc->lil_flags = LL_LEASE_RESYNC_DONE;
+ ioc->lil_count = 0;
+ for (i = 0; i < comp_size; i++) {
+ int j;
+
+ for (j = 0; j < copied; j++) {
+ if (comp_array[i].lrc_mirror_id != ids[j])
+ continue;
+
+ ioc->lil_ids[ioc->lil_count] = comp_array[i].lrc_id;
+ ioc->lil_count++;
+ }
+ }
+ rc = llapi_lease_set(fd, ioc);
+ if (rc <= 0) {
+ if (rc == 0)
+ rc = -EBUSY;
+ fprintf(stderr,
+ "%s %s: release lease lock of '%s' failed: %s\n",
+ progname, argv[0], fname, strerror(errno));
+ goto free_ioc;
+ }
+
+ rc = 0;
+
+free_ioc:
+ free(ioc);
+close_fd:
+ close(fd);
+
+ return rc;
+}
/**
* struct verify_chunk - Mirror chunk to be verified.
* @chunk: [start, end) of the chunk.
for (i = 1; i < chunk->mirror_count; i++) {
if (crc_array[i] != crc_array[0]) {
rc = -EINVAL;
- if (!verbose)
- goto error;
fprintf(stderr,
"%s: chunk "DEXT" has different checksum value on mirror %u and mirror %u.\n",
git://git.whamcloud.com / fs / lustre-release.git / blobdiff