[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH] xen_disk: use bdrv_aio_flush instead of bdrv_flush
From: |
Stefano Stabellini |
Subject: |
[Qemu-devel] [PATCH] xen_disk: use bdrv_aio_flush instead of bdrv_flush |
Date: |
Fri, 13 Apr 2012 19:45:08 +0100 |
Signed-off-by: Stefano Stabellini <address@hidden>
---
hw/xen_disk.c | 13 ++++++-------
1 files changed, 6 insertions(+), 7 deletions(-)
diff --git a/hw/xen_disk.c b/hw/xen_disk.c
index 84ca76e..3e4a47b 100644
--- a/hw/xen_disk.c
+++ b/hw/xen_disk.c
@@ -324,9 +324,6 @@ static void qemu_aio_complete(void *opaque, int ret)
if (ioreq->aio_inflight > 0) {
return;
}
- if (ioreq->postsync) {
- bdrv_flush(ioreq->blkdev->bs);
- }
ioreq->status = ioreq->aio_errors ? BLKIF_RSP_ERROR : BLKIF_RSP_OKAY;
ioreq_unmap(ioreq);
@@ -343,9 +340,9 @@ static int ioreq_runio_qemu_aio(struct ioreq *ioreq)
goto err_no_map;
}
- ioreq->aio_inflight++;
if (ioreq->presync) {
- bdrv_flush(blkdev->bs); /* FIXME: aio_flush() ??? */
+ ioreq->aio_inflight++;
+ bdrv_aio_flush(ioreq->blkdev->bs, qemu_aio_complete, ioreq);
}
switch (ioreq->req.operation) {
@@ -372,8 +369,10 @@ static int ioreq_runio_qemu_aio(struct ioreq *ioreq)
/* unknown operation (shouldn't happen -- parse catches this) */
goto err;
}
-
- qemu_aio_complete(ioreq, 0);
+ if (ioreq->postsync) {
+ ioreq->aio_inflight++;
+ bdrv_aio_flush(ioreq->blkdev->bs, qemu_aio_complete, ioreq);
+ }
return 0;
--
1.7.2.5
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [Qemu-devel] [PATCH] xen_disk: use bdrv_aio_flush instead of bdrv_flush,
Stefano Stabellini <=