]> git.sesse.net Git - bcachefs-tools-debian/blobdiff - cmd_fs.c
New upstream release
[bcachefs-tools-debian] / cmd_fs.c
index f8c46429af60344a448849eaf29980df33d27308..007c8d87a64fca68422f2de6f904d2221cfa97f3 100644 (file)
--- a/cmd_fs.c
+++ b/cmd_fs.c
@@ -4,66 +4,96 @@
 
 #include <uuid/uuid.h>
 
-#include "ccan/darray/darray.h"
-
 #include "linux/sort.h"
 
 #include "libbcachefs/bcachefs_ioctl.h"
+#include "libbcachefs/darray.h"
 #include "libbcachefs/opts.h"
 
 #include "cmds.h"
 #include "libbcachefs.h"
 
-static void print_dev_usage_type(const char *type,
-                                unsigned bucket_size,
-                                u64 buckets, u64 sectors,
-                                enum units units)
+static void __dev_usage_type_to_text(struct printbuf *out,
+                                    const char *type,
+                                    unsigned bucket_size,
+                                    u64 buckets, u64 sectors, u64 frag)
 {
-       u64 frag = max((s64) buckets * bucket_size - (s64) sectors, 0LL);
+       prt_printf(out, "%s:", type);
+       prt_tab(out);
+
+       prt_units_u64(out, sectors << 9);
+       prt_tab_rjust(out);
+
+       prt_printf(out, "%llu", buckets);
+       prt_tab_rjust(out);
+
+       if (frag) {
+               prt_units_u64(out, frag << 9);
+               prt_tab_rjust(out);
+       }
+       prt_newline(out);
+}
 
-       printf_pad(20, "  %s:", type);
-       printf(" %15s %15llu %15s\n",
-              pr_units(sectors, units),
-              buckets,
-              pr_units(frag, units));
+static void dev_usage_type_to_text(struct printbuf *out,
+                                  struct bch_ioctl_dev_usage *u,
+                                  enum bch_data_type type)
+{
+       __dev_usage_type_to_text(out, bch2_data_types[type],
+                       u->bucket_size,
+                       u->d[type].buckets,
+                       u->d[type].sectors,
+                       u->d[type].fragmented);
 }
 
-static void print_dev_usage(struct bchfs_handle fs,
-                           struct dev_name *d,
-                           enum units units)
+static void dev_usage_to_text(struct printbuf *out,
+                             struct bchfs_handle fs,
+                             struct dev_name *d)
 {
        struct bch_ioctl_dev_usage u = bchu_dev_usage(fs, d->idx);
        unsigned i;
 
-       printf("\n");
-       printf_pad(20, "%s (device %u):", d->label ?: "(no label)", d->idx);
-       printf("%30s%16s\n", d->dev ?: "(device not found)", bch2_member_states[u.state]);
-
-       printf("%-20s%16s%16s%16s\n",
-              "", "data", "buckets", "fragmented");
-
-       for (i = BCH_DATA_sb; i < BCH_DATA_NR; i++)
-               print_dev_usage_type(bch2_data_types[i],
-                                    u.bucket_size,
-                                    u.buckets[i],
-                                    u.sectors[i],
-                                    units);
-
-       print_dev_usage_type("erasure coded",
-                            u.bucket_size,
-                            u.ec_buckets,
-                            u.ec_sectors,
-                            units);
-
-       printf_pad(20, "  available:");
-       printf(" %15s %15llu\n",
-              pr_units(u.available_buckets * u.bucket_size, units),
-              u.available_buckets);
-
-       printf_pad(20, "  capacity:");
-       printf(" %15s %15llu\n",
-              pr_units(u.nr_buckets * u.bucket_size, units),
-              u.nr_buckets);
+       prt_newline(out);
+       prt_printf(out, "%s (device %u):", d->label ?: "(no label)", d->idx);
+       prt_tab(out);
+       prt_str(out, d->dev ?: "(device not found)");
+       prt_tab_rjust(out);
+
+       prt_str(out, bch2_member_states[u.state]);
+       prt_tab_rjust(out);
+
+       prt_newline(out);
+
+       printbuf_indent_add(out, 2);
+       prt_tab(out);
+
+       prt_str(out, "data");
+       prt_tab_rjust(out);
+
+       prt_str(out, "buckets");
+       prt_tab_rjust(out);
+
+       prt_str(out, "fragmented");
+       prt_tab_rjust(out);
+
+       prt_newline(out);
+
+       for (i = 0; i < BCH_DATA_NR; i++)
+               dev_usage_type_to_text(out, &u, i);
+       __dev_usage_type_to_text(out, "erasure coded",
+                                u.bucket_size,
+                                u.buckets_ec, u.buckets_ec * u.bucket_size, 0);
+
+       prt_str(out, "capacity:");
+       prt_tab(out);
+
+       prt_units_u64(out, (u.nr_buckets * u.bucket_size) << 9);
+       prt_tab_rjust(out);
+       prt_printf(out, "%llu", u.nr_buckets);
+       prt_tab_rjust(out);
+
+       printbuf_indent_sub(out, 2);
+
+       prt_newline(out);
 }
 
 static int dev_by_label_cmp(const void *_l, const void *_r)
