btrfs-progs: fix scrub error return from pthread_mutex_lock
[platform/upstream/btrfs-progs.git] / cmds-device.c
index 0fc4c7f..58df6da 100644 (file)
@@ -28,7 +28,7 @@
 #include "ioctl.h"
 #include "utils.h"
 
-#include "btrfs_cmds.h"
+#include "commands.h"
 
 /* FIXME - imported cruft, fix sparse errors and warnings */
 #ifdef __CHECKER__
@@ -39,12 +39,26 @@ struct btrfs_ioctl_vol_args { char name[BTRFS_VOL_NAME_MAX]; };
 static inline int ioctl(int fd, int define, void *arg) { return 0; }
 #endif
 
-int do_add_volume(int nargs, char **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>",
+       "Add a device to a filesystem",
+       NULL
+};
 
-       char    *mntpnt = args[nargs-1];
+static int cmd_add_dev(int argc, char **argv)
+{
+       char    *mntpnt;
        int     i, fdmnt, ret=0, e;
 
+       if (check_argc_min(argc, 3))
+               usage(cmd_add_dev_usage);
+
+       mntpnt = argv[argc - 1];
 
        fdmnt = open_file_or_dir(mntpnt);
        if (fdmnt < 0) {
@@ -52,62 +66,62 @@ int do_add_volume(int nargs, char **args)
                return 12;
        }
 
-       for (i = 1; i < (nargs-1); i++ ){
+       for (i = 1; i < argc - 1; i++ ){
                struct btrfs_ioctl_vol_args ioctl_args;
                int     devfd, res;
                u64 dev_block_count = 0;
                struct stat st;
                int mixed = 0;
 
-               res = check_mounted(args[i]);
+               res = check_mounted(argv[i]);
                if (res < 0) {
                        fprintf(stderr, "error checking %s mount status\n",
-                               args[i]);
+                               argv[i]);
                        ret++;
                        continue;
                }
                if (res == 1) {
-                       fprintf(stderr, "%s is mounted\n", args[i]);
+                       fprintf(stderr, "%s is mounted\n", argv[i]);
                        ret++;
                        continue;
                }
 
-               devfd = open(args[i], O_RDWR);
-               if (!devfd) {
-                       fprintf(stderr, "ERROR: Unable to open device '%s'\n", args[i]);
-                       close(devfd);
+               devfd = open(argv[i], O_RDWR);
+               if (devfd < 0) {
+                       fprintf(stderr, "ERROR: Unable to open device '%s'\n", argv[i]);
                        ret++;
                        continue;
                }
                res = fstat(devfd, &st);
                if (res) {
-                       fprintf(stderr, "ERROR: Unable to stat '%s'\n", args[i]);
+                       fprintf(stderr, "ERROR: Unable to stat '%s'\n", argv[i]);
                        close(devfd);
                        ret++;
                        continue;
                }
                if (!S_ISBLK(st.st_mode)) {
-                       fprintf(stderr, "ERROR: '%s' is not a block device\n", args[i]);
+                       fprintf(stderr, "ERROR: '%s' is not a block device\n", argv[i]);
                        close(devfd);
                        ret++;
                        continue;
                }
 
-               res = btrfs_prepare_device(devfd, args[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", args[i]);
+                       fprintf(stderr, "ERROR: Unable to init '%s'\n", argv[i]);
                        close(devfd);
                        ret++;
                        continue;
                }
                close(devfd);
 
-               strncpy(ioctl_args.name, args[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){
-                       fprintf(stderr, "ERROR: error adding the device '%s' - %s\n", 
-                               args[i], strerror(e));
+                       fprintf(stderr, "ERROR: error adding the device '%s' - %s\n",
+                               argv[i], strerror(e));
                        ret++;
                }
 
@@ -118,31 +132,40 @@ int do_add_volume(int nargs, char **args)
                return ret+20;
        else
                return 0;
-
 }
 
-int do_remove_volume(int nargs, char **args)
-{
+static const char * const cmd_rm_dev_usage[] = {
+       "btrfs device delete <device> [<device>...] <path>",
+       "Remove a device from a filesystem",
+       NULL
+};
 
-       char    *mntpnt = args[nargs-1];
+static int cmd_rm_dev(int argc, char **argv)
+{
+       char    *mntpnt;
        int     i, fdmnt, ret=0, e;
 
+       if (check_argc_min(argc, 3))
+               usage(cmd_rm_dev_usage);
+
+       mntpnt = argv[argc - 1];
+
        fdmnt = open_file_or_dir(mntpnt);
        if (fdmnt < 0) {
                fprintf(stderr, "ERROR: can't access to '%s'\n", mntpnt);
                return 12;
        }
 
-       for(i=1 ; i < (nargs-1) ; i++ ){
+       for(i=1 ; i < argc - 1; i++ ){
                struct  btrfs_ioctl_vol_args arg;
                int     res;
 
-               strncpy(arg.name, args[i], BTRFS_PATH_NAME_MAX);
+               strncpy_null(arg.name, argv[i]);
                res = ioctl(fdmnt, BTRFS_IOC_RM_DEV, &arg);
                e = errno;
                if(res<0){
-                       fprintf(stderr, "ERROR: error removing the device '%s' - %s\n", 
-                               args[i], strerror(e));
+                       fprintf(stderr, "ERROR: error removing the device '%s' - %s\n",
+                               argv[i], strerror(e));
                        ret++;
                }
        }
@@ -154,18 +177,21 @@ int do_remove_volume(int nargs, char **args)
                return 0;
 }
 
-int do_scan(int argc, char **argv)
+static const char * const cmd_scan_dev_usage[] = {
+       "btrfs device scan [<device>...]",
+       "Scan devices for a btrfs filesystem",
+       NULL
+};
+
+static int cmd_scan_dev(int argc, char **argv)
 {
        int     i, fd, e;
        int     checklist = 1;
        int     devstart = 1;
 
-       if( argc >= 2 && !strcmp(argv[1],"--all-devices")){
-
-               if( argc >2 ){
-                       fprintf(stderr, "ERROR: too may arguments\n");
-                        return 22;
-                }
+       if( argc > 1 && !strcmp(argv[1],"--all-devices")){
+               if (check_argc_max(argc, 2))
+                       usage(cmd_scan_dev_usage);
 
                checklist = 0;
                devstart += 1;
@@ -199,7 +225,7 @@ int do_scan(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
@@ -210,7 +236,7 @@ int do_scan(int argc, char **argv)
 
                if( ret < 0 ){
                        close(fd);
-                       fprintf(stderr, "ERROR: unable to scan the device '%s' - %s\n", 
+                       fprintf(stderr, "ERROR: unable to scan the device '%s' - %s\n",
                                argv[i], strerror(e));
                        return 11;
                }
@@ -218,6 +244,167 @@ int do_scan(int argc, char **argv)
 
        close(fd);
        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 }
+       }
+};
+
+int cmd_device(int argc, char **argv)
+{
+       return handle_command_group(&device_cmd_group, argc, argv);
+}