david.venhoff/QEMU-Nyx-fork
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

block: Use new AsyncContext for bdrv_read/write emulation

Browse Source 
bdrv_read/write emulation is used as the perfect example why we need something
like AsyncContexts. So maybe they better start using it.

Signed-off-by: Kevin Wolf <kwolf@redhat.com>
Signed-off-by: Anthony Liguori <aliguori@us.ibm.com>
This commit is contained in:
Kevin Wolf 2009-10-22 17:54:39 +02:00 committed by Anthony Liguori
parent 9a1e948129
commit 65d6b3d885
1 changed files with 18 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
block.c
View File

@ -1696,19 +1696,26 @@ static int bdrv_read_em(BlockDriverState *bs, int64_t sector_num,
struct iovec iov; struct iovec iov;
QEMUIOVector qiov; QEMUIOVector qiov;
async_context_push();
async_ret = NOT_DONE; async_ret = NOT_DONE;
iov.iov_base = (void *)buf; iov.iov_base = (void *)buf;
iov.iov_len = nb_sectors * 512; iov.iov_len = nb_sectors * 512;
qemu_iovec_init_external(&qiov, &iov, 1); qemu_iovec_init_external(&qiov, &iov, 1);
acb = bdrv_aio_readv(bs, sector_num, &qiov, nb_sectors, acb = bdrv_aio_readv(bs, sector_num, &qiov, nb_sectors,
bdrv_rw_em_cb, &async_ret); bdrv_rw_em_cb, &async_ret);
if (acb == NULL) if (acb == NULL) {
return -1; async_ret = -1;
goto fail;
}
while (async_ret == NOT_DONE) { while (async_ret == NOT_DONE) {
qemu_aio_wait(); qemu_aio_wait();
} }
fail:
async_context_pop();
return async_ret; return async_ret;
} }
@ -1720,17 +1727,24 @@ static int bdrv_write_em(BlockDriverState *bs, int64_t sector_num,
struct iovec iov; struct iovec iov;
QEMUIOVector qiov; QEMUIOVector qiov;
async_context_push();
async_ret = NOT_DONE; async_ret = NOT_DONE;
iov.iov_base = (void *)buf; iov.iov_base = (void *)buf;
iov.iov_len = nb_sectors * 512; iov.iov_len = nb_sectors * 512;
qemu_iovec_init_external(&qiov, &iov, 1); qemu_iovec_init_external(&qiov, &iov, 1);
acb = bdrv_aio_writev(bs, sector_num, &qiov, nb_sectors, acb = bdrv_aio_writev(bs, sector_num, &qiov, nb_sectors,
bdrv_rw_em_cb, &async_ret); bdrv_rw_em_cb, &async_ret);
if (acb == NULL) if (acb == NULL) {
return -1; async_ret = -1;
goto fail;
}
while (async_ret == NOT_DONE) { while (async_ret == NOT_DONE) {
qemu_aio_wait(); qemu_aio_wait();
} }
fail:
async_context_pop();
return async_ret; return async_ret;
} }