diff options
author | Christoph Hellwig <hch@lst.de> | 2009-07-10 13:33:38 +0200 |
---|---|---|
committer | Anthony Liguori <aliguori@us.ibm.com> | 2009-07-10 12:25:36 -0500 |
commit | 230d4fa48bd64dbc07b509e0eb0bbc885ddf4cc8 (patch) | |
tree | d86c03c958eb50dcf286e383a76d8e57d492f7ff | |
parent | 52249f0f3c9f101a71ed24e207731525b8431c0a (diff) |
qemu-io: small cleanups for the aio code
Address a couple of review comments from Kevin.
Signed-off-by: Christoph Hellwig <hch@lst.de>
-rw-r--r-- | qemu-io.c | 40 |
1 files changed, 16 insertions, 24 deletions
@@ -769,25 +769,23 @@ aio_write_done(void *opaque, int ret) { struct aio_ctx *ctx = opaque; struct timeval t2; - int total; - int cnt = 1; gettimeofday(&t2, NULL); - total = ctx->qiov.size; if (ret < 0) { printf("aio_write failed: %s\n", strerror(-ret)); return; } - if (ctx->qflag) + if (ctx->qflag) { return; + } /* Finally, report back -- -C gives a parsable format */ t2 = tsub(t2, ctx->t1); - print_report("wrote", &t2, ctx->offset, ctx->qiov.size, total, cnt, - ctx->Cflag); + print_report("wrote", &t2, ctx->offset, ctx->qiov.size, + ctx->qiov.size, 1, ctx->Cflag); qemu_io_free(ctx->buf); free(ctx); @@ -800,44 +798,41 @@ aio_read_done(void *opaque, int ret) { struct aio_ctx *ctx = opaque; struct timeval t2; - int total; - int cnt = 1; gettimeofday(&t2, NULL); - total = ctx->qiov.size; - if (ret < 0) { printf("readv failed: %s\n", strerror(-ret)); return; } if (ctx->Pflag) { - void *cmp_buf = malloc(total); + void *cmp_buf = malloc(ctx->qiov.size); - memset(cmp_buf, ctx->pattern, total); - if (memcmp(ctx->buf, cmp_buf, total)) { + memset(cmp_buf, ctx->pattern, ctx->qiov.size); + if (memcmp(ctx->buf, cmp_buf, ctx->qiov.size)) { printf("Pattern verification failed at offset %lld, " - "%d bytes\n", - (long long) ctx->offset, total); + "%zd bytes\n", + (long long) ctx->offset, ctx->qiov.size); } free(cmp_buf); } - if (ctx->qflag) + if (ctx->qflag) { return; + } - if (ctx->vflag) - dump_buffer(ctx->buf, ctx->offset, total); + if (ctx->vflag) { + dump_buffer(ctx->buf, ctx->offset, ctx->qiov.size); + } /* Finally, report back -- -C gives a parsable format */ t2 = tsub(t2, ctx->t1); - print_report("read", &t2, ctx->offset, ctx->qiov.size, total, cnt, - ctx->Cflag); + print_report("read", &t2, ctx->offset, ctx->qiov.size, + ctx->qiov.size, 1, ctx->Cflag); qemu_io_free(ctx->buf); free(ctx); - } static void @@ -870,8 +865,6 @@ aio_read_f(int argc, char **argv) struct aio_ctx *ctx = calloc(1, sizeof(struct aio_ctx)); BlockDriverAIOCB *acb; - ctx->pattern = 0xcd; - while ((c = getopt(argc, argv, "CP:qv")) != EOF) { switch (c) { case 'C': @@ -1035,7 +1028,6 @@ aio_write_f(int argc, char **argv) return 0; } - for (i = optind; i < argc; i++) { size_t len; |