From 6512a2a7106480c19183d6466a6845bc9bdf6ec0 Mon Sep 17 00:00:00 2001 From: aliguori Date: Fri, 20 Mar 2009 18:26:07 +0000 Subject: Implement cancellation method for dma async I/O (Avi Kivity) Move the dma helpers to a private aio pool, and implement a cancellation method for them. Should prevent issues when cancelling I/O while dma is in progress. Signed-off-by: Avi Kivity Signed-off-by: Anthony Liguori git-svn-id: svn://svn.savannah.nongnu.org/qemu/trunk@6872 c046a42c-6fe2-441c-8c8c-71466251a162 --- dma-helpers.c | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) (limited to 'dma-helpers.c') diff --git a/dma-helpers.c b/dma-helpers.c index b2ade19acb..19fa4f01fd 100644 --- a/dma-helpers.c +++ b/dma-helpers.c @@ -10,6 +10,8 @@ #include "dma.h" #include "block_int.h" +static AIOPool dma_aio_pool; + void qemu_sglist_init(QEMUSGList *qsg, int alloc_hint) { qsg->sg = qemu_malloc(alloc_hint * sizeof(ScatterGatherEntry)); @@ -126,7 +128,7 @@ static BlockDriverAIOCB *dma_bdrv_io( DMABlockState *dbs = qemu_malloc(sizeof(*dbs)); dbs->bs = bs; - dbs->acb = qemu_aio_get(bs, cb, opaque); + dbs->acb = qemu_aio_get_pool(&dma_aio_pool, bs, cb, opaque); dbs->sg = sg; dbs->sector_num = sector_num; dbs->sg_cur_index = 0; @@ -153,3 +155,14 @@ BlockDriverAIOCB *dma_bdrv_write(BlockDriverState *bs, return dma_bdrv_io(bs, sg, sector, cb, opaque, 1); } +static void dma_aio_cancel(BlockDriverAIOCB *acb) +{ + DMABlockState *dbs = (DMABlockState *)acb->opaque; + + bdrv_aio_cancel(dbs->acb); +} + +void dma_helper_init(void) +{ + aio_pool_init(&dma_aio_pool, sizeof(BlockDriverAIOCB), dma_aio_cancel); +} -- cgit v1.2.1