btrfs-progs: fix scrub error return from pthread_mutex_lock
[platform/upstream/btrfs-progs.git] / cmds-device.c
index 51089ba..58df6da 100644 (file)
@@ -39,8 +39,10 @@ struct btrfs_ioctl_vol_args { char name[BTRFS_VOL_NAME_MAX]; };
 static inline int ioctl(int fd, int define, void *arg) { return 0; }
 #endif
 
-static const char device_cmd_group_usage[] =
-       "btrfs device <command> [<args>]";
+static const char * const device_cmd_group_usage[] = {
+       "btrfs device <command> [<args>]",
+       NULL
+};
 
 static const char * const cmd_add_dev_usage[] = {
        "btrfs device add <device> [<device>...] <path>",
@@ -85,9 +87,8 @@ static int cmd_add_dev(int argc, char **argv)
                }
 
                devfd = open(argv[i], O_RDWR);
-               if (!devfd) {
+               if (devfd < 0) {
                        fprintf(stderr, "ERROR: Unable to open device '%s'\n", argv[i]);
-                       close(devfd);
                        ret++;
                        continue;
                }
@@ -105,7 +106,8 @@ static int cmd_add_dev(int argc, char **argv)
                        continue;
                }
 
-               res = btrfs_prepare_device(devfd, argv[i], 1, &dev_block_count, &mixed);
+               res = btrfs_prepare_device(devfd, argv[i], 1, &dev_block_count,
+                                          0, &mixed, 0);
                if (res) {
                        fprintf(stderr, "ERROR: Unable to init '%s'\n", argv[i]);
                        close(devfd);
@@ -114,7 +116,7 @@ static int cmd_add_dev(int argc, char **argv)
                }
                close(devfd);
 
