[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH v4 1/5] qemu-io: Account IO by aio_read and aio_writ
From: |
Fam Zheng |
Subject: |
[Qemu-devel] [PATCH v4 1/5] qemu-io: Account IO by aio_read and aio_write |
Date: |
Thu, 5 Jun 2014 16:47:42 +0800 |
This will enable accounting of aio requests issued from qemu-io aio
read/write commands.
Signed-off-by: Fam Zheng <address@hidden>
Reviewed-by: Benoit Canet <address@hidden>
---
qemu-io-cmds.c | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/qemu-io-cmds.c b/qemu-io-cmds.c
index 60c1ceb..ae6c299 100644
--- a/qemu-io-cmds.c
+++ b/qemu-io-cmds.c
@@ -1346,6 +1346,7 @@ out:
}
struct aio_ctx {
+ BlockDriverState *bs;
QEMUIOVector qiov;
int64_t offset;
char *buf;
@@ -1353,6 +1354,7 @@ struct aio_ctx {
int vflag;
int Cflag;
int Pflag;
+ BlockAcctCookie acct;
int pattern;
struct timeval t1;
};
@@ -1370,6 +1372,8 @@ static void aio_write_done(void *opaque, int ret)
goto out;
}
+ bdrv_acct_done(ctx->bs, &ctx->acct);
+
if (ctx->qflag) {
goto out;
}
@@ -1407,6 +1411,8 @@ static void aio_read_done(void *opaque, int ret)
g_free(cmp_buf);
}
+ bdrv_acct_done(ctx->bs, &ctx->acct);
+
if (ctx->qflag) {
goto out;
}
@@ -1462,6 +1468,7 @@ static int aio_read_f(BlockDriverState *bs, int argc,
char **argv)
int nr_iov, c;
struct aio_ctx *ctx = g_new0(struct aio_ctx, 1);
+ ctx->bs = bs;
while ((c = getopt(argc, argv, "CP:qv")) != EOF) {
switch (c) {
case 'C':
@@ -1515,6 +1522,7 @@ static int aio_read_f(BlockDriverState *bs, int argc,
char **argv)
}
gettimeofday(&ctx->t1, NULL);
+ bdrv_acct_start(bs, &ctx->acct, ctx->qiov.size, BDRV_ACCT_READ);
bdrv_aio_readv(bs, ctx->offset >> 9, &ctx->qiov,
ctx->qiov.size >> 9, aio_read_done, ctx);
return 0;
@@ -1558,6 +1566,7 @@ static int aio_write_f(BlockDriverState *bs, int argc,
char **argv)
int pattern = 0xcd;
struct aio_ctx *ctx = g_new0(struct aio_ctx, 1);
+ ctx->bs = bs;
while ((c = getopt(argc, argv, "CqP:")) != EOF) {
switch (c) {
case 'C':
@@ -1607,6 +1616,7 @@ static int aio_write_f(BlockDriverState *bs, int argc,
char **argv)
}
gettimeofday(&ctx->t1, NULL);
+ bdrv_acct_start(bs, &ctx->acct, ctx->qiov.size, BDRV_ACCT_WRITE);
bdrv_aio_writev(bs, ctx->offset >> 9, &ctx->qiov,
ctx->qiov.size >> 9, aio_write_done, ctx);
return 0;
--
2.0.0
- [Qemu-devel] [PATCH v4 0/5] This series adds iotest case for IO throttling., Fam Zheng, 2014/06/05
- [Qemu-devel] [PATCH v4 1/5] qemu-io: Account IO by aio_read and aio_write,
Fam Zheng <=
- [Qemu-devel] [PATCH v4 2/5] qtest: Add scripts/qtest/qtest.py, Fam Zheng, 2014/06/05
- [Qemu-devel] [PATCH v4 3/5] qemu-iotests: Add VM method qtest() to iotests.py, Fam Zheng, 2014/06/05
- [Qemu-devel] [PATCH v4 4/5] qemu-iotests: Allow caller to disable underscore convertion for qmp, Fam Zheng, 2014/06/05
- [Qemu-devel] [PATCH v4 5/5] qemu-iotests: Add 093 for IO throttling, Fam Zheng, 2014/06/05
- Re: [Qemu-devel] [PATCH v4 0/5] This series adds iotest case for IO throttling., Fam Zheng, 2014/06/16