/illumos-kvm-cmd/block/ |
H A D | vdi.c | 508 acb->orig_buf = acb->buf; in vdi_aio_setup() 533 acb->bh = qemu_bh_new(cb, acb); in vdi_schedule_bh() 572 acb->nb_sectors -= acb->n_sectors; in vdi_aio_read_cb() 580 acb->sector_num += acb->n_sectors; in vdi_aio_read_cb() 581 acb->buf += acb->n_sectors * SECTOR_SIZE; in vdi_aio_read_cb() 619 qemu_iovec_from_buffer(acb->qiov, acb->orig_buf, acb->qiov->size); in vdi_aio_read_cb() 622 acb->common.cb(acb->common.opaque, ret); in vdi_aio_read_cb() 656 acb->nb_sectors -= acb->n_sectors; in vdi_aio_write_cb() 657 acb->sector_num += acb->n_sectors; in vdi_aio_write_cb() 658 acb->buf += acb->n_sectors * SECTOR_SIZE; in vdi_aio_write_cb() [all …]
|
H A D | blkverify.c | 63 acb->is_write ? "write" : "read", acb->sector_num, in blkverify_err() 246 acb->bh = NULL; in blkverify_aio_get() 251 acb->done = 0; in blkverify_aio_get() 253 acb->buf = NULL; in blkverify_aio_get() 256 return acb; in blkverify_aio_get() 264 if (acb->buf) { in blkverify_aio_bh() 268 acb->common.cb(acb->common.opaque, acb->ret); in blkverify_aio_bh() 290 acb->verify(acb); in blkverify_aio_cb() 293 acb->bh = qemu_bh_new(blkverify_aio_bh, acb); in blkverify_aio_cb() 318 qemu_iovec_init(&acb->raw_qiov, acb->qiov->niov); in blkverify_aio_readv() [all …]
|
H A D | qcow2.c | 415 acb->bh = qemu_bh_new(cb, acb); in qcow2_schedule_bh() 445 qemu_iovec_copy(&acb->hd_qiov, acb->qiov, acb->bytes_done, in qcow2_aio_read_cb() 453 acb->sector_num += acb->cur_nr_sectors; in qcow2_aio_read_cb() 454 acb->bytes_done += acb->cur_nr_sectors * 512; in qcow2_aio_read_cb() 463 acb->cur_nr_sectors = acb->remaining_sectors; in qcow2_aio_read_cb() 478 qemu_iovec_copy(&acb->hd_qiov, acb->qiov, acb->bytes_done, in qcow2_aio_read_cb() 557 acb->common.cb(acb->common.opaque, ret); in qcow2_aio_read_cb() 644 acb->sector_num += acb->cur_nr_sectors; in qcow2_aio_write_cb() 645 acb->bytes_done += acb->cur_nr_sectors * 512; in qcow2_aio_write_cb() 677 qemu_iovec_copy(&acb->hd_qiov, acb->qiov, acb->bytes_done, in qcow2_aio_write_cb() [all …]
|
H A D | qed.c | 137 if (!acb) { in qed_write_header_read_cb() 792 acb->bh = qemu_bh_new(qed_aio_complete_bh, acb); in qed_aio_complete() 954 uint64_t start = acb->cur_pos + acb->cur_qiov.size; in qed_aio_write_postfill() 1022 qemu_iovec_copy(&acb->cur_qiov, acb->qiov, acb->qiov_offset, len); in qed_aio_write_alloc() 1045 qemu_iovec_copy(&acb->cur_qiov, acb->qiov, acb->qiov_offset, len); in qed_aio_write_inplace() 1115 qemu_iovec_copy(&acb->cur_qiov, acb->qiov, acb->qiov_offset, len); in qed_aio_read_data() 1149 trace_qed_aio_next_io(s, acb, ret, acb->cur_pos + acb->cur_qiov.size); in qed_aio_next_io() 1157 acb->qiov_offset += acb->cur_qiov.size; in qed_aio_next_io() 1158 acb->cur_pos += acb->cur_qiov.size; in qed_aio_next_io() 1162 if (acb->cur_pos >= acb->end_pos) { in qed_aio_next_io() [all …]
|
H A D | qcow.c | 566 acb->nb_sectors -= acb->n; in qcow_aio_read_cb() 567 acb->sector_num += acb->n; in qcow_aio_read_cb() 568 acb->buf += acb->n * 512; in qcow_aio_read_cb() 581 if (acb->n > acb->nb_sectors) in qcow_aio_read_cb() 582 acb->n = acb->nb_sectors; in qcow_aio_read_cb() 591 &acb->hd_qiov, acb->n, qcow_aio_read_cb, acb); in qcow_aio_read_cb() 660 acb->nb_sectors -= acb->n; in qcow_aio_write_cb() 661 acb->sector_num += acb->n; in qcow_aio_write_cb() 662 acb->buf += acb->n * 512; in qcow_aio_write_cb() 672 if (acb->n > acb->nb_sectors) in qcow_aio_write_cb() [all …]
|
H A D | curl.c | 131 CURLAIOCB *acb = s->acb[i]; in curl_read_cb() local 133 if (!acb) in curl_read_cb() 137 qemu_iovec_from_buffer(acb->qiov, s->orig_buf + acb->start, in curl_read_cb() 138 acb->end - acb->start); in curl_read_cb() 139 acb->common.cb(acb->common.opaque, 0); in curl_read_cb() 174 acb->common.cb(acb->common.opaque, 0); in curl_find_buf() 188 acb->end = acb->start + len; in curl_find_buf() 192 state->acb[j] = acb; in curl_find_buf() 412 CURLAIOCB *acb; in curl_aio_readv() local 418 if (!acb) in curl_aio_readv() [all …]
|
H A D | rbd.c | 59 RBDAIOCB *acb; member 346 RBDAIOCB *acb = rcb->acb; in rbd_complete_aio() local 349 acb->aiocnt--; in rbd_complete_aio() 389 acb->bh = qemu_bh_new(rbd_aio_bh_cb, acb); in rbd_complete_aio() 691 qemu_iovec_from_buffer(acb->qiov, acb->bounce, acb->qiov->size); in rbd_aio_bh_cb() 694 acb->common.cb(acb->common.opaque, (acb->ret > 0 ? 0 : acb->ret)); in rbd_aio_bh_cb() 708 RBDAIOCB *acb; in rbd_aio_rw_vector() local 723 acb->ret = 0; in rbd_aio_rw_vector() 725 acb->s = s; in rbd_aio_rw_vector() 730 qemu_iovec_to_buffer(acb->qiov, acb->bounce); in rbd_aio_rw_vector() [all …]
|
H A D | sheepdog.c | 400 acb->common.cb(acb->common.opaque, acb->ret); in sd_finish_aiocb() 413 acb->common.cb(acb->common.opaque, -EIO); in sd_aio_cancel() 437 acb->bh = NULL; in sd_aio_setup() 438 acb->ret = 0; in sd_aio_setup() 440 return acb; in sd_aio_setup() 445 if (acb->bh) { in sd_schedule_bh() 446 error_report("bug: %d %d\n", acb->aiocb_type, acb->aiocb_type); in sd_schedule_bh() 450 acb->bh = qemu_bh_new(cb, acb); in sd_schedule_bh() 451 if (!acb->bh) { in sd_schedule_bh() 772 acb->qiov->niov, 0, acb->aiocb_type); in send_pending_req() [all …]
|
H A D | blkdebug.c | 319 qemu_bh_delete(acb->bh); in error_callback_bh() 320 acb->common.cb(acb->common.opaque, acb->ret); in error_callback_bh() 321 qemu_aio_release(acb); in error_callback_bh() 327 qemu_aio_release(acb); in blkdebug_aio_cancel() 347 acb->ret = -error; in inject_error() 350 acb->bh = bh; in inject_error() 353 return &acb->common; in inject_error() 366 BlockDriverAIOCB *acb = in blkdebug_aio_readv() local 368 return acb; in blkdebug_aio_readv() 381 BlockDriverAIOCB *acb = in blkdebug_aio_writev() local [all …]
|
/illumos-kvm-cmd/ |
H A D | posix-aio-compat.c | 432 acb = *pacb; in posix_aio_process_queue() 433 if (!acb) in posix_aio_process_queue() 462 acb->common.cb(acb->common.opaque, ret); in posix_aio_process_queue() 539 if (!acb->active) { in paio_cancel() 554 paio_remove(acb); in paio_cancel() 569 if (!acb) in paio_submit() 571 acb->aio_type = type; in paio_submit() 588 return &acb->common; in paio_submit() 598 if (!acb) in paio_ioctl() 604 acb->aio_offset = 0; in paio_ioctl() [all …]
|
H A D | block.c | 2404 acb->pool->cancel(acb); in bdrv_aio_cancel() 2440 qemu_iovec_from_buffer(acb->qiov, acb->bounce, acb->qiov->size); in bdrv_aio_bh_cb() 2442 acb->common.cb(acb->common.opaque, acb->ret); in bdrv_aio_bh_cb() 2464 if (!acb->bh) in bdrv_aio_rw_vector() 2465 acb->bh = qemu_bh_new(bdrv_aio_bh_cb, acb); in bdrv_aio_rw_vector() 2468 qemu_iovec_to_buffer(acb->qiov, acb->bounce); in bdrv_aio_rw_vector() 2502 acb->ret = 0; in bdrv_aio_flush_em() 2504 if (!acb->bh) in bdrv_aio_flush_em() 2505 acb->bh = qemu_bh_new(bdrv_aio_bh_cb, acb); in bdrv_aio_flush_em() 2524 acb->bh = qemu_bh_new(bdrv_aio_bh_cb, acb); in bdrv_aio_noop_em() [all …]
|
H A D | dma-helpers.c | 42 BlockDriverAIOCB *acb; member 88 dbs->acb = NULL; in dma_bdrv_cb() 120 dbs->acb = bdrv_aio_writev(dbs->bs, dbs->sector_num, &dbs->iov, in dma_bdrv_cb() 123 dbs->acb = bdrv_aio_readv(dbs->bs, dbs->sector_num, &dbs->iov, in dma_bdrv_cb() 126 if (!dbs->acb) { in dma_bdrv_cb() 133 static void dma_aio_cancel(BlockDriverAIOCB *acb) in dma_aio_cancel() argument 135 DMAAIOCB *dbs = container_of(acb, DMAAIOCB, common); in dma_aio_cancel() 137 if (dbs->acb) { in dma_aio_cancel() 138 bdrv_aio_cancel(dbs->acb); in dma_aio_cancel() 154 dbs->acb = NULL; in dma_bdrv_io() [all …]
|
H A D | qemu-io.c | 238 BlockDriverAIOCB *acb; in do_aio_readv() local 241 acb = bdrv_aio_readv(bs, offset >> 9, qiov, qiov->size >> 9, in do_aio_readv() 243 if (!acb) in do_aio_readv() 255 BlockDriverAIOCB *acb; in do_aio_writev() local 260 if (!acb) in do_aio_writev() 1124 BlockDriverAIOCB *acb; in aio_read_f() local 1175 acb = bdrv_aio_readv(bs, ctx->offset >> 9, &ctx->qiov, in aio_read_f() 1177 if (!acb) { in aio_read_f() 1225 BlockDriverAIOCB *acb; in aio_write_f() local 1270 acb = bdrv_aio_writev(bs, ctx->offset >> 9, &ctx->qiov, in aio_write_f() [all …]
|
H A D | block_int.h | 44 void (*cancel)(BlockDriverAIOCB *acb);
|
H A D | block.h | 122 void bdrv_aio_cancel(BlockDriverAIOCB *acb);
|
/illumos-kvm-cmd/hw/ |
H A D | virtio-blk.c | 267 BlockDriverAIOCB *acb; in virtio_blk_handle_flush() local 274 acb = bdrv_aio_flush(req->dev->bs, virtio_blk_flush_complete, req); in virtio_blk_handle_flush() 275 if (!acb) { in virtio_blk_handle_flush() 315 BlockDriverAIOCB *acb; in virtio_blk_handle_read() local 329 acb = bdrv_aio_readv(req->dev->bs, sector, &req->qiov, in virtio_blk_handle_read() 332 if (!acb) { in virtio_blk_handle_read()
|
/illumos-kvm-cmd/hw/ide/ |
H A D | core.c | 656 BlockDriverAIOCB *acb; in ide_flush_cache() local 663 acb = bdrv_aio_flush(s->bs, ide_flush_cb, s); in ide_flush_cache() 664 if (acb == NULL) { in ide_flush_cache()
|