Revision c4d9d196 block/raw-posix.c
| b/block/raw-posix.c | ||
|---|---|---|
| 750 | 750 |
BlockDriverCompletionFunc *cb, void *opaque, int type) |
| 751 | 751 |
{
|
| 752 | 752 |
RawPosixAIOData *acb = g_slice_new(RawPosixAIOData); |
| 753 |
ThreadPool *pool; |
|
| 753 | 754 |
|
| 754 | 755 |
acb->bs = bs; |
| 755 | 756 |
acb->aio_type = type; |
| ... | ... | |
| 763 | 764 |
acb->aio_offset = sector_num * 512; |
| 764 | 765 |
|
| 765 | 766 |
trace_paio_submit(acb, opaque, sector_num, nb_sectors, type); |
| 766 |
return thread_pool_submit_aio(aio_worker, acb, cb, opaque); |
|
| 767 |
pool = aio_get_thread_pool(bdrv_get_aio_context(bs)); |
|
| 768 |
return thread_pool_submit_aio(pool, aio_worker, acb, cb, opaque); |
|
| 767 | 769 |
} |
| 768 | 770 |
|
| 769 | 771 |
static BlockDriverAIOCB *raw_aio_submit(BlockDriverState *bs, |
| ... | ... | |
| 1413 | 1415 |
{
|
| 1414 | 1416 |
BDRVRawState *s = bs->opaque; |
| 1415 | 1417 |
RawPosixAIOData *acb; |
| 1418 |
ThreadPool *pool; |
|
| 1416 | 1419 |
|
| 1417 | 1420 |
if (fd_open(bs) < 0) |
| 1418 | 1421 |
return NULL; |
| ... | ... | |
| 1424 | 1427 |
acb->aio_offset = 0; |
| 1425 | 1428 |
acb->aio_ioctl_buf = buf; |
| 1426 | 1429 |
acb->aio_ioctl_cmd = req; |
| 1427 |
return thread_pool_submit_aio(aio_worker, acb, cb, opaque); |
|
| 1430 |
pool = aio_get_thread_pool(bdrv_get_aio_context(bs)); |
|
| 1431 |
return thread_pool_submit_aio(pool, aio_worker, acb, cb, opaque); |
|
| 1428 | 1432 |
} |
| 1429 | 1433 |
|
| 1430 | 1434 |
#elif defined(__FreeBSD__) || defined(__FreeBSD_kernel__) |
Also available in: Unified diff