Btrfs-progs: make zero-log use partial open
[platform/upstream/btrfs-progs.git] / btrfs-list.c
index a748d5e..b6b8493 100644 (file)
  */
 
 #define _GNU_SOURCE
-#ifndef __CHECKER__
 #include <sys/ioctl.h>
 #include <sys/mount.h>
 #include "ioctl.h"
-#endif
 #include <stdio.h>
 #include <stdlib.h>
 #include <sys/types.h>
@@ -35,6 +33,7 @@
 #include "utils.h"
 #include <uuid/uuid.h>
 #include "btrfs-list.h"
+#include "rbtree-utils.h"
 
 #define BTRFS_LIST_NFILTERS_INCREASE   (2 * BTRFS_LIST_FILTER_MAX)
 #define BTRFS_LIST_NCOMPS_INCREASE     (2 * BTRFS_LIST_COMP_MAX)
@@ -46,7 +45,7 @@ struct root_lookup {
        struct rb_root root;
 };
 
-struct {
+static struct {
        char    *name;
        char    *column_name;
        int     need_print;
@@ -87,6 +86,11 @@ struct {
                .need_print     = 0,
        },
        {
+               .name           = "received_uuid",
+               .column_name    = "Received UUID",
+               .need_print     = 0,
+       },
+       {
                .name           = "uuid",
                .column_name    = "UUID",
                .need_print     = 0,
@@ -240,9 +244,8 @@ void btrfs_list_free_comparer_set(struct btrfs_list_comparer_set *comp_set)
        free(comp_set);
 }
 
-int btrfs_list_setup_comparer(struct btrfs_list_comparer_set  **comp_set,
-                             enum btrfs_list_comp_enum comparer,
-                             int is_descending)
+static int btrfs_list_setup_comparer(struct btrfs_list_comparer_set **comp_set,
+               enum btrfs_list_comp_enum comparer, int is_descending)
 {
        struct btrfs_list_comparer_set *set = *comp_set;
        int size;
@@ -394,7 +397,7 @@ static struct root_info *root_tree_search(struct root_lookup *root_tree,
 static int update_root(struct root_lookup *root_lookup,
                       u64 root_id, u64 ref_tree, u64 root_offset, u64 flags,
                       u64 dir_id, char *name, int name_len, u64 ogen, u64 gen,
-                      time_t ot, void *uuid, void *puuid)
+                      time_t ot, void *uuid, void *puuid, void *ruuid)
 {
        struct root_info *ri;
 
@@ -402,8 +405,7 @@ static int update_root(struct root_lookup *root_lookup,
        if (!ri || ri->root_id != root_id)
                return -ENOENT;
        if (name && name_len > 0) {
-               if (ri->name)
-                       free(ri->name);
+               free(ri->name);
 
                ri->name = malloc(name_len + 1);
                if (!ri->name) {
@@ -433,6 +435,8 @@ static int update_root(struct root_lookup *root_lookup,
                memcpy(&ri->uuid, uuid, BTRFS_UUID_SIZE);
        if (puuid)
                memcpy(&ri->puuid, puuid, BTRFS_UUID_SIZE);
+       if (ruuid)
+               memcpy(&ri->ruuid, ruuid, BTRFS_UUID_SIZE);
 
        return 0;
 }
@@ -451,17 +455,19 @@ static int update_root(struct root_lookup *root_lookup,
  * ot: the original time(create time) of the root
  * uuid: uuid of the root
  * puuid: uuid of the root parent if any
+ * ruuid: uuid of the received subvol, if any
  */
 static int add_root(struct root_lookup *root_lookup,
                    u64 root_id, u64 ref_tree, u64 root_offset, u64 flags,
                    u64 dir_id, char *name, int name_len, u64 ogen, u64 gen,
-                   time_t ot, void *uuid, void *puuid)
+                   time_t ot, void *uuid, void *puuid, void *ruuid)
 {
        struct root_info *ri;
        int ret;
 
        ret = update_root(root_lookup, root_id, ref_tree, root_offset, flags,
-                         dir_id, name, name_len, ogen, gen, ot, uuid, puuid);
+                         dir_id, name, name_len, ogen, gen, ot,
+                         uuid, puuid, ruuid);
        if (!ret)
                return 0;
 
@@ -505,6 +511,9 @@ static int add_root(struct root_lookup *root_lookup,
        if (puuid)
                memcpy(&ri->puuid, puuid, BTRFS_UUID_SIZE);
 
+       if (ruuid)
+               memcpy(&ri->ruuid, ruuid, BTRFS_UUID_SIZE);
+
        ret = root_tree_insert(root_lookup, ri);
        if (ret) {
                printf("failed to insert tree %llu\n", (unsigned long long)root_id);
@@ -513,33 +522,20 @@ static int add_root(struct root_lookup *root_lookup,
        return 0;
 }
 
-void __free_root_info(struct root_info *ri)
+static void __free_root_info(struct rb_node *node)
 {
-       if (ri->name)
-               free(ri->name);
-
-       if (ri->path)
-               free(ri->path);
-
-       if (ri->full_path)
-               free(ri->full_path);
+       struct root_info *ri;
 
+       ri = rb_entry(node, struct root_info, rb_node);
+       free(ri->name);
+       free(ri->path);
+       free(ri->full_path);
        free(ri);
 }
 
-void __free_all_subvolumn(struct root_lookup *root_tree)
+static inline void __free_all_subvolumn(struct root_lookup *root_tree)
 {
-       struct root_info *entry;
-       struct rb_node *n;
-
-       n = rb_first(&root_tree->root);
-       while (n) {
-               entry = rb_entry(n, struct root_info, rb_node);
-               rb_erase(n, &root_tree->root);
-               __free_root_info(entry);
-
-               n = rb_first(&root_tree->root);
-       }
+       rb_free_nodes(&root_tree->root, __free_root_info);
 }
 
 /*
@@ -577,13 +573,13 @@ static int resolve_root(struct root_lookup *rl, struct root_info *ri,
 
                add_len = strlen(found->path);
 
-               /* room for / and for null */
-               tmp = malloc(add_len + 2 + len);
-               if (!tmp) {
-                       perror("malloc failed");
-                       exit(1);
-               }
                if (full_path) {
+                       /* room for / and for null */
+                       tmp = malloc(add_len + 2 + len);
+                       if (!tmp) {
+                               perror("malloc failed");
+                               exit(1);
+                       }
                        memcpy(tmp + add_len + 1, full_path, len);
                        tmp[add_len] = '/';
                        memcpy(tmp, found->path, add_len);
@@ -595,23 +591,18 @@ static int resolve_root(struct root_lookup *rl, struct root_info *ri,
                        full_path = strdup(found->path);
                        len = add_len;
                }
+               if (!ri->top_id)
+                       ri->top_id = found->ref_tree;
 
                next = found->ref_tree;
-
-               if (next == top_id) {
-                       ri->top_id = top_id;
+               if (next == top_id)
                        break;
-               }
-
                /*
                * if the ref_tree = BTRFS_FS_TREE_OBJECTID,
                * we are at the top
                */
-               if (next == BTRFS_FS_TREE_OBJECTID) {
-                       ri->top_id = next;
+               if (next == BTRFS_FS_TREE_OBJECTID)
                        break;
-               }
-
                /*
                * if the ref_tree wasn't in our tree of roots, the
                * subvolume was deleted.
@@ -775,7 +766,7 @@ static u64 find_root_gen(int fd)
 
                if (sk->min_type != BTRFS_ROOT_ITEM_KEY)
                        break;
-               if (sk->min_objectid != BTRFS_ROOT_ITEM_KEY)
+               if (sk->min_objectid != ino_args.treeid)
                        break;
        }
        return max_found;
@@ -827,7 +818,7 @@ static char *__ino_resolve(int fd, u64 dirid)
  * simple string builder, returning a new string with both
  * dirid and name
  */
-char *build_name(char *dirid, char *name)
+static char *build_name(char *dirid, char *name)
 {
        char *full;
        if (!dirid)
@@ -1000,6 +991,7 @@ static int __list_subvol_search(int fd, struct root_lookup *root_lookup)
        time_t t;
        u8 uuid[BTRFS_UUID_SIZE];
        u8 puuid[BTRFS_UUID_SIZE];
+       u8 ruuid[BTRFS_UUID_SIZE];
 
        root_lookup_init(root_lookup);
        memset(&args, 0, sizeof(args));
@@ -1052,27 +1044,29 @@ static int __list_subvol_search(int fd, struct root_lookup *root_lookup)
 
                                add_root(root_lookup, sh.objectid, sh.offset,
                                         0, 0, dir_id, name, name_len, 0, 0, 0,
-                                        NULL, NULL);
+                                        NULL, NULL, NULL);
                        } else if (sh.type == BTRFS_ROOT_ITEM_KEY) {
                                ri = (struct btrfs_root_item *)(args.buf + off);
                                gen = btrfs_root_generation(ri);
                                flags = btrfs_root_flags(ri);
                                if(sh.len >
                                   sizeof(struct btrfs_root_item_v0)) {
-                                       t = ri->otime.sec;
+                                       t = btrfs_stack_timespec_sec(&ri->otime);
                                        ogen = btrfs_root_otransid(ri);
                                        memcpy(uuid, ri->uuid, BTRFS_UUID_SIZE);
                                        memcpy(puuid, ri->parent_uuid, BTRFS_UUID_SIZE);
+                                       memcpy(ruuid, ri->received_uuid, BTRFS_UUID_SIZE);
                                } else {
                                        t = 0;
                                        ogen = 0;
                                        memset(uuid, 0, BTRFS_UUID_SIZE);
                                        memset(puuid, 0, BTRFS_UUID_SIZE);
+                                       memset(ruuid, 0, BTRFS_UUID_SIZE);
                                }
 
                                add_root(root_lookup, sh.objectid, 0,
                                         sh.offset, flags, 0, NULL, 0, ogen,
-                                        gen, t, uuid, puuid);
+                                        gen, t, uuid, puuid, ruuid);
                        }
 
                        off += sh.len;
@@ -1180,7 +1174,12 @@ static int filter_full_path(struct root_info *ri, u64 data)
 
 static int filter_by_parent(struct root_info *ri, u64 data)
 {
-       return !uuid_compare(ri->puuid, (u8 *)data);
+       return !uuid_compare(ri->puuid, (u8 *)(unsigned long)data);
+}
+
+static int filter_deleted(struct root_info *ri, u64 data)
+{
+       return ri->deleted;
 }
 
 static btrfs_list_filter_func all_filter_funcs[] = {
@@ -1196,6 +1195,7 @@ static btrfs_list_filter_func all_filter_funcs[] = {
        [BTRFS_LIST_FILTER_TOPID_EQUAL]         = filter_topid_equal,
        [BTRFS_LIST_FILTER_FULL_PATH]           = filter_full_path,
        [BTRFS_LIST_FILTER_BY_PARENT]           = filter_by_parent,
+       [BTRFS_LIST_FILTER_DELETED]             = filter_deleted,
 };
 
 struct btrfs_list_filter_set *btrfs_list_alloc_filter_set(void)
@@ -1250,6 +1250,9 @@ int btrfs_list_setup_filter(struct btrfs_list_filter_set **filter_set,
 
        BUG_ON(set->filters[set->nfilters].filter_func);
 
+       if (filter == BTRFS_LIST_FILTER_DELETED)
+               set->only_deleted = 1;
+
        set->filters[set->nfilters].filter_func = all_filter_funcs[filter];
        set->filters[set->nfilters].data = data;
        set->nfilters++;
@@ -1261,9 +1264,15 @@ static int filter_root(struct root_info *ri,
 {
        int i, ret;
 
-       if (!set || !set->nfilters)
+       if (!set)
                return 1;
 
+       if (set->only_deleted && !ri->deleted)
+               return 0;
+
+       if (!set->only_deleted && ri->deleted)
+               return 0;
+
        for (i = 0; i < set->nfilters; i++) {
                if (!set->filters[i].filter_func)
                        break;
@@ -1291,12 +1300,13 @@ static void __filter_and_sort_subvol(struct root_lookup *all_subvols,
                entry = rb_entry(n, struct root_info, rb_node);
 
                ret = resolve_root(all_subvols, entry, top_id);
-               if (ret == -ENOENT)
-                       goto skip;
+               if (ret == -ENOENT) {
+                       entry->full_path = strdup("DELETED");
+                       entry->deleted = 1;
+               }
                ret = filter_root(entry, filter_set);
                if (ret)
                        sort_tree_insert(sort_tree, entry, comp_set);
-skip:
                n = rb_prev(n);
        }
 }
@@ -1323,7 +1333,7 @@ static void print_subvolume_column(struct root_info *subv,
                                   enum btrfs_list_column_enum column)
 {
        char tstr[256];
-       char uuidparse[37];
+       char uuidparse[BTRFS_UUID_UNPARSED_SIZE];
 
        BUG_ON(column >= BTRFS_LIST_ALL || column < 0);
 
@@ -1344,10 +1354,12 @@ static void print_subvolume_column(struct root_info *subv,
                printf("%llu", subv->top_id);
                break;
        case BTRFS_LIST_OTIME:
-               if (subv->otime)
-                       strftime(tstr, 256, "%Y-%m-%d %X",
-                                localtime(&subv->otime));
-               else
+               if (subv->otime) {
+                       struct tm tm;
+
+                       localtime_r(&subv->otime, &tm);
+                       strftime(tstr, 256, "%Y-%m-%d %X", &tm);
+               } else
                        strcpy(tstr, "-");
                printf("%s", tstr);
                break;
@@ -1365,6 +1377,13 @@ static void print_subvolume_column(struct root_info *subv,
                        uuid_unparse(subv->puuid, uuidparse);
                printf("%s", uuidparse);
                break;
+       case BTRFS_LIST_RUUID:
+               if (uuid_is_null(subv->ruuid))
+                       strcpy(uuidparse, "-");
+               else
+                       uuid_unparse(subv->ruuid, uuidparse);
+               printf("%s", uuidparse);
+               break;
        case BTRFS_LIST_PATH:
                BUG_ON(!subv->full_path);
                printf("%s", subv->full_path);
@@ -1426,7 +1445,7 @@ static void print_single_volume_info_default(struct root_info *subv)
        printf("\n");
 }
 
-static void print_all_volume_info_tab_head()
+static void print_all_volume_info_tab_head(void)
 {
        int i;
        int len;
@@ -1482,7 +1501,7 @@ static void print_all_volume_info(struct root_lookup *sorted_tree,
        }
 }
 
-int btrfs_list_subvols(int fd, struct root_lookup *root_lookup)
+static int btrfs_list_subvols(int fd, struct root_lookup *root_lookup)
 {
        int ret;
 
@@ -1527,7 +1546,7 @@ int btrfs_list_subvols_print(int fd, struct btrfs_list_filter_set *filter_set,
        return 0;
 }
 
-char *strdup_or_null(const char *s)
+static char *strdup_or_null(const char *s)
 {
        if (!s)
                return NULL;
@@ -1694,7 +1713,7 @@ int btrfs_list_find_updated_files(int fd, u64 root_id, u64 oldest_gen)
                if (ret < 0) {
                        fprintf(stderr, "ERROR: can't perform the search- %s\n",
                                strerror(e));
-                       return ret;
+                       break;
                }
                /* the ioctl returns the number of item it found in nr_items */
                if (sk->nr_items == 0)
@@ -1794,7 +1813,7 @@ char *btrfs_list_path_for_root(int fd, u64 root)
        return ret_path;
 }
 
-int btrfs_list_parse_sort_string(char *optarg,
+int btrfs_list_parse_sort_string(char *opt_arg,
                                 struct btrfs_list_comparer_set **comps)
 {
        int order;
@@ -1803,7 +1822,7 @@ int btrfs_list_parse_sort_string(char *optarg,
        char **ptr_argv;
        int what_to_sort;
 
-       while ((p = strtok(optarg, ",")) != NULL) {
+       while ((p = strtok(opt_arg, ",")) != NULL) {
                flag = 0;
                ptr_argv = all_sort_items;
 
@@ -1839,7 +1858,7 @@ int btrfs_list_parse_sort_string(char *optarg,
                        what_to_sort = btrfs_list_get_sort_item(p);
                        btrfs_list_setup_comparer(comps, what_to_sort, order);
                }
-               optarg = NULL;
+               opt_arg = NULL;
        }
 
        return 0;
@@ -1850,38 +1869,30 @@ int btrfs_list_parse_sort_string(char *optarg,
  *
  * type is the filter object.
  */
-int btrfs_list_parse_filter_string(char *optarg,
+int btrfs_list_parse_filter_string(char *opt_arg,
                                   struct btrfs_list_filter_set **filters,
                                   enum btrfs_list_filter_enum type)
 {
 
        u64 arg;
-       char *ptr_parse_end = NULL;
-       char *ptr_optarg_end = optarg + strlen(optarg);
 
-       switch (*(optarg++)) {
+       switch (*(opt_arg++)) {
        case '+':
-               arg = (u64)strtol(optarg, &ptr_parse_end, 10);
+               arg = arg_strtou64(opt_arg);
                type += 2;
-               if (ptr_parse_end != ptr_optarg_end)
-                       return -1;
 
                btrfs_list_setup_filter(filters, type, arg);
                break;
        case '-':
-               arg = (u64)strtoll(optarg, &ptr_parse_end, 10);
+               arg = arg_strtou64(opt_arg);
                type += 1;
-               if (ptr_parse_end != ptr_optarg_end)
-                       return -1;
 
                btrfs_list_setup_filter(filters, type, arg);
                break;
        default:
-               optarg--;
-               arg = (u64)strtoll(optarg, &ptr_parse_end, 10);
+               opt_arg--;
+               arg = arg_strtou64(opt_arg);
 
-               if (ptr_parse_end != ptr_optarg_end)
-                       return -1;
                btrfs_list_setup_filter(filters, type, arg);
                break;
        }