-               strncpy(ioctl_args.name, argv[i], BTRFS_PATH_NAME_MAX);
+               strncpy_null(ioctl_args.name, argv[i]);
                res = ioctl(fdmnt, BTRFS_IOC_ADD_DEV, &ioctl_args);
                e = errno;
                if(res<0){
@@ -158,7 +160,7 @@ static int cmd_rm_dev(int argc, char **argv)
                struct  btrfs_ioctl_vol_args arg;
                int     res;
 
-               strncpy(arg.name, argv[i], BTRFS_PATH_NAME_MAX);
+               strncpy_null(arg.name, argv[i]);
                res = ioctl(fdmnt, BTRFS_IOC_RM_DEV, &arg);
                e = errno;
                if(res<0){
@@ -223,7 +225,7 @@ static int cmd_scan_dev(int argc, char **argv)
 
                printf("Scanning for Btrfs filesystems in '%s'\n", argv[i]);
 
-               strncpy(args.name, argv[i], BTRFS_PATH_NAME_MAX);
+               strncpy_null(args.name, argv[i]);
                /*
                 * FIXME: which are the error code returned by this ioctl ?
                 * it seems that is impossible to understand if there no is
@@ -244,11 +246,160 @@ static int cmd_scan_dev(int argc, char **argv)
        return 0;
 }
 
+static const char * const cmd_ready_dev_usage[] = {
+       "btrfs device ready <device>",
+       "Check device to see if it has all of it's devices in cache for mounting",
+       NULL
+};
+
+static int cmd_ready_dev(int argc, char **argv)
+{
+       struct  btrfs_ioctl_vol_args args;
+       int     fd;
+       int     ret;
+
+       if (check_argc_min(argc, 2))
+               usage(cmd_ready_dev_usage);
+
+       fd = open("/dev/btrfs-control", O_RDWR);
+       if (fd < 0) {
+               perror("failed to open /dev/btrfs-control");
+               return 10;
+       }
+
+       strncpy(args.name, argv[argc - 1], BTRFS_PATH_NAME_MAX);
+       ret = ioctl(fd, BTRFS_IOC_DEVICES_READY, &args);
+       if (ret < 0) {
+               fprintf(stderr, "ERROR: unable to determine if the device '%s'"
+                       " is ready for mounting - %s\n", argv[argc - 1],
+                       strerror(errno));
+               ret = 1;
+       }
+
+       close(fd);
+       return ret;
+}
+
+static const char * const cmd_dev_stats_usage[] = {
+       "btrfs device stats [-z] <path>|<device>",
+       "Show current device IO stats. -z to reset stats afterwards.",
+       NULL
+};
+
+static int cmd_dev_stats(int argc, char **argv)
+{
+       char *path;
+       struct btrfs_ioctl_fs_info_args fi_args;
+       struct btrfs_ioctl_dev_info_args *di_args = NULL;
+       int ret;
+       int fdmnt;
+       int i;
+       char c;
+       int err = 0;
+       __u64 flags = 0;
+
+       optind = 1;
+       while ((c = getopt(argc, argv, "z")) != -1) {
+               switch (c) {
+               case 'z':
+                       flags = BTRFS_DEV_STATS_RESET;
+                       break;
+               case '?':
+               default:
+                       fprintf(stderr, "ERROR: device stat args invalid.\n"
+                                       " device stat [-z] <path>|<device>\n"
+                                       " -z  to reset stats after reading.\n");
+                       return 1;
+               }
+       }
+
+       if (optind + 1 != argc) {
+               fprintf(stderr, "ERROR: device stat needs path|device as single"
+                       " argument\n");
+               return 1;
+       }
+
+       path = argv[optind];
+
+       fdmnt = open_file_or_dir(path);
+       if (fdmnt < 0) {
+               fprintf(stderr, "ERROR: can't access '%s'\n", path);
+               return 12;
+       }
+
+       ret = get_fs_info(fdmnt, path, &fi_args, &di_args);
+       if (ret) {
+               fprintf(stderr, "ERROR: getting dev info for devstats failed: "
+                               "%s\n", strerror(-ret));
+               err = 1;
+               goto out;
+       }
+       if (!fi_args.num_devices) {
+               fprintf(stderr, "ERROR: no devices found\n");
+               err = 1;
+               goto out;
+       }
+
+       for (i = 0; i < fi_args.num_devices; i++) {
+               struct btrfs_ioctl_get_dev_stats args = {0};
+               __u8 path[BTRFS_DEVICE_PATH_NAME_MAX + 1];
+
+               strncpy((char *)path, (char *)di_args[i].path,
+                       BTRFS_DEVICE_PATH_NAME_MAX);
+               path[BTRFS_DEVICE_PATH_NAME_MAX] = '\0';
+
+               args.devid = di_args[i].devid;
+               args.nr_items = BTRFS_DEV_STAT_VALUES_MAX;
+               args.flags = flags;
+
+               if (ioctl(fdmnt, BTRFS_IOC_GET_DEV_STATS, &args) < 0) {
+                       fprintf(stderr,
+                               "ERROR: ioctl(BTRFS_IOC_GET_DEV_STATS) on %s failed: %s\n",
+                               path, strerror(errno));
+                       err = 1;
+               } else {
+                       if (args.nr_items >= BTRFS_DEV_STAT_WRITE_ERRS + 1)
+                               printf("[%s].write_io_errs   %llu\n",
+                                      path,
+                                      (unsigned long long) args.values[
+                                       BTRFS_DEV_STAT_WRITE_ERRS]);
+                       if (args.nr_items >= BTRFS_DEV_STAT_READ_ERRS + 1)
+                               printf("[%s].read_io_errs    %llu\n",
+                                      path,
+                                      (unsigned long long) args.values[
+                                       BTRFS_DEV_STAT_READ_ERRS]);
+                       if (args.nr_items >= BTRFS_DEV_STAT_FLUSH_ERRS + 1)
+                               printf("[%s].flush_io_errs   %llu\n",
+                                      path,
+                                      (unsigned long long) args.values[
+                                       BTRFS_DEV_STAT_FLUSH_ERRS]);
+                       if (args.nr_items >= BTRFS_DEV_STAT_CORRUPTION_ERRS + 1)
+                               printf("[%s].corruption_errs %llu\n",
+                                      path,
+                                      (unsigned long long) args.values[
+                                       BTRFS_DEV_STAT_CORRUPTION_ERRS]);
+                       if (args.nr_items >= BTRFS_DEV_STAT_GENERATION_ERRS + 1)
+                               printf("[%s].generation_errs %llu\n",
+                                      path,
+                                      (unsigned long long) args.values[
+                                       BTRFS_DEV_STAT_GENERATION_ERRS]);
+               }
+       }
+
+out:
+       free(di_args);
+       close(fdmnt);
+
+       return err;
+}
+
 const struct cmd_group device_cmd_group = {
        device_cmd_group_usage, NULL, {
                { "add", cmd_add_dev, cmd_add_dev_usage, NULL, 0 },
                { "delete", cmd_rm_dev, cmd_rm_dev_usage, NULL, 0 },
                { "scan", cmd_scan_dev, cmd_scan_dev_usage, NULL, 0 },
+               { "ready", cmd_ready_dev, cmd_ready_dev_usage, NULL, 0 },
+               { "stats", cmd_dev_stats, cmd_dev_stats_usage, NULL, 0 },
                { 0, 0, 0, 0, 0 }
        }
 };