2
* Block protocol for block driver correctness testing
4
* Copyright (C) 2010 IBM, Corp.
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.
11
#include "qemu_socket.h" /* for EINPROGRESS on Windows */
12
#include "block_int.h"
15
BlockDriverState *test_file;
18
typedef struct BlkverifyAIOCB BlkverifyAIOCB;
19
struct BlkverifyAIOCB {
20
BlockDriverAIOCB common;
23
/* Request metadata */
28
int ret; /* first completed request's result */
29
unsigned int done; /* completion counter */
30
bool *finished; /* completion signal for cancel */
32
QEMUIOVector *qiov; /* user I/O vector */
33
QEMUIOVector raw_qiov; /* cloned I/O vector for raw file */
34
void *buf; /* buffer for raw file I/O */
36
void (*verify)(BlkverifyAIOCB *acb);
39
static void blkverify_aio_cancel(BlockDriverAIOCB *blockacb)
41
BlkverifyAIOCB *acb = (BlkverifyAIOCB *)blockacb;
42
bool finished = false;
44
/* Wait until request completes, invokes its callback, and frees itself */
45
acb->finished = &finished;
51
static AIOPool blkverify_aio_pool = {
52
.aiocb_size = sizeof(BlkverifyAIOCB),
53
.cancel = blkverify_aio_cancel,
56
static void GCC_FMT_ATTR(2, 3) blkverify_err(BlkverifyAIOCB *acb,
62
fprintf(stderr, "blkverify: %s sector_num=%" PRId64 " nb_sectors=%d ",
63
acb->is_write ? "write" : "read", acb->sector_num,
65
vfprintf(stderr, fmt, ap);
66
fprintf(stderr, "\n");
71
/* Valid blkverify filenames look like blkverify:path/to/raw_image:path/to/image */
72
static int blkverify_open(BlockDriverState *bs, const char *filename, int flags)
74
BDRVBlkverifyState *s = bs->opaque;
78
/* Parse the blkverify: prefix */
79
if (strncmp(filename, "blkverify:", strlen("blkverify:"))) {
82
filename += strlen("blkverify:");
84
/* Parse the raw image filename */
85
c = strchr(filename, ':');
90
raw = strdup(filename);
91
raw[c - filename] = '\0';
92
ret = bdrv_file_open(&bs->file, raw, flags);
99
/* Open the test file */
100
s->test_file = bdrv_new("");
101
ret = bdrv_open(s->test_file, filename, flags, NULL);
103
bdrv_delete(s->test_file);
111
static void blkverify_close(BlockDriverState *bs)
113
BDRVBlkverifyState *s = bs->opaque;
115
bdrv_delete(s->test_file);
119
static int64_t blkverify_getlength(BlockDriverState *bs)
121
BDRVBlkverifyState *s = bs->opaque;
123
return bdrv_getlength(s->test_file);
127
* Check that I/O vector contents are identical
131
* @ret: Offset to first mismatching byte or -1 if match
133
static ssize_t blkverify_iovec_compare(QEMUIOVector *a, QEMUIOVector *b)
138
assert(a->niov == b->niov);
139
for (i = 0; i < a->niov; i++) {
141
uint8_t *p = (uint8_t *)a->iov[i].iov_base;
142
uint8_t *q = (uint8_t *)b->iov[i].iov_base;
144
assert(a->iov[i].iov_len == b->iov[i].iov_len);
145
while (len < a->iov[i].iov_len && *p++ == *q++) {
151
if (len != a->iov[i].iov_len) {
160
struct iovec *src_iov;
164
static int sortelem_cmp_src_base(const void *a, const void *b)
166
const IOVectorSortElem *elem_a = a;
167
const IOVectorSortElem *elem_b = b;
170
if (elem_a->src_iov->iov_base < elem_b->src_iov->iov_base) {
172
} else if (elem_a->src_iov->iov_base > elem_b->src_iov->iov_base) {
179
static int sortelem_cmp_src_index(const void *a, const void *b)
181
const IOVectorSortElem *elem_a = a;
182
const IOVectorSortElem *elem_b = b;
184
return elem_a->src_index - elem_b->src_index;
188
* Copy contents of I/O vector
190
* The relative relationships of overlapping iovecs are preserved. This is
191
* necessary to ensure identical semantics in the cloned I/O vector.
193
static void blkverify_iovec_clone(QEMUIOVector *dest, const QEMUIOVector *src,
196
IOVectorSortElem sortelems[src->niov];
200
/* Sort by source iovecs by base address */
201
for (i = 0; i < src->niov; i++) {
202
sortelems[i].src_index = i;
203
sortelems[i].src_iov = &src->iov[i];
205
qsort(sortelems, src->niov, sizeof(sortelems[0]), sortelem_cmp_src_base);
207
/* Allocate buffer space taking into account overlapping iovecs */
209
for (i = 0; i < src->niov; i++) {
210
struct iovec *cur = sortelems[i].src_iov;
211
ptrdiff_t rewind = 0;
214
if (last_end && last_end > cur->iov_base) {
215
rewind = last_end - cur->iov_base;
218
sortelems[i].dest_base = buf - rewind;
219
buf += cur->iov_len - MIN(rewind, cur->iov_len);
220
last_end = MAX(cur->iov_base + cur->iov_len, last_end);
223
/* Sort by source iovec index and build destination iovec */
224
qsort(sortelems, src->niov, sizeof(sortelems[0]), sortelem_cmp_src_index);
225
for (i = 0; i < src->niov; i++) {
226
qemu_iovec_add(dest, sortelems[i].dest_base, src->iov[i].iov_len);
230
static BlkverifyAIOCB *blkverify_aio_get(BlockDriverState *bs, bool is_write,
231
int64_t sector_num, QEMUIOVector *qiov,
233
BlockDriverCompletionFunc *cb,
236
BlkverifyAIOCB *acb = qemu_aio_get(&blkverify_aio_pool, bs, cb, opaque);
239
acb->is_write = is_write;
240
acb->sector_num = sector_num;
241
acb->nb_sectors = nb_sectors;
242
acb->ret = -EINPROGRESS;
247
acb->finished = NULL;
251
static void blkverify_aio_bh(void *opaque)
253
BlkverifyAIOCB *acb = opaque;
255
qemu_bh_delete(acb->bh);
257
qemu_iovec_destroy(&acb->raw_qiov);
258
qemu_vfree(acb->buf);
260
acb->common.cb(acb->common.opaque, acb->ret);
262
*acb->finished = true;
264
qemu_aio_release(acb);
267
static void blkverify_aio_cb(void *opaque, int ret)
269
BlkverifyAIOCB *acb = opaque;
271
switch (++acb->done) {
277
if (acb->ret != ret) {
278
blkverify_err(acb, "return value mismatch %d != %d", acb->ret, ret);
285
acb->bh = qemu_bh_new(blkverify_aio_bh, acb);
286
qemu_bh_schedule(acb->bh);
291
static void blkverify_verify_readv(BlkverifyAIOCB *acb)
293
ssize_t offset = blkverify_iovec_compare(acb->qiov, &acb->raw_qiov);
295
blkverify_err(acb, "contents mismatch in sector %" PRId64,
296
acb->sector_num + (int64_t)(offset / BDRV_SECTOR_SIZE));
300
static BlockDriverAIOCB *blkverify_aio_readv(BlockDriverState *bs,
301
int64_t sector_num, QEMUIOVector *qiov, int nb_sectors,
302
BlockDriverCompletionFunc *cb, void *opaque)
304
BDRVBlkverifyState *s = bs->opaque;
305
BlkverifyAIOCB *acb = blkverify_aio_get(bs, false, sector_num, qiov,
306
nb_sectors, cb, opaque);
308
acb->verify = blkverify_verify_readv;
309
acb->buf = qemu_blockalign(bs->file, qiov->size);
310
qemu_iovec_init(&acb->raw_qiov, acb->qiov->niov);
311
blkverify_iovec_clone(&acb->raw_qiov, qiov, acb->buf);
313
if (!bdrv_aio_readv(s->test_file, sector_num, qiov, nb_sectors,
314
blkverify_aio_cb, acb)) {
315
blkverify_aio_cb(acb, -EIO);
317
if (!bdrv_aio_readv(bs->file, sector_num, &acb->raw_qiov, nb_sectors,
318
blkverify_aio_cb, acb)) {
319
blkverify_aio_cb(acb, -EIO);
324
static BlockDriverAIOCB *blkverify_aio_writev(BlockDriverState *bs,
325
int64_t sector_num, QEMUIOVector *qiov, int nb_sectors,
326
BlockDriverCompletionFunc *cb, void *opaque)
328
BDRVBlkverifyState *s = bs->opaque;
329
BlkverifyAIOCB *acb = blkverify_aio_get(bs, true, sector_num, qiov,
330
nb_sectors, cb, opaque);
332
if (!bdrv_aio_writev(s->test_file, sector_num, qiov, nb_sectors,
333
blkverify_aio_cb, acb)) {
334
blkverify_aio_cb(acb, -EIO);
336
if (!bdrv_aio_writev(bs->file, sector_num, qiov, nb_sectors,
337
blkverify_aio_cb, acb)) {
338
blkverify_aio_cb(acb, -EIO);
343
static BlockDriverAIOCB *blkverify_aio_flush(BlockDriverState *bs,
344
BlockDriverCompletionFunc *cb,
347
BDRVBlkverifyState *s = bs->opaque;
349
/* Only flush test file, the raw file is not important */
350
return bdrv_aio_flush(s->test_file, cb, opaque);
353
static BlockDriver bdrv_blkverify = {
354
.format_name = "blkverify",
355
.protocol_name = "blkverify",
357
.instance_size = sizeof(BDRVBlkverifyState),
359
.bdrv_getlength = blkverify_getlength,
361
.bdrv_file_open = blkverify_open,
362
.bdrv_close = blkverify_close,
364
.bdrv_aio_readv = blkverify_aio_readv,
365
.bdrv_aio_writev = blkverify_aio_writev,
366
.bdrv_aio_flush = blkverify_aio_flush,
369
static void bdrv_blkverify_init(void)
371
bdrv_register(&bdrv_blkverify);
374
block_init(bdrv_blkverify_init);