summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChristoph Hellwig <hch@lst.de>2009-07-10 13:33:38 +0200
committerAnthony Liguori <aliguori@us.ibm.com>2009-07-10 12:25:36 -0500
commit230d4fa48bd64dbc07b509e0eb0bbc885ddf4cc8 (patch)
treed86c03c958eb50dcf286e383a76d8e57d492f7ff
parent52249f0f3c9f101a71ed24e207731525b8431c0a (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.c40
1 files changed, 16 insertions, 24 deletions
diff --git a/qemu-io.c b/qemu-io.c
index 566ca79fc8..28159d807d 100644
--- a/qemu-io.c
+++ b/qemu-io.c
@@ -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;