cmd_list improvements; use %m

This commit is contained in:
Kent Overstreet 2017-04-14 20:40:50 -08:00
parent 819f2dde79
commit 5c7454176e
9 changed files with 71 additions and 39 deletions

View File

@ -26,10 +26,7 @@ int cmd_assemble(int argc, char *argv[])
for (unsigned i = 1; i < argc; i++) for (unsigned i = 1; i < argc; i++)
assemble->devs[i] = (__u64) argv[i]; assemble->devs[i] = (__u64) argv[i];
int ret = ioctl(bcachectl_open(), BCH_IOCTL_ASSEMBLE, assemble); xioctl(bcachectl_open(), BCH_IOCTL_ASSEMBLE, assemble);
if (ret < 0)
die("BCH_IOCTL_ASSEMBLE error: %s", strerror(errno));
return 0; return 0;
} }
@ -42,9 +39,6 @@ int cmd_incremental(int argc, char *argv[])
.dev = (__u64) argv[1], .dev = (__u64) argv[1],
}; };
int ret = ioctl(bcachectl_open(), BCH_IOCTL_INCREMENTAL, &incremental); xioctl(bcachectl_open(), BCH_IOCTL_INCREMENTAL, &incremental);
if (ret < 0)
die("BCH_IOCTL_INCREMENTAL error: %s", strerror(errno));
return 0; return 0;
} }

View File

