| /openbmc/qemu/util/ |
| H A D | aiocb.c | 31 BlockAIOCB *acb; in qemu_aio_get() local
33 acb = g_malloc(aiocb_info->aiocb_size); in qemu_aio_get()
34 acb->aiocb_info = aiocb_info; in qemu_aio_get()
35 acb->bs = bs; in qemu_aio_get()
36 acb->cb = cb; in qemu_aio_get()
37 acb->opaque = opaque; in qemu_aio_get()
38 acb->refcnt = 1; in qemu_aio_get()
39 return acb; in qemu_aio_get()
44 BlockAIOCB *acb = p; in qemu_aio_ref() local
45 acb->refcnt++; in qemu_aio_ref()
[all …]
|
| H A D | thread-pool.c | 218 static void thread_pool_cancel(BlockAIOCB *acb) in thread_pool_cancel() argument
220 ThreadPoolElementAio *elem = (ThreadPoolElementAio *)acb; in thread_pool_cancel()
|
| /openbmc/qemu/block/ |
| H A D | quorum.c | 144 QuorumAIOCB *acb; member
148 static void quorum_aio_finalize(QuorumAIOCB *acb) in quorum_aio_finalize() argument
150 g_free(acb->qcrs); in quorum_aio_finalize()
151 g_free(acb); in quorum_aio_finalize()
170 QuorumAIOCB *acb = g_new(QuorumAIOCB, 1); in quorum_aio_get() local
173 *acb = (QuorumAIOCB) { in quorum_aio_get()
181 .votes.vote_list = QLIST_HEAD_INITIALIZER(acb.votes.vote_list), in quorum_aio_get()
184 acb->qcrs = g_new0(QuorumChildRequest, s->num_children); in quorum_aio_get()
186 acb->qcrs[i].buf = NULL; in quorum_aio_get()
187 acb->qcrs[i].ret = 0; in quorum_aio_get()
[all …]
|
| H A D | qed.c | 876 static BDRVQEDState *acb_to_s(QEDAIOCB *acb) in acb_to_s() argument
878 return acb->bs->opaque; in acb_to_s()
970 static void coroutine_fn qed_aio_complete(QEDAIOCB *acb) in qed_aio_complete() argument
972 BDRVQEDState *s = acb_to_s(acb); in qed_aio_complete()
975 qemu_iovec_destroy(&acb->cur_qiov); in qed_aio_complete()
976 qed_unref_l2_cache_entry(acb->request.l2_table); in qed_aio_complete()
979 if (acb->flags & QED_AIOCB_ZERO) { in qed_aio_complete()
980 qemu_vfree(acb->qiov->iov[0].iov_base); in qed_aio_complete()
981 acb->qiov->iov[0].iov_base = NULL; in qed_aio_complete()
990 if (acb == s->allocating_acb) { in qed_aio_complete()
[all …]
|
| H A D | null.c | 157 NullAIOCB *acb = opaque; in null_bh_cb() local
158 acb->common.cb(acb->common.opaque, 0); in null_bh_cb()
159 qemu_aio_unref(acb); in null_bh_cb()
164 NullAIOCB *acb = opaque; in null_timer_cb() local
165 acb->common.cb(acb->common.opaque, 0); in null_timer_cb()
166 timer_deinit(&acb->timer); in null_timer_cb()
167 qemu_aio_unref(acb); in null_timer_cb()
174 NullAIOCB *acb; in null_aio_common() local
177 acb = qemu_aio_get(&null_aiocb_info, bs, cb, opaque); in null_aio_common()
180 aio_timer_init(bdrv_get_aio_context(bs), &acb->timer, in null_aio_common()
[all …]
|
| H A D | iscsi.c | 157 IscsiAIOCB *acb = p; in iscsi_bh_cb() local
159 qemu_bh_delete(acb->bh); in iscsi_bh_cb()
161 acb->common.cb(acb->common.opaque, acb->status); in iscsi_bh_cb()
163 if (acb->task != NULL) { in iscsi_bh_cb()
164 scsi_free_scsi_task(acb->task); in iscsi_bh_cb()
165 acb->task = NULL; in iscsi_bh_cb()
168 qemu_aio_unref(acb); in iscsi_bh_cb()
172 iscsi_schedule_bh(IscsiAIOCB *acb) in iscsi_schedule_bh() argument
174 if (acb->bh) { in iscsi_schedule_bh()
177 acb->bh = aio_bh_new(acb->iscsilun->aio_context, iscsi_bh_cb, acb); in iscsi_schedule_bh()
[all …]
|
| H A D | curl.c | 95 CURLAIOCB *acb[CURL_NUM_ACB]; member
262 curl_find_buf(BDRVCURLState *s, uint64_t start, uint64_t len, CURLAIOCB *acb) in curl_find_buf() argument
287 qemu_iovec_from_buf(acb->qiov, 0, buf, clamped_len); in curl_find_buf()
289 qemu_iovec_memset(acb->qiov, clamped_len, 0, len - clamped_len); in curl_find_buf()
291 acb->ret = 0; in curl_find_buf()
304 acb->start = start - state->buf_start; in curl_find_buf()
305 acb->end = acb->start + clamped_len; in curl_find_buf()
308 if (!state->acb[j]) { in curl_find_buf()
309 state->acb[j] = acb; in curl_find_buf()
361 CURLAIOCB *acb = state->acb[i]; in curl_multi_check_completion() local
[all …]
|
| H A D | block-backend.c | 1528 struct BlockBackendAIOCB *acb = opaque; in error_callback_bh() local
1530 blk_dec_in_flight(acb->blk); in error_callback_bh()
1531 acb->common.cb(acb->common.opaque, acb->ret); in error_callback_bh()
1532 qemu_aio_unref(acb); in error_callback_bh()
1539 struct BlockBackendAIOCB *acb; in blk_abort_aio_request() local
1543 acb = blk_aio_get(&block_backend_aiocb_info, blk, cb, opaque); in blk_abort_aio_request()
1544 acb->blk = blk; in blk_abort_aio_request()
1545 acb->ret = ret; in blk_abort_aio_request()
1548 error_callback_bh, acb); in blk_abort_aio_request()
1549 return &acb->common; in blk_abort_aio_request()
[all …]
|
| H A D | gluster.c | 736 GlusterAIOCB *acb = (GlusterAIOCB *)arg; in gluster_finish_aiocb() local
738 if (!ret || ret == acb->size) { in gluster_finish_aiocb()
739 acb->ret = 0; /* Success */ in gluster_finish_aiocb()
741 acb->ret = -errno; /* Read/Write failed */ in gluster_finish_aiocb()
743 acb->ret = -EIO; /* Partial read/write - fail it */ in gluster_finish_aiocb()
746 aio_co_schedule(acb->aio_context, acb->coroutine); in gluster_finish_aiocb()
1003 GlusterAIOCB acb; in qemu_gluster_co_pwrite_zeroes() local
1006 acb.size = bytes; in qemu_gluster_co_pwrite_zeroes()
1007 acb.ret = 0; in qemu_gluster_co_pwrite_zeroes()
1008 acb.coroutine = qemu_coroutine_self(); in qemu_gluster_co_pwrite_zeroes()
[all …]
|
| H A D | trace-events | 62 file_paio_submit(void *acb, void *opaque, int64_t offset, int count, int type) "acb %p opaque %p of…
126 qed_aio_complete(void *s, void *acb, int ret) "s %p acb %p ret %d"
127 qed_aio_setup(void *s, void *acb, int64_t sector_num, int nb_sectors, void *opaque, int flags) "s %…
128 qed_aio_next_io(void *s, void *acb, int ret, uint64_t cur_pos) "s %p acb %p ret %d cur_pos %"PRIu64
129 qed_aio_read_data(void *s, void *acb, int ret, uint64_t offset, size_t len) "s %p acb %p ret %d off…
130 qed_aio_write_data(void *s, void *acb, int ret, uint64_t offset, size_t len) "s %p acb %p ret %d of…
131 qed_aio_write_prefill(void *s, void *acb, uint64_t start, size_t len, uint64_t offset) "s %p acb %p…
132 qed_aio_write_postfill(void *s, void *acb, uint64_t start, size_t len, uint64_t offset) "s %p acb %…
133 qed_aio_write_main(void *s, void *acb, int ret, uint64_t offset, size_t len) "s %p acb %p ret %d of…
|
| H A D | file-win32.c | 155 RawWin32AIOData *acb = g_new(RawWin32AIOData, 1); in paio_submit() local
157 acb->bs = bs; in paio_submit()
158 acb->hfile = hfile; in paio_submit()
159 acb->aio_type = type; in paio_submit()
162 acb->aio_iov = qiov->iov; in paio_submit()
163 acb->aio_niov = qiov->niov; in paio_submit()
166 acb->aio_nbytes = count; in paio_submit()
167 acb->aio_offset = offset; in paio_submit()
169 trace_file_paio_submit(acb, opaque, offset, count, type); in paio_submit()
170 return thread_pool_submit_aio(aio_worker, acb, cb, opaque); in paio_submit()
|
| H A D | file-posix.c | 2588 RawPosixAIOData acb; in raw_co_prw() local
2628 acb = (RawPosixAIOData) { in raw_co_prw()
2641 ret = raw_thread_pool_submit(handle_aiocb_rw, &acb); in raw_co_prw()
2696 RawPosixAIOData acb; in raw_co_flush_to_disk() local
2704 acb = (RawPosixAIOData) { in raw_co_flush_to_disk()
2720 return raw_thread_pool_submit(handle_aiocb_flush, &acb); in raw_co_flush_to_disk()
2746 RawPosixAIOData acb; in raw_regular_truncate() local
2748 acb = (RawPosixAIOData) { in raw_regular_truncate()
2759 return raw_thread_pool_submit(handle_aiocb_truncate, &acb); in raw_regular_truncate()
3506 RawPosixAIOData acb = (RawPosixAIOData) { in raw_co_zone_report()
[all …]
|
| H A D | io.c | 1010 BlockAIOCB *acb; in bdrv_driver_preadv() local
1015 acb = drv->bdrv_aio_preadv(bs, offset, bytes, qiov, flags, in bdrv_driver_preadv()
1017 if (acb == NULL) { in bdrv_driver_preadv()
1093 BlockAIOCB *acb; in bdrv_driver_pwritev() local
1098 acb = drv->bdrv_aio_pwritev(bs, offset, bytes, qiov, flags, in bdrv_driver_pwritev()
1100 if (acb == NULL) { in bdrv_driver_pwritev()
2993 void bdrv_aio_cancel(BlockAIOCB *acb) in bdrv_aio_cancel() argument
2996 qemu_aio_ref(acb); in bdrv_aio_cancel()
2997 bdrv_aio_cancel_async(acb); in bdrv_aio_cancel()
2998 AIO_WAIT_WHILE_UNLOCKED(NULL, acb->refcnt > 1); in bdrv_aio_cancel()
[all …]
|
| /openbmc/qemu/tests/unit/ |
| H A D | test-block-backend.c | 43 BlockAIOCB *acb; in test_drain_aio_error() local
46 acb = blk_aio_flush(blk, test_drain_aio_error_flush_cb, &completed); in test_drain_aio_error()
47 g_assert(acb != NULL); in test_drain_aio_error()
60 BlockAIOCB *acb; in test_drain_all_aio_error() local
63 acb = blk_aio_flush(blk, test_drain_aio_error_flush_cb, &completed); in test_drain_all_aio_error()
64 g_assert(acb != NULL); in test_drain_all_aio_error()
|
| H A D | test-bdrv-drain.c | 223 BlockAIOCB *acb; in test_drv_cb_common() local
247 acb = blk_aio_preadv(blk, 0, &qiov, 0, aio_ret_cb, &aio_ret); in test_drv_cb_common()
248 g_assert(acb != NULL); in test_drv_cb_common()
533 BlockAIOCB *acb; in test_iothread_common() local
565 acb = blk_aio_preadv(blk, 0, &qiov, 0, test_iothread_aio_cb, &aio_ret); in test_iothread_common()
567 acb = blk_aio_preadv(blk, 0, &qiov, 0, aio_ret_cb, &aio_ret); in test_iothread_common()
569 g_assert(acb != NULL); in test_iothread_common()
1230 BlockAIOCB *acb; in test_detach_indirect() local
1301 acb = blk_aio_preadv(blk, 0, &qiov, 0, detach_by_parent_aio_cb, NULL); in test_detach_indirect()
1302 g_assert(acb != NULL); in test_detach_indirect()
|
| /openbmc/qemu/system/ |
| H A D | dma-helpers.c | 63 BlockAIOCB *acb; member
82 assert(!dbs->acb && dbs->bh); in reschedule_dma()
104 assert(!dbs->acb && !dbs->bh); in dma_complete()
125 dbs->acb = NULL; in dma_blk_cb()
181 dbs->acb = dbs->io_func(dbs->offset, &dbs->iov, in dma_blk_cb()
183 assert(dbs->acb); in dma_blk_cb()
186 static void dma_aio_cancel(BlockAIOCB *acb) in dma_aio_cancel() argument
188 DMAAIOCB *dbs = container_of(acb, DMAAIOCB, common); in dma_aio_cancel()
192 assert(!(dbs->acb && dbs->bh)); in dma_aio_cancel()
193 if (dbs->acb) { in dma_aio_cancel()
[all …]
|
| /openbmc/qemu/include/system/ |
| H A D | block-backend-global-state.h | 78 void blk_aio_cancel(BlockAIOCB *acb);
|
| H A D | block-backend-io.h | 68 void blk_aio_cancel_async(BlockAIOCB *acb);
|
| /openbmc/qemu/include/block/ |
| H A D | aio.h | 34 void (*cancel_async)(BlockAIOCB *acb);
|
| H A D | block-global-state.h | 202 void bdrv_aio_cancel(BlockAIOCB *acb);
|
| H A D | block-io.h | 103 void bdrv_aio_cancel_async(BlockAIOCB *acb);
|
| /openbmc/qemu/ |
| H A D | qemu-img.c | 4644 BlockAIOCB *acb; in bench_cb() local
4673 acb = blk_aio_flush(b->blk, cb, b); in bench_cb()
4674 if (!acb) { in bench_cb()
4699 acb = blk_aio_pwritev(b->blk, offset, b->qiov, 0, bench_cb, b); in bench_cb()
4701 acb = blk_aio_preadv(b->blk, offset, b->qiov, 0, bench_cb, b); in bench_cb()
4703 if (!acb) { in bench_cb()
|
| /openbmc/openbmc/meta-openembedded/meta-oe/recipes-support/canonical-multitouch/geis/ |
| H A D | 0001-provide-function-declaration-with-prototypes.patch | 100 index 5912acb..099cde4 100644
|
| /openbmc/qemu/hw/ide/ |
| H A D | core.c | 427 static void trim_aio_cancel(BlockAIOCB *acb) in trim_aio_cancel() argument
429 TrimAIOCB *iocb = container_of(acb, TrimAIOCB, common); in trim_aio_cancel()
|
| /openbmc/qemu/hw/nvme/ |
| H A D | ctrl.c | 3489 static void nvme_flush_cancel(BlockAIOCB *acb) in nvme_flush_cancel() argument
3491 NvmeFlushAIOCB *iocb = container_of(acb, NvmeFlushAIOCB, common); in nvme_flush_cancel()
|