qemu-devel.nongnu.org archive mirror
 help / color / mirror / Atom feed
* [Qemu-devel] [PATCH 1/2] qemu-io: small cleanups for the aio code
@ 2009-07-01 11:20 Christoph Hellwig
  2009-07-09 20:02 ` Anthony Liguori
  0 siblings, 1 reply; 7+ messages in thread
From: Christoph Hellwig @ 2009-07-01 11:20 UTC (permalink / raw)
  To: qemu-devel

Address a couple of review comments from Kevin.


Signed-off-by: Christoph Hellwig <hch@lst.de>

Index: qemu/qemu-io.c
===================================================================
--- qemu.orig/qemu-io.c	2009-07-01 10:45:24.488370800 +0200
+++ qemu/qemu-io.c	2009-07-01 10:52:44.962241654 +0200
@@ -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);
+				(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;
 

^ permalink raw reply	[flat|nested] 7+ messages in thread

end of thread, other threads:[~2009-07-10 15:25 UTC | newest]

Thread overview: 7+ messages (download: mbox.gz follow: Atom feed
-- links below jump to the message on this page --
2009-07-01 11:20 [Qemu-devel] [PATCH 1/2] qemu-io: small cleanups for the aio code Christoph Hellwig
2009-07-09 20:02 ` Anthony Liguori
2009-07-10  1:37   ` Christoph Hellwig
2009-07-10 10:20     ` malc
2009-07-10 10:47       ` Christoph Hellwig
2009-07-10 13:04         ` Jamie Lokier
2009-07-10 15:25         ` malc

This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).