@ -13,6 +13,7 @@
#include "btree_cache.h" #include "btree_cache.h"
#include "btree_iter.h" #include "btree_iter.h"
#include "buckets.h" #include "buckets.h"
#include "error.h"
#include "journal.h" #include "journal.h"
#include "super.h" #include "super.h"
@ -153,7 +154,7 @@ int cmd_dump(int argc, char *argv[])
} }
static void list_keys(struct bch_fs *c, enum btree_id btree_id, static void list_keys(struct bch_fs *c, enum btree_id btree_id,
struct bpos start, struct bpos end, int mode) struct bpos start, struct bpos end)
{ {
struct btree_iter iter; struct btree_iter iter;
struct bkey_s_c k; struct bkey_s_c k;
@ -171,7 +172,7 @@ static void list_keys(struct bch_fs *c, enum btree_id btree_id,
} }
static void list_btree_formats(struct bch_fs *c, enum btree_id btree_id, static void list_btree_formats(struct bch_fs *c, enum btree_id btree_id,
struct bpos start, struct bpos end, int mode) struct bpos start, struct bpos end)
{ {
struct btree_iter iter; struct btree_iter iter;
struct btree *b; struct btree *b;
@ -187,6 +188,36 @@ static void list_btree_formats(struct bch_fs *c, enum btree_id btree_id,
bch2_btree_iter_unlock(&iter); bch2_btree_iter_unlock(&iter);
} }
static void list_nodes_keys(struct bch_fs *c, enum btree_id btree_id,
struct bpos start, struct bpos end)
{
struct btree_iter iter;
struct btree_node_iter node_iter;
struct bkey unpacked;
struct bkey_s_c k;
struct btree *b;
char buf[4096];
for_each_btree_node(&iter, c, btree_id, start, 0, b) {
if (bkey_cmp(b->key.k.p, end) > 0)
break;
bch2_print_btree_node(c, b, buf, sizeof(buf));
fputs(buf, stdout);
buf[0] = '\t';
for_each_btree_node_key_unpack(b, k, &node_iter,
btree_node_is_extents(b),
&unpacked) {
bch2_bkey_val_to_text(c, bkey_type(0, btree_id),
buf + 1, sizeof(buf) - 1, k);
puts(buf);
}
}
bch2_btree_iter_unlock(&iter);
}
static struct bpos parse_pos(char *buf) static struct bpos parse_pos(char *buf)
{ {
char *s = buf, *field; char *s = buf, *field;
@ -224,6 +255,7 @@ static void list_keys_usage(void)
static const char * const list_modes[] = { static const char * const list_modes[] = {
"keys", "keys",
"formats", "formats",
"nodes",
NULL NULL
}; };
@ -241,7 +273,7 @@ int cmd_list(int argc, char *argv[])
opts.norecovery = true; opts.norecovery = true;
opts.errors = BCH_ON_ERROR_CONTINUE; opts.errors = BCH_ON_ERROR_CONTINUE;
while ((opt = getopt(argc, argv, "b:s:e:i:m:h")) != -1) while ((opt = getopt(argc, argv, "b:s:e:i:m:fvh")) != -1)
switch (opt) { switch (opt) {
case 'b': case 'b':
btree_id = read_string_list_or_die(optarg, btree_id = read_string_list_or_die(optarg,
@ -263,6 +295,13 @@ int cmd_list(int argc, char *argv[])
mode = read_string_list_or_die(optarg, mode = read_string_list_or_die(optarg,
list_modes, "list mode"); list_modes, "list mode");
break; break;
case 'f':
opts.fix_errors = FSCK_ERR_YES;
opts.norecovery = false;
break;
case 'v':
opts.verbose_recovery = true;
break;
case 'h': case 'h':
list_keys_usage(); list_keys_usage();
exit(EXIT_SUCCESS); exit(EXIT_SUCCESS);
@ -277,10 +316,13 @@ int cmd_list(int argc, char *argv[])
switch (mode) { switch (mode) {
case 0: case 0:
list_keys(c, btree_id, start, end, mode); list_keys(c, btree_id, start, end);
break; break;
case 1: case 1:
list_btree_formats(c, btree_id, start, end, mode); list_btree_formats(c, btree_id, start, end);
break;
case 2:
list_nodes_keys(c, btree_id, start, end);
break; break;
default: default:
die("Invalid mode"); die("Invalid mode");

View File

@ -119,7 +119,7 @@ int cmd_device_show(int argc, char *argv[])
char link[PATH_MAX]; char link[PATH_MAX];
if (readlinkat(dirfd(fs.sysfs), entry->d_name, if (readlinkat(dirfd(fs.sysfs), entry->d_name,
link, sizeof(link)) < 0) link, sizeof(link)) < 0)
die("readlink error: %s\n", strerror(errno)); die("readlink error: %m\n");
char *dev_name = basename(dirname(link)); char *dev_name = basename(dirname(link));

View File

@ -45,7 +45,7 @@ static char *dev_t_to_path(dev_t dev)
free(sysfs_dev); free(sysfs_dev);
if (ret < 0 || ret >= sizeof(link)) if (ret < 0 || ret >= sizeof(link))
die("readlink error while looking up block device: %s", strerror(errno)); die("readlink error while looking up block device: %m");
link[ret] = '\0'; link[ret] = '\0';
@ -222,7 +222,7 @@ static void copy_xattrs(struct bch_fs *c, struct bch_inode_unpacked *dst,
char attrs[XATTR_LIST_MAX]; char attrs[XATTR_LIST_MAX];
ssize_t attrs_size = llistxattr(src, attrs, sizeof(attrs)); ssize_t attrs_size = llistxattr(src, attrs, sizeof(attrs));
if (attrs_size < 0) if (attrs_size < 0)
die("listxattr error: %s", strerror(errno)); die("listxattr error: %m");
for (const char *next, *attr = attrs; for (const char *next, *attr = attrs;
attr < attrs + attrs_size; attr < attrs + attrs_size;
@ -233,7 +233,7 @@ static void copy_xattrs(struct bch_fs *c, struct bch_inode_unpacked *dst,
ssize_t val_size = lgetxattr(src, attr, val, sizeof(val)); ssize_t val_size = lgetxattr(src, attr, val, sizeof(val));
if (val_size < 0) if (val_size < 0)
die("error getting xattr val: %s", strerror(errno)); die("error getting xattr val: %m");
const struct xattr_handler *h = xattr_resolve_name(&attr); const struct xattr_handler *h = xattr_resolve_name(&attr);
@ -356,7 +356,7 @@ static void copy_link(struct bch_fs *c, struct bch_inode_unpacked *dst,
{ {
ssize_t ret = readlink(src, buf, sizeof(buf)); ssize_t ret = readlink(src, buf, sizeof(buf));
if (ret < 0) if (ret < 0)
die("readlink error: %s", strerror(errno)); die("readlink error: %m");
write_data(c, dst, 0, buf, round_up(ret, block_bytes(c))); write_data(c, dst, 0, buf, round_up(ret, block_bytes(c)));
} }
@ -428,7 +428,7 @@ static void copy_dir(struct copy_fs_state *s,
int fd; int fd;
if (fchdir(src_fd)) if (fchdir(src_fd))
die("chdir error: %s", strerror(errno)); die("chdir error: %m");
struct stat stat = struct stat stat =
xfstatat(src_fd, d->d_name, AT_SYMLINK_NOFOLLOW); xfstatat(src_fd, d->d_name, AT_SYMLINK_NOFOLLOW);
@ -499,7 +499,7 @@ next:
} }
if (errno) if (errno)
die("readdir error: %s", strerror(errno)); die("readdir error: %m");
} }
static ranges reserve_new_fs_space(const char *file_path, unsigned block_size, static ranges reserve_new_fs_space(const char *file_path, unsigned block_size,
@ -510,8 +510,8 @@ static ranges reserve_new_fs_space(const char *file_path, unsigned block_size,
? open(file_path, O_RDWR|O_CREAT, 0600) ? open(file_path, O_RDWR|O_CREAT, 0600)
: open(file_path, O_RDWR|O_CREAT|O_EXCL, 0600); : open(file_path, O_RDWR|O_CREAT|O_EXCL, 0600);
if (fd < 0) if (fd < 0)
die("Error creating %s for bcachefs metadata: %s", die("Error creating %s for bcachefs metadata: %m",
file_path, strerror(errno)); file_path);
struct stat statbuf = xfstat(fd); struct stat statbuf = xfstat(fd);
@ -521,8 +521,7 @@ static ranges reserve_new_fs_space(const char *file_path, unsigned block_size,
*bcachefs_inum = statbuf.st_ino; *bcachefs_inum = statbuf.st_ino;
if (fallocate(fd, 0, 0, size)) if (fallocate(fd, 0, 0, size))
die("Error reserving space for bcachefs metadata: %s", die("Error reserving space for bcachefs metadata: %m");
strerror(errno));
fsync(fd); fsync(fd);
@ -581,7 +580,7 @@ static void copy_fs(struct bch_fs *c, int src_fd, const char *src_path,
die("error looking up root directory: %s", strerror(-ret)); die("error looking up root directory: %s", strerror(-ret));
if (fchdir(src_fd)) if (fchdir(src_fd))
die("chdir error: %s", strerror(errno)); die("chdir error: %m");
struct stat stat = xfstat(src_fd); struct stat stat = xfstat(src_fd);
copy_times(c, &root_inode, &stat); copy_times(c, &root_inode, &stat);

View File

@ -109,7 +109,7 @@ void bch2_add_key(struct bch_sb *sb, const char *passphrase)
add_key("user", description, add_key("user", description,
&passphrase_key, sizeof(passphrase_key), &passphrase_key, sizeof(passphrase_key),
KEY_SPEC_USER_KEYRING) < 0) KEY_SPEC_USER_KEYRING) < 0)
die("add_key error: %s", strerror(errno)); die("add_key error: %m");
memzero_explicit(description, strlen(description)); memzero_explicit(description, strlen(description));
free(description); free(description);

View File

@ -186,7 +186,7 @@ struct bch_sb *bch2_format(struct format_opts opts,
struct timespec now; struct timespec now;
if (clock_gettime(CLOCK_REALTIME, &now)) if (clock_gettime(CLOCK_REALTIME, &now))
die("error getting current time: %s", strerror(errno)); die("error getting current time: %m");
sb->time_base_lo = cpu_to_le64(now.tv_sec * NSEC_PER_SEC + now.tv_nsec); sb->time_base_lo = cpu_to_le64(now.tv_sec * NSEC_PER_SEC + now.tv_nsec);
sb->time_precision = cpu_to_le32(1); sb->time_precision = cpu_to_le32(1);

View File

@ -23,8 +23,7 @@ int submit_bio_wait(struct bio *bio)
if (bio->bi_opf & REQ_PREFLUSH) { if (bio->bi_opf & REQ_PREFLUSH) {
ret = fdatasync(bio->bi_bdev->bd_fd); ret = fdatasync(bio->bi_bdev->bd_fd);
if (ret) { if (ret) {
fprintf(stderr, "fsync error: %s\n", fprintf(stderr, "fsync error: %m\n");
strerror(errno));
return -EIO; return -EIO;
} }
} }
@ -56,16 +55,14 @@ int submit_bio_wait(struct bio *bio)
} }
if (ret != bio->bi_iter.bi_size) { if (ret != bio->bi_iter.bi_size) {
fprintf(stderr, "IO error: %li (%s)\n", fprintf(stderr, "IO error: %li (%m)\n", ret);
ret, strerror(errno));
return -EIO; return -EIO;
} }
if (bio->bi_opf & REQ_FUA) { if (bio->bi_opf & REQ_FUA) {
ret = fdatasync(bio->bi_bdev->bd_fd); ret = fdatasync(bio->bi_bdev->bd_fd);
if (ret) { if (ret) {
fprintf(stderr, "fsync error: %s\n", fprintf(stderr, "fsync error: %m\n");
strerror(errno));
return -EIO; return -EIO;
} }
} }

View File

@ -67,7 +67,7 @@ char *read_file_str(int dirfd, const char *path)
len = read(fd, buf, len); len = read(fd, buf, len);
if (len < 0) if (len < 0)
die("read error: %s", strerror(errno)); die("read error: %m");
buf[len] = '\0'; buf[len] = '\0';
if (len && buf[len - 1] == '\n') if (len && buf[len - 1] == '\n')

View File

@ -66,14 +66,14 @@ static inline void xpwrite(int fd, const void *buf, size_t count, off_t offset)
ssize_t r = pwrite(fd, buf, count, offset); ssize_t r = pwrite(fd, buf, count, offset);
if (r != count) if (r != count)
die("write error (ret %zi err %s)", r, strerror(errno)); die("write error (ret %zi err %m)", r);
} }
#define xopenat(_dirfd, _path, ...) \ #define xopenat(_dirfd, _path, ...) \
({ \ ({ \
int _fd = openat((_dirfd), (_path), __VA_ARGS__); \ int _fd = openat((_dirfd), (_path), __VA_ARGS__); \
if (_fd < 0) \ if (_fd < 0) \
die("Error opening %s: %s", (_path), strerror(errno)); \ die("Error opening %s: %m", (_path)); \
_fd; \ _fd; \
}) })
@ -83,7 +83,7 @@ static inline struct stat xfstatat(int dirfd, const char *path, int flags)
{ {
struct stat stat; struct stat stat;
if (fstatat(dirfd, path, &stat, flags)) if (fstatat(dirfd, path, &stat, flags))
die("stat error: %s", strerror(errno)); die("stat error: %m");
return stat; return stat;
} }
@ -91,14 +91,14 @@ static inline struct stat xfstat(int fd)
{ {
struct stat stat; struct stat stat;
if (fstat(fd, &stat)) if (fstat(fd, &stat))
die("stat error: %s", strerror(errno)); die("stat error: %m");
return stat; return stat;
} }
#define xioctl(_fd, _nr, ...) \ #define xioctl(_fd, _nr, ...) \
do { \ do { \
if (ioctl((_fd), (_nr), ##__VA_ARGS__)) \ if (ioctl((_fd), (_nr), ##__VA_ARGS__)) \
die(#_nr " ioctl error: %s", strerror(errno)); \ die(#_nr " ioctl error: %m"); \
} while (0) } while (0)
enum units { enum units {