@@ -81,15 +111,16 @@ static struct dev_name *dev_idx_to_name(dev_names *dev_names, unsigned idx)
 {
        struct dev_name *dev;
 
-       darray_foreach(dev, *dev_names)
+       darray_for_each(*dev_names, dev)
                if (dev->idx == idx)
                        return dev;
 
        return NULL;
 }
 
-static void print_replicas_usage(const struct bch_replicas_usage *r,
-                                dev_names *dev_names, enum units units)
+static void replicas_usage_to_text(struct printbuf *out,
+                                  const struct bch_replicas_usage *r,
+                                  dev_names *dev_names)
 {
        unsigned i;
 
@@ -113,10 +144,18 @@ static void print_replicas_usage(const struct bch_replicas_usage *r,
        *d++ = ']';
        *d++ = '\0';
 
-       printf_pad(16, "%s: ", bch2_data_types[r->r.data_type]);
-       printf_pad(16, "%u/%u ", r->r.nr_required, r->r.nr_devs);
-       printf_pad(32, "%s ", devs);
-       printf(" %s\n", pr_units(r->sectors, units));
+       prt_printf(out, "%s: ", bch2_data_types[r->r.data_type]);
+       prt_tab(out);
+
+       prt_printf(out, "%u/%u ", r->r.nr_required, r->r.nr_devs);
+       prt_tab(out);
+
+       prt_printf(out, "%s ", devs);
+       prt_tab(out);
+
+       prt_units_u64(out, r->sectors << 9);
+       prt_tab_rjust(out);
+       prt_newline(out);
 }
 
 #define for_each_usage_replica(_u, _r)                                 \
@@ -125,10 +164,9 @@ static void print_replicas_usage(const struct bch_replicas_usage *r,
             _r = replicas_usage_next(_r),                              \
             BUG_ON((void *) _r > (void *) (_u)->replicas + (_u)->replica_entries_bytes))
 
-static void print_fs_usage(const char *path, enum units units)
+static void fs_usage_to_text(struct printbuf *out, const char *path)
 {
        unsigned i;
-       char uuid[40];
 
        struct bchfs_handle fs = bcache_fs_open(path);
 
@@ -137,60 +175,102 @@ static void print_fs_usage(const char *path, enum units units)
 
        struct bch_ioctl_fs_usage *u = bchu_fs_usage(fs);
 
-       uuid_unparse(fs.uuid.b, uuid);
-       printf("Filesystem %s:\n", uuid);
+       prt_str(out, "Filesystem: ");
+       pr_uuid(out, fs.uuid.b);
+       prt_newline(out);
+
+       printbuf_tabstops_reset(out);
+       printbuf_tabstop_push(out, 20);
+       printbuf_tabstop_push(out, 16);
 
-       printf("%-20s%12s\n", "Size:", pr_units(u->capacity, units));
-       printf("%-20s%12s\n", "Used:", pr_units(u->used, units));
+       prt_str(out, "Size:");
+       prt_tab(out);
+       prt_units_u64(out, u->capacity << 9);
+       prt_tab_rjust(out);
+       prt_newline(out);
 
-       printf("%-20s%12s\n", "Online reserved:", pr_units(u->online_reserved, units));
+       prt_str(out, "Used:");
+       prt_tab(out);
+       prt_units_u64(out, u->used << 9);
+       prt_tab_rjust(out);
+       prt_newline(out);
 
-       printf("\n");
-       printf("%-16s%-16s%s\n", "Data type", "Required/total", "Devices");
+       prt_str(out, "Online reserved:");
+       prt_tab(out);
+       prt_units_u64(out, u->online_reserved << 9);
+       prt_tab_rjust(out);
+       prt_newline(out);
+
+       prt_newline(out);
+
+       printbuf_tabstops_reset(out);
+       printbuf_tabstop_push(out, 16);
+       printbuf_tabstop_push(out, 16);
+       printbuf_tabstop_push(out, 18);
+       printbuf_tabstop_push(out, 18);
+
+       prt_str(out, "Data type");
+       prt_tab(out);
+
+       prt_str(out, "Required/total");
+       prt_tab(out);
+
+       prt_str(out, "Devices");
+       prt_newline(out);
 
        for (i = 0; i < BCH_REPLICAS_MAX; i++) {
                if (!u->persistent_reserved[i])
                        continue;
 
-               printf_pad(16, "%s: ", "reserved");
-               printf_pad(16, "%u/%u ", 1, i);
-               printf_pad(32, "[] ");
-               printf("%s\n", pr_units(u->persistent_reserved[i], units));
+               prt_str(out, "reserved:");
+               prt_tab(out);
+               prt_printf(out, "%u/%u ", 1, i);
+               prt_tab(out);
+               prt_str(out, "[] ");
+               prt_units_u64(out, u->persistent_reserved[i] << 9);
+               prt_tab_rjust(out);
+               prt_newline(out);
        }
 
        struct bch_replicas_usage *r;
 
        for_each_usage_replica(u, r)
                if (r->r.data_type < BCH_DATA_user)
-                       print_replicas_usage(r, &dev_names, units);
+                       replicas_usage_to_text(out, r, &dev_names);
 
        for_each_usage_replica(u, r)
                if (r->r.data_type == BCH_DATA_user &&
                    r->r.nr_required <= 1)
-                       print_replicas_usage(r, &dev_names, units);
+                       replicas_usage_to_text(out, r, &dev_names);
 
        for_each_usage_replica(u, r)
                if (r->r.data_type == BCH_DATA_user &&
                    r->r.nr_required > 1)
-                       print_replicas_usage(r, &dev_names, units);
+                       replicas_usage_to_text(out, r, &dev_names);
 
        for_each_usage_replica(u, r)
                if (r->r.data_type > BCH_DATA_user)
-                       print_replicas_usage(r, &dev_names, units);
+                       replicas_usage_to_text(out, r, &dev_names);
 
        free(u);
 
-       sort(&darray_item(dev_names, 0), darray_size(dev_names),
-            sizeof(darray_item(dev_names, 0)), dev_by_label_cmp, NULL);
+       sort(dev_names.data, dev_names.nr,
+            sizeof(dev_names.data[0]), dev_by_label_cmp, NULL);
+
+       printbuf_tabstops_reset(out);
+       printbuf_tabstop_push(out, 16);
+       printbuf_tabstop_push(out, 20);
+       printbuf_tabstop_push(out, 16);
+       printbuf_tabstop_push(out, 14);
 
-       darray_foreach(dev, dev_names)
-               print_dev_usage(fs, dev, units);
+       darray_for_each(dev_names, dev)
+               dev_usage_to_text(out, fs, dev);
 
-       darray_foreach(dev, dev_names) {
+       darray_for_each(dev_names, dev) {
                free(dev->dev);
                free(dev->label);
        }
-       darray_free(dev_names);
+       darray_exit(&dev_names);
 
        bcache_fs_close(fs);
 }
@@ -209,24 +289,33 @@ int fs_usage(void)
 
 int cmd_fs_usage(int argc, char *argv[])
 {
-       enum units units = BYTES;
+       bool human_readable = false;
+       struct printbuf buf = PRINTBUF;
        char *fs;
        int opt;
 
        while ((opt = getopt(argc, argv, "h")) != -1)
                switch (opt) {
                case 'h':
-                       units = HUMAN_READABLE;
+                       human_readable = true;
                        break;
                }
        args_shift(optind);
 
        if (!argc) {
-               print_fs_usage(".", units);
+               printbuf_reset(&buf);
+               buf.human_readable_units = human_readable;
+               fs_usage_to_text(&buf, ".");
+               printf("%s", buf.buf);
        } else {
-               while ((fs = arg_pop()))
-                       print_fs_usage(fs, units);
+               while ((fs = arg_pop())) {
+                       printbuf_reset(&buf);
+                       buf.human_readable_units = human_readable;
+                       fs_usage_to_text(&buf, fs);
+                       printf("%s", buf.buf);
+               }
        }
 
+       printbuf_exit(&buf);
        return 0;
 }