X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=cmds-send.c;h=c5ecdaa11999017545c35b3605810b57e509c916;hb=refs%2Fheads%2Faccepted%2Ftizen_5.0_unified;hp=37b4e791f66ce43678c56c1b872a64e9ebfa852f;hpb=ba23855cdc8961bbaef1fcad4854d494cdb3afd3;p=platform%2Fupstream%2Fbtrfs-progs.git diff --git a/cmds-send.c b/cmds-send.c index 37b4e79..c5ecdaa 100644 --- a/cmds-send.c +++ b/cmds-send.c @@ -43,8 +43,9 @@ #include "send.h" #include "send-utils.h" +#include "help.h" -#define SEND_BUFFER_SIZE (64 * 1024) +#define SEND_BUFFER_SIZE SZ_64K /* * Default is 1 for historical reasons, changing may break scripts that expect @@ -70,8 +71,12 @@ static int get_root_id(struct btrfs_send *sctx, const char *path, u64 *root_id) si = subvol_uuid_search(&sctx->sus, 0, NULL, 0, path, subvol_search_by_path); - if (!si) - return -ENOENT; + if (IS_ERR_OR_NULL(si)) { + if (!si) + return -ENOENT; + else + return PTR_ERR(si); + } *root_id = si->root_id; free(si->path); free(si); @@ -85,8 +90,8 @@ static struct subvol_info *get_parent(struct btrfs_send *sctx, u64 root_id) si_tmp = subvol_uuid_search(&sctx->sus, root_id, NULL, 0, NULL, subvol_search_by_root_id); - if (!si_tmp) - return NULL; + if (IS_ERR_OR_NULL(si_tmp)) + return si_tmp; si = subvol_uuid_search(&sctx->sus, 0, si_tmp->parent_uuid, 0, NULL, subvol_search_by_uuid); @@ -105,8 +110,11 @@ static int find_good_parent(struct btrfs_send *sctx, u64 root_id, u64 *found) int i; parent = get_parent(sctx, root_id); - if (!parent) { - ret = -ENOENT; + if (IS_ERR_OR_NULL(parent)) { + if (!parent) + ret = -ENOENT; + else + ret = PTR_ERR(parent); goto out; } @@ -122,7 +130,7 @@ static int find_good_parent(struct btrfs_send *sctx, u64 root_id, u64 *found) s64 tmp; parent2 = get_parent(sctx, sctx->clone_sources[i]); - if (!parent2) + if (IS_ERR_OR_NULL(parent2)) continue; if (parent2->root_id != parent->root_id) { free(parent2->path); @@ -136,9 +144,11 @@ static int find_good_parent(struct btrfs_send *sctx, u64 root_id, u64 *found) parent2 = subvol_uuid_search(&sctx->sus, sctx->clone_sources[i], NULL, 0, NULL, subvol_search_by_root_id); - - if (!parent2) { - ret = -ENOENT; + if (IS_ERR_OR_NULL(parent2)) { + if (!parent2) + ret = -ENOENT; + else + ret = PTR_ERR(parent2); goto out; } tmp = parent2->ctransid - parent->ctransid; @@ -225,7 +235,7 @@ out: return ret; } -static void *dump_thread_copy(void *arg) +static void* read_sent_data_copy(void *arg) { int ret; struct btrfs_send *sctx = (struct btrfs_send*)arg; @@ -258,7 +268,7 @@ out: } #endif -static void* dump_thread(void *arg) +static void *read_sent_data(void *arg) { int ret; struct btrfs_send *sctx = (struct btrfs_send*)arg; @@ -318,8 +328,7 @@ static int do_send(struct btrfs_send *send, u64 parent_root_id, send->send_fd = pipefd[0]; if (!ret) - ret = pthread_create(&t_read, NULL, dump_thread, - send); + ret = pthread_create(&t_read, NULL, read_sent_data, send); if (ret) { ret = -ret; error("thread setup failed: %s", strerror(-ret));