block/blkverify.c

   1 /*
   2  * Block protocol for block driver correctness testing
   3  *
   4  * Copyright (C) 2010 IBM, Corp.
   5  *
   6  * This work is licensed under the terms of the GNU GPL, version 2 or later.
   7  * See the COPYING file in the top-level directory.
   8  */
   9
  10 #include "qemu/osdep.h"
  11 #include "qapi/error.h"
  12 #include "qemu/sockets.h" /* for EINPROGRESS on Windows */
  13 #include "block/block_int.h"
  14 #include "qapi/qmp/qdict.h"
  15 #include "qapi/qmp/qstring.h"
  16 #include "qemu/cutils.h"
  17 #include "qemu/module.h"
  18 #include "qemu/option.h"
  19
  20 typedef struct {
  21     BdrvChild *test_file;
  22 } BDRVBlkverifyState;
  23
  24 typedef struct BlkverifyRequest {
  25     Coroutine *co;
  26     BlockDriverState *bs;
  27
  28     /* Request metadata */
  29     bool is_write;
  30     uint64_t offset;
  31     uint64_t bytes;
  32     int flags;
  33
  34     int (*request_fn)(BdrvChild *, int64_t, unsigned int, QEMUIOVector *,
  35                       BdrvRequestFlags);
  36
  37     int ret;                    /* test image result */
  38     int raw_ret;                /* raw image result */
  39
  40     unsigned int done;          /* completion counter */
  41
  42     QEMUIOVector *qiov;         /* user I/O vector */
  43     QEMUIOVector *raw_qiov;     /* cloned I/O vector for raw file */
  44 } BlkverifyRequest;
  45
  46 static void GCC_FMT_ATTR(2, 3) blkverify_err(BlkverifyRequest *r,
  47                                              const char *fmt, ...)
  48 {
  49     va_list ap;
  50
  51     va_start(ap, fmt);
  52     fprintf(stderr, "blkverify: %s offset=%" PRId64 " bytes=%" PRId64 " ",
  53             r->is_write ? "write" : "read", r->offset, r->bytes);
  54     vfprintf(stderr, fmt, ap);
  55     fprintf(stderr, "\n");
  56     va_end(ap);
  57     exit(1);
  58 }
  59
  60 /* Valid blkverify filenames look like blkverify:path/to/raw_image:path/to/image */
  61 static void blkverify_parse_filename(const char *filename, QDict *options,
  62                                      Error **errp)
  63 {
  64     const char *c;
  65     QString *raw_path;
  66
  67
  68     /* Parse the blkverify: prefix */
  69     if (!strstart(filename, "blkverify:", &filename)) {
  70         /* There was no prefix; therefore, all options have to be already
  71            present in the QDict (except for the filename) */
  72         qdict_put_str(options, "x-image", filename);
  73         return;
  74     }
  75
  76     /* Parse the raw image filename */
  77     c = strchr(filename, ':');
  78     if (c == NULL) {
  79         error_setg(errp, "blkverify requires raw copy and original image path");
  80         return;
  81     }
  82
  83     /* TODO Implement option pass-through and set raw.filename here */
  84     raw_path = qstring_from_substr(filename, 0, c - filename);
  85     qdict_put(options, "x-raw", raw_path);
  86
  87     /* TODO Allow multi-level nesting and set file.filename here */
  88     filename = c + 1;
  89     qdict_put_str(options, "x-image", filename);
  90 }
  91
  92 static QemuOptsList runtime_opts = {
  93     .name = "blkverify",
  94     .head = QTAILQ_HEAD_INITIALIZER(runtime_opts.head),
  95     .desc = {
  96         {
  97             .name = "x-raw",
  98             .type = QEMU_OPT_STRING,
  99             .help = "[internal use only, will be removed]",
 100         },
 101         {
 102             .name = "x-image",
 103             .type = QEMU_OPT_STRING,
 104             .help = "[internal use only, will be removed]",
 105         },
 106         { /* end of list */ }
 107     },
 108 };
 109
 110 static int blkverify_open(BlockDriverState *bs, QDict *options, int flags,
 111                           Error **errp)
 112 {
 113     BDRVBlkverifyState *s = bs->opaque;
 114     QemuOpts *opts;
 115     Error *local_err = NULL;
 116     int ret;
 117
 118     opts = qemu_opts_create(&runtime_opts, NULL, 0, &error_abort);
 119     if (!qemu_opts_absorb_qdict(opts, options, &local_err)) {
 120         error_propagate(errp, local_err);
 121         ret = -EINVAL;
 122         goto fail;
 123     }
 124
 125     /* Open the raw file */
 126     bs->file = bdrv_open_child(qemu_opt_get(opts, "x-raw"), options, "raw",
 127                                bs, &child_of_bds,
 128                                BDRV_CHILD_FILTERED | BDRV_CHILD_PRIMARY,
 129                                false, &local_err);
 130     if (local_err) {
 131         ret = -EINVAL;
 132         error_propagate(errp, local_err);
 133         goto fail;
 134     }
 135
 136     /* Open the test file */
 137     s->test_file = bdrv_open_child(qemu_opt_get(opts, "x-image"), options,
 138                                    "test", bs, &child_of_bds, BDRV_CHILD_DATA,
 139                                    false, &local_err);
 140     if (local_err) {
 141         ret = -EINVAL;
 142         error_propagate(errp, local_err);
 143         goto fail;
 144     }
 145
 146     bs->supported_write_flags = BDRV_REQ_WRITE_UNCHANGED;
 147     bs->supported_zero_flags = BDRV_REQ_WRITE_UNCHANGED;
 148
 149     ret = 0;
 150 fail:
 151     qemu_opts_del(opts);
 152     return ret;
 153 }
 154
 155 static void blkverify_close(BlockDriverState *bs)
 156 {
 157     BDRVBlkverifyState *s = bs->opaque;
 158
 159     bdrv_unref_child(bs, s->test_file);
 160     s->test_file = NULL;
 161 }
 162
 163 static int64_t blkverify_getlength(BlockDriverState *bs)
 164 {
 165     BDRVBlkverifyState *s = bs->opaque;
 166
 167     return bdrv_getlength(s->test_file->bs);
 168 }
 169
 170 static void coroutine_fn blkverify_do_test_req(void *opaque)
 171 {
 172     BlkverifyRequest *r = opaque;
 173     BDRVBlkverifyState *s = r->bs->opaque;
 174
 175     r->ret = r->request_fn(s->test_file, r->offset, r->bytes, r->qiov,
 176                            r->flags);
 177     r->done++;
 178     qemu_coroutine_enter_if_inactive(r->co);
 179 }
 180
 181 static void coroutine_fn blkverify_do_raw_req(void *opaque)
 182 {
 183     BlkverifyRequest *r = opaque;
 184
 185     r->raw_ret = r->request_fn(r->bs->file, r->offset, r->bytes, r->raw_qiov,
 186                                r->flags);
 187     r->done++;
 188     qemu_coroutine_enter_if_inactive(r->co);
 189 }
 190
 191 static int coroutine_fn
 192 blkverify_co_prwv(BlockDriverState *bs, BlkverifyRequest *r, uint64_t offset,
 193                   uint64_t bytes, QEMUIOVector *qiov, QEMUIOVector *raw_qiov,
 194                   int flags, bool is_write)
 195 {
 196     Coroutine *co_a, *co_b;
 197
 198     *r = (BlkverifyRequest) {
 199         .co         = qemu_coroutine_self(),
 200         .bs         = bs,
 201         .offset     = offset,
 202         .bytes      = bytes,
 203         .qiov       = qiov,
 204         .raw_qiov   = raw_qiov,
 205         .flags      = flags,
 206         .is_write   = is_write,
 207         .request_fn = is_write ? bdrv_co_pwritev : bdrv_co_preadv,
 208     };
 209
 210     co_a = qemu_coroutine_create(blkverify_do_test_req, r);
 211     co_b = qemu_coroutine_create(blkverify_do_raw_req, r);
 212
 213     qemu_coroutine_enter(co_a);
 214     qemu_coroutine_enter(co_b);
 215
 216     while (r->done < 2) {
 217         qemu_coroutine_yield();
 218     }
 219
 220     if (r->ret != r->raw_ret) {
 221         blkverify_err(r, "return value mismatch %d != %d", r->ret, r->raw_ret);
 222     }
 223
 224     return r->ret;
 225 }
 226
 227 static int coroutine_fn
 228 blkverify_co_preadv(BlockDriverState *bs, uint64_t offset, uint64_t bytes,
 229                     QEMUIOVector *qiov, int flags)
 230 {
 231     BlkverifyRequest r;
 232     QEMUIOVector raw_qiov;
 233     void *buf;
 234     ssize_t cmp_offset;
 235     int ret;
 236
 237     buf = qemu_blockalign(bs->file->bs, qiov->size);
 238     qemu_iovec_init(&raw_qiov, qiov->niov);
 239     qemu_iovec_clone(&raw_qiov, qiov, buf);
 240
 241     ret = blkverify_co_prwv(bs, &r, offset, bytes, qiov, &raw_qiov, flags,
 242                             false);
 243
 244     cmp_offset = qemu_iovec_compare(qiov, &raw_qiov);
 245     if (cmp_offset != -1) {
 246         blkverify_err(&r, "contents mismatch at offset %" PRId64,
 247                       offset + cmp_offset);
 248     }
 249
 250     qemu_iovec_destroy(&raw_qiov);
 251     qemu_vfree(buf);
 252
 253     return ret;
 254 }
 255
 256 static int coroutine_fn
 257 blkverify_co_pwritev(BlockDriverState *bs, uint64_t offset, uint64_t bytes,
 258                      QEMUIOVector *qiov, int flags)
 259 {
 260     BlkverifyRequest r;
 261     return blkverify_co_prwv(bs, &r, offset, bytes, qiov, qiov, flags, true);
 262 }
 263
 264 static int blkverify_co_flush(BlockDriverState *bs)
 265 {
 266     BDRVBlkverifyState *s = bs->opaque;
 267
 268     /* Only flush test file, the raw file is not important */
 269     return bdrv_co_flush(s->test_file->bs);
 270 }
 271
 272 static bool blkverify_recurse_can_replace(BlockDriverState *bs,
 273                                           BlockDriverState *to_replace)
 274 {
 275     BDRVBlkverifyState *s = bs->opaque;
 276
 277     /*
 278      * blkverify quits the whole qemu process if there is a mismatch
 279      * between bs->file->bs and s->test_file->bs.  Therefore, we know
 280      * know that both must match bs and we can recurse down to either.
 281      */
 282     return bdrv_recurse_can_replace(bs->file->bs, to_replace) ||
 283            bdrv_recurse_can_replace(s->test_file->bs, to_replace);
 284 }
 285
 286 static void blkverify_refresh_filename(BlockDriverState *bs)
 287 {
 288     BDRVBlkverifyState *s = bs->opaque;
 289
 290     if (bs->file->bs->exact_filename[0]
 291         && s->test_file->bs->exact_filename[0])
 292     {
 293         int ret = snprintf(bs->exact_filename, sizeof(bs->exact_filename),
 294                            "blkverify:%s:%s",
 295                            bs->file->bs->exact_filename,
 296                            s->test_file->bs->exact_filename);
 297         if (ret >= sizeof(bs->exact_filename)) {
 298             /* An overflow makes the filename unusable, so do not report any */
 299             bs->exact_filename[0] = 0;
 300         }
 301     }
 302 }
 303
 304 static char *blkverify_dirname(BlockDriverState *bs, Error **errp)
 305 {
 306     /* In general, there are two BDSs with different dirnames below this one;
 307      * so there is no unique dirname we could return (unless both are equal by
 308      * chance). Therefore, to be consistent, just always return NULL. */
 309     error_setg(errp, "Cannot generate a base directory for blkverify nodes");
 310     return NULL;
 311 }
 312
 313 static BlockDriver bdrv_blkverify = {
 314     .format_name                      = "blkverify",
 315     .protocol_name                    = "blkverify",
 316     .instance_size                    = sizeof(BDRVBlkverifyState),
 317
 318     .bdrv_parse_filename              = blkverify_parse_filename,
 319     .bdrv_file_open                   = blkverify_open,
 320     .bdrv_close                       = blkverify_close,
 321     .bdrv_child_perm                  = bdrv_default_perms,
 322     .bdrv_getlength                   = blkverify_getlength,
 323     .bdrv_refresh_filename            = blkverify_refresh_filename,
 324     .bdrv_dirname                     = blkverify_dirname,
 325
 326     .bdrv_co_preadv                   = blkverify_co_preadv,
 327     .bdrv_co_pwritev                  = blkverify_co_pwritev,
 328     .bdrv_co_flush                    = blkverify_co_flush,
 329
 330     .is_filter                        = true,
 331     .bdrv_recurse_can_replace         = blkverify_recurse_can_replace,
 332 };
 333
 334 static void bdrv_blkverify_init(void)
 335 {
 336     bdrv_register(&bdrv_blkverify);
 337 }
 338
 339 block_init(bdrv_blkverify_init);