97 lines
3.2 KiB
Diff
97 lines
3.2 KiB
Diff
From 3b92e958482155404cfd134a9608041eed69622a Mon Sep 17 00:00:00 2001
|
|
From: Avi Kivity <avi@redhat.com>
|
|
Date: Fri, 20 Mar 2009 18:26:12 +0000
|
|
Subject: [STABLE][PATCH 1/4] Use vectored aiocb storage to store vector translation state
|
|
|
|
Now that we have a dedicated acb pool for vector translation acbs, we can
|
|
store the vector translation state in the acbs instead of in an external
|
|
structure.
|
|
|
|
Signed-off-by: Avi Kivity <avi@redhat.com>
|
|
|
|
---
|
|
block.c | 29 ++++++++++++++---------------
|
|
1 files changed, 14 insertions(+), 15 deletions(-)
|
|
|
|
diff --git a/block.c b/block.c
|
|
index b12318f..689ea37 100644
|
|
--- a/block.c
|
|
+++ b/block.c
|
|
@@ -1332,31 +1332,32 @@ char *bdrv_snapshot_dump(char *buf, int buf_size, QEMUSnapshotInfo *sn)
|
|
/**************************************************************/
|
|
/* async I/Os */
|
|
|
|
-typedef struct VectorTranslationState {
|
|
+typedef struct VectorTranslationAIOCB {
|
|
+ BlockDriverAIOCB common;
|
|
QEMUIOVector *iov;
|
|
uint8_t *bounce;
|
|
int is_write;
|
|
BlockDriverAIOCB *aiocb;
|
|
- BlockDriverAIOCB *this_aiocb;
|
|
-} VectorTranslationState;
|
|
+} VectorTranslationAIOCB;
|
|
|
|
-static void bdrv_aio_cancel_vector(BlockDriverAIOCB *acb)
|
|
+static void bdrv_aio_cancel_vector(BlockDriverAIOCB *_acb)
|
|
{
|
|
- VectorTranslationState *s = acb->opaque;
|
|
+ VectorTranslationAIOCB *acb
|
|
+ = container_of(_acb, VectorTranslationAIOCB, common);
|
|
|
|
- bdrv_aio_cancel(s->aiocb);
|
|
+ bdrv_aio_cancel(acb->aiocb);
|
|
}
|
|
|
|
static void bdrv_aio_rw_vector_cb(void *opaque, int ret)
|
|
{
|
|
- VectorTranslationState *s = opaque;
|
|
+ VectorTranslationAIOCB *s = (VectorTranslationAIOCB *)opaque;
|
|
|
|
if (!s->is_write) {
|
|
qemu_iovec_from_buffer(s->iov, s->bounce, s->iov->size);
|
|
}
|
|
qemu_vfree(s->bounce);
|
|
- s->this_aiocb->cb(s->this_aiocb->opaque, ret);
|
|
- qemu_aio_release(s->this_aiocb);
|
|
+ s->common.cb(s->common.opaque, ret);
|
|
+ qemu_aio_release(s);
|
|
}
|
|
|
|
static BlockDriverAIOCB *bdrv_aio_rw_vector(BlockDriverState *bs,
|
|
@@ -1368,11 +1369,9 @@ static BlockDriverAIOCB *bdrv_aio_rw_vector(BlockDriverState *bs,
|
|
int is_write)
|
|
|
|
{
|
|
- VectorTranslationState *s = qemu_mallocz(sizeof(*s));
|
|
- BlockDriverAIOCB *aiocb = qemu_aio_get_pool(&vectored_aio_pool, bs,
|
|
- cb, opaque);
|
|
+ VectorTranslationAIOCB *s = qemu_aio_get_pool(&vectored_aio_pool, bs,
|
|
+ cb, opaque);
|
|
|
|
- s->this_aiocb = aiocb;
|
|
s->iov = iov;
|
|
s->bounce = qemu_memalign(512, nb_sectors * 512);
|
|
s->is_write = is_write;
|
|
@@ -1384,7 +1383,7 @@ static BlockDriverAIOCB *bdrv_aio_rw_vector(BlockDriverState *bs,
|
|
s->aiocb = bdrv_aio_read(bs, sector_num, s->bounce, nb_sectors,
|
|
bdrv_aio_rw_vector_cb, s);
|
|
}
|
|
- return aiocb;
|
|
+ return &s->common;
|
|
}
|
|
|
|
BlockDriverAIOCB *bdrv_aio_readv(BlockDriverState *bs, int64_t sector_num,
|
|
@@ -1560,7 +1559,7 @@ static int bdrv_write_em(BlockDriverState *bs, int64_t sector_num,
|
|
|
|
void bdrv_init(void)
|
|
{
|
|
- aio_pool_init(&vectored_aio_pool, sizeof(BlockDriverAIOCB),
|
|
+ aio_pool_init(&vectored_aio_pool, sizeof(VectorTranslationAIOCB),
|
|
bdrv_aio_cancel_vector);
|
|
|
|
bdrv_register(&bdrv_raw);
|
|
--
|
|
1.6.0.6
|
|
|