[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [Qemu-devel] [PATCH v2 12/17] qemu-img: add a "map" subcommand
From: |
Fam Zheng |
Subject: |
Re: [Qemu-devel] [PATCH v2 12/17] qemu-img: add a "map" subcommand |
Date: |
Thu, 18 Jul 2013 15:25:38 +0800 |
User-agent: |
Mutt/1.5.21 (2010-09-15) |
On Tue, 07/16 18:29, Paolo Bonzini wrote:
> This command dumps the metadata of an entire chain, in either tabular or JSON
> format.
>
> Signed-off-by: Paolo Bonzini <address@hidden>
> ---
> v1->v2: mention encrypted clusters, use PRId64
>
> qemu-img-cmds.hx | 6 ++
> qemu-img.c | 185
> +++++++++++++++++++++++++++++++++++++++++++++++++++++++
> 2 files changed, 191 insertions(+)
>
> diff --git a/qemu-img-cmds.hx b/qemu-img-cmds.hx
> index 4ca7e95..acc3a1c 100644
> --- a/qemu-img-cmds.hx
> +++ b/qemu-img-cmds.hx
> @@ -45,6 +45,12 @@ STEXI
> @item info [-f @var{fmt}] address@hidden [--backing-chain] @var{filename}
> ETEXI
>
> +DEF("map", img_map,
> + "map [-f fmt] [--output=ofmt] filename")
> +STEXI
> address@hidden map [-f @var{fmt}] address@hidden filename
> +ETEXI
> +
> DEF("snapshot", img_snapshot,
> "snapshot [-q] [-l | -a snapshot | -c snapshot | -d snapshot] filename")
> STEXI
> diff --git a/qemu-img.c b/qemu-img.c
> index c5c8ebc..b905bb6 100644
> --- a/qemu-img.c
> +++ b/qemu-img.c
> @@ -1768,6 +1768,191 @@ static int img_info(int argc, char **argv)
> return 0;
> }
>
> +
> +typedef struct MapEntry {
> + int flags;
> + int depth;
> + int64_t start;
> + int64_t length;
> + int64_t offset;
> +} MapEntry;
> +
> +static void dump_map_entry(OutputFormat output_format, MapEntry *e,
> + MapEntry *next)
> +{
> + switch (output_format) {
> + case OFORMAT_HUMAN:
> + if ((e->flags & (BDRV_BLOCK_DATA|BDRV_BLOCK_ZERO)) ==
> BDRV_BLOCK_DATA) {
> + printf("%"PRId64" %"PRId64" %d %"PRId64"\n",
> + e->start, e->length, e->depth, e->offset);
> + }
> + /* This format ignores the distinction between 0, ZERO and ZERO|DATA.
> + * Modify the flags here to allow more coalescing.
> + */
> + if (next &&
> + (next->flags & (BDRV_BLOCK_DATA|BDRV_BLOCK_ZERO)) !=
> BDRV_BLOCK_DATA) {
> + next->flags &= ~BDRV_BLOCK_DATA;
> + next->flags |= BDRV_BLOCK_ZERO;
> + }
> + break;
> + case OFORMAT_JSON:
> + printf("%s{ 'start': %"PRId64", 'length': %"PRId64", 'depth': %d, "
> + "'zero': %s, 'data': %s",
> + (e->start == 0 ? "[" : ",\n"),
> + e->start, e->length, e->depth,
> + (e->flags & BDRV_BLOCK_ZERO) ? "true" : "false",
> + (e->flags & BDRV_BLOCK_DATA) ? "true" : "false");
> + if (e->flags & BDRV_BLOCK_OFFSET_VALID) {
> + printf(", 'offset': %"PRId64"", e->offset);
> + }
> + putchar('}');
> +
> + if (!next) {
> + printf("]\n");
> + }
> + break;
> + }
> +}
> +
> +static int64_t get_block_status(BlockDriverState *bs, int64_t sector_num,
> + int *nb_sectors, int *depth)
> +{
> + int64_t ret;
> +
> + /* As an optimization, we could cache the current range of unallocated
> + * clusters in each file of the chain, and avoid querying the same
> + * range repeatedly.
> + */
> +
> + *depth = 0;
> + for (;;) {
> + int orig_nb_sectors = *nb_sectors;
> +
> + if (bs == NULL) {
> + return 0;
> + }
> + ret = bdrv_get_block_status(bs, sector_num, *nb_sectors, nb_sectors);
> + if (ret < 0) {
> + return ret;
> + }
> +
> + if (ret & (BDRV_BLOCK_ZERO|BDRV_BLOCK_DATA)) {
> + return ret;
> + }
> + if (!*nb_sectors) {
> + /* Beyond the end of this image (while presumably within the
> + * range of the BlockDriverState above this one). The extra
> + * data is read as zeroes.
> + */
> + *nb_sectors = orig_nb_sectors;
> + return BDRV_BLOCK_ZERO;
> + }
> +
> + bs = bs->backing_hd;
> + (*depth)++;
> + }
> +}
> +
> +static int img_map(int argc, char **argv)
> +{
> + int c;
> + OutputFormat output_format = OFORMAT_HUMAN;
> + BlockDriverState *bs;
> + const char *filename, *fmt, *output;
> + int64_t length;
> + MapEntry curr = { .length = 0 }, next;
> +
> + fmt = NULL;
> + output = NULL;
> + for(;;) {
> + int option_index = 0;
> + static const struct option long_options[] = {
> + {"help", no_argument, 0, 'h'},
> + {"format", required_argument, 0, 'f'},
> + {"output", required_argument, 0, OPTION_OUTPUT},
> + {0, 0, 0, 0}
> + };
> + c = getopt_long(argc, argv, "f:h",
> + long_options, &option_index);
> + if (c == -1) {
> + break;
> + }
> + switch(c) {
> + case '?':
> + case 'h':
> + help();
> + break;
> + case 'f':
> + fmt = optarg;
> + break;
> + case OPTION_OUTPUT:
> + output = optarg;
> + break;
> + }
> + }
> + if (optind >= argc) {
> + help();
> + }
> + filename = argv[optind++];
> +
> + if (output && !strcmp(output, "json")) {
> + output_format = OFORMAT_JSON;
> + } else if (output && !strcmp(output, "human")) {
> + output_format = OFORMAT_HUMAN;
> + } else if (output) {
> + error_report("--output must be used with human or json as
> argument.");
> + return 1;
> + }
> +
> + bs = bdrv_new_open(filename, fmt, BDRV_O_FLAGS, true, false);
> + if (!bs) {
> + return 1;
> + }
> +
> + length = bdrv_getlength(bs);
> + while (curr.start + curr.length < length) {
> + int64_t nsectors_left, ret;
> + int64_t sector_num;
> + int n, depth, flags;
> +
> + /* Probe up to 1 G at a time. */
> + sector_num = (curr.start + curr.length) >> BDRV_SECTOR_BITS;
> + nsectors_left = DIV_ROUND_UP(length, BDRV_SECTOR_SIZE) - sector_num;
> + n = MAX(1 << (30 - BDRV_SECTOR_BITS), nsectors_left);
> + ret = get_block_status(bs, sector_num, &n, &depth);
Am I misunderstanding here, n is at least 1G, but in your comment it's
up to 1 G at a time?
> +
> + if (ret < 0) {
> + error_report("Could not read file metadata: %s", strerror(-ret));
> + return 1;
> + }
> + if ((ret & BDRV_BLOCK_DATA) &&
> + !(ret & BDRV_BLOCK_OFFSET_VALID)) {
> + error_report("File contains external, encrypted or compressed
> clusters.");
> + return 1;
> + }
> +
> + flags = ret & ~BDRV_BLOCK_OFFSET_MASK;
> + ret &= BDRV_BLOCK_OFFSET_MASK;
> + if (curr.length == 0 || curr.flags != flags || curr.depth != depth ||
> + ((curr.flags & BDRV_BLOCK_OFFSET_VALID) &&
> + curr.offset + curr.length != ret)) {
> + next.flags = flags;
> + next.depth = depth;
> + next.start = sector_num << BDRV_SECTOR_BITS;
> + next.offset = ret;
> + next.length = 0;
> + if (curr.length > 0) {
> + dump_map_entry(output_format, &curr, &next);
> + }
> + curr = next;
> + }
> + curr.length += n << BDRV_SECTOR_BITS;
> + }
> +
> + dump_map_entry(output_format, &curr, NULL);
> + return 0;
> +}
> +
> #define SNAPSHOT_LIST 1
> #define SNAPSHOT_CREATE 2
> #define SNAPSHOT_APPLY 3
> --
> 1.8.3.1
>
>
--
Fam
- Re: [Qemu-devel] [PATCH v2 10/17] block: define get_block_status return value, (continued)
Re: [Qemu-devel] [PATCH v2 10/17] block: define get_block_status return value, Eric Blake, 2013/07/19
[Qemu-devel] [PATCH v2 11/17] block: return get_block_status data and flags for formats, Paolo Bonzini, 2013/07/16
[Qemu-devel] [PATCH v2 13/17] block: use bdrv_has_zero_init to return BDRV_BLOCK_ZERO, Paolo Bonzini, 2013/07/16
[Qemu-devel] [PATCH v2 12/17] qemu-img: add a "map" subcommand, Paolo Bonzini, 2013/07/16
[Qemu-devel] [PATCH v2 14/17] raw-posix: return get_block_status data and flags, Paolo Bonzini, 2013/07/16
[Qemu-devel] [PATCH v2 15/17] raw-posix: detect XFS unwritten extents, Paolo Bonzini, 2013/07/16
[Qemu-devel] [PATCH v2 16/17] block: add default get_block_status implementation for protocols, Paolo Bonzini, 2013/07/16
[Qemu-devel] [PATCH v2 17/17] block: look for zero blocks in bs->file, Paolo Bonzini, 2013/07/16