Home
last modified time | relevance | path

Searched refs:aio_context (Results 1 – 25 of 34) sorted by relevance

12

/openbmc/qemu/block/
H A Dreplication.c465 AioContext *aio_context; in replication_start() local
472 aio_context_acquire(aio_context); in replication_start()
632 aio_context_release(aio_context); in replication_start()
639 AioContext *aio_context; in replication_do_checkpoint() local
642 aio_context_acquire(aio_context); in replication_do_checkpoint()
659 aio_context_release(aio_context); in replication_do_checkpoint()
666 AioContext *aio_context; in replication_get_error() local
669 aio_context_acquire(aio_context); in replication_get_error()
683 aio_context_release(aio_context); in replication_get_error()
712 AioContext *aio_context; in replication_stop() local
[all …]
H A Dwrite-threshold.c36 AioContext *aio_context; in qmp_block_set_write_threshold() local
44 aio_context = bdrv_get_aio_context(bs); in qmp_block_set_write_threshold()
45 aio_context_acquire(aio_context); in qmp_block_set_write_threshold()
49 aio_context_release(aio_context); in qmp_block_set_write_threshold()
H A Dqapi-sysemu.c177 AioContext *aio_context; in blockdev_remove_medium() local
207 aio_context = bdrv_get_aio_context(bs); in blockdev_remove_medium()
208 aio_context_acquire(aio_context); in blockdev_remove_medium()
228 aio_context_release(aio_context); in blockdev_remove_medium()
440 AioContext *aio_context; in qmp_block_set_io_throttle() local
447 aio_context = blk_get_aio_context(blk); in qmp_block_set_io_throttle()
448 aio_context_acquire(aio_context); in qmp_block_set_io_throttle()
527 aio_context_release(aio_context); in qmp_block_set_io_throttle()
H A Dio_uring.c53 AioContext *aio_context; member
218 assert(luringcb->co->ctx == s->aio_context); in luring_process_completions()
413 s->aio_context = NULL; in luring_detach_aio_context()
418 s->aio_context = new_context; in luring_attach_aio_context()
420 aio_set_fd_handler(s->aio_context, s->ring.ring_fd, in luring_attach_aio_context()
H A Dlinux-aio.c58 AioContext *aio_context; member
107 assert(laiocb->co->ctx == laiocb->ctx->aio_context); in qemu_laio_process_completion()
346 uint64_t max_batch = s->aio_context->aio_max_batch ?: DEFAULT_MAX_BATCH; in laio_max_batch()
437 s->aio_context = NULL; in laio_detach_aio_context()
442 s->aio_context = new_context; in laio_attach_aio_context()
H A Dnfs.c61 AioContext *aio_context; member
197 aio_set_fd_handler(client->aio_context, nfs_get_fd(client->context), in nfs_set_events()
261 replay_bh_schedule_oneshot_event(task->client->aio_context, in nfs_co_generic_cb()
374 aio_set_fd_handler(client->aio_context, nfs_get_fd(client->context), in nfs_detach_aio_context()
384 client->aio_context = new_context; in nfs_attach_aio_context()
392 aio_set_fd_handler(client->aio_context, nfs_get_fd(client->context), in nfs_client_close()
615 client->aio_context = bdrv_get_aio_context(bs); in nfs_file_open()
652 client->aio_context = qemu_get_aio_context(); in nfs_file_co_create()
728 replay_bh_schedule_oneshot_event(task->client->aio_context, in nfs_get_allocated_file_size_cb()
H A Dthrottle-groups.c446 aio_co_enter(tgm->aio_context, co); in throttle_group_restart_queue()
552 tgm->aio_context = ctx; in throttle_group_register_tgm()
567 tgm->aio_context, in throttle_group_register_tgm()
598 AIO_WAIT_WHILE(tgm->aio_context, qatomic_read(&tgm->restart_pending) > 0); in throttle_group_unregister_tgm()
629 tgm->aio_context = new_context; in throttle_group_attach_aio_context()
655 tgm->aio_context = NULL; in throttle_group_detach_aio_context()
H A Dcurl.c118 AioContext *aio_context; member
135 aio_set_fd_handler(s->aio_context, socket->fd, in curl_drop_socket()
183 aio_set_fd_handler(s->aio_context, fd, in curl_sock_cb()
187 aio_set_fd_handler(s->aio_context, fd, in curl_sock_cb()
191 aio_set_fd_handler(s->aio_context, fd, in curl_sock_cb()
196 aio_set_fd_handler(s->aio_context, fd, in curl_sock_cb()
615 s->aio_context = new_context; in curl_attach_aio_context()
795 s->aio_context = bdrv_get_aio_context(bs); in curl_open()
H A Dnvme.c99 AioContext *aio_context; member
220 AioContext *aio_context, in nvme_create_queue_pair() argument
234 trace_nvme_create_queue_pair(idx, q, size, aio_context, in nvme_create_queue_pair()
248 q->completion_bh = aio_bh_new(aio_context, nvme_process_completion_bh, q); in nvme_create_queue_pair()
345 replay_bh_schedule_oneshot_event(q->s->aio_context, in nvme_wake_free_req_locked()
522 AioContext *aio_context = bdrv_get_aio_context(bs); in nvme_admin_cmd_sync() local
531 AIO_WAIT_WHILE(aio_context, ret == -EINPROGRESS); in nvme_admin_cmd_sync()
745 AioContext *aio_context = bdrv_get_aio_context(bs); in nvme_init() local
757 s->aio_context = bdrv_get_aio_context(bs); in nvme_init()
835 q = nvme_create_queue_pair(s, aio_context, 0, NVME_QUEUE_SIZE, errp); in nvme_init()
[all …]
H A Discsi.c68 AioContext *aio_context; member
177 acb->bh = aio_bh_new(acb->iscsilun->aio_context, iscsi_bh_cb, acb); in iscsi_schedule_bh()
266 aio_timer_init(iTask->iscsilun->aio_context, in iscsi_co_generic_cb()
288 replay_bh_schedule_oneshot_event(iTask->iscsilun->aio_context, in iscsi_co_generic_cb()
365 aio_set_fd_handler(iscsilun->aio_context, iscsi_get_fd(iscsi), in iscsi_set_events()
1542 aio_set_fd_handler(iscsilun->aio_context, iscsi_get_fd(iscsilun->iscsi), in iscsi_detach_aio_context()
1561 iscsilun->aio_context = new_context; in iscsi_attach_aio_context()
1565 iscsilun->nop_timer = aio_timer_new(iscsilun->aio_context, in iscsi_attach_aio_context()
1573 iscsilun->event_timer = aio_timer_new(iscsilun->aio_context, in iscsi_attach_aio_context()
1906 iscsilun->aio_context = bdrv_get_aio_context(bs); in iscsi_open()
[all …]
H A Dgluster.c60 AioContext *aio_context; member
753 aio_co_schedule(acb->aio_context, acb->coroutine); in gluster_finish_aiocb()
1018 acb.aio_context = bdrv_get_aio_context(bs); in qemu_gluster_co_pwrite_zeroes()
1196 acb.aio_context = bdrv_get_aio_context(bs); in qemu_gluster_co_rw()
1263 acb.aio_context = bdrv_get_aio_context(bs); in qemu_gluster_co_flush_to_disk()
1311 acb.aio_context = bdrv_get_aio_context(bs); in qemu_gluster_co_pdiscard()
H A Dio.c484 AioContext *aio_context = bdrv_get_aio_context(bs); in bdrv_drain_all_poll() local
485 aio_context_acquire(aio_context); in bdrv_drain_all_poll()
487 aio_context_release(aio_context); in bdrv_drain_all_poll()
528 AioContext *aio_context = bdrv_get_aio_context(bs); in bdrv_drain_all_begin_nopoll() local
530 aio_context_acquire(aio_context); in bdrv_drain_all_begin_nopoll()
532 aio_context_release(aio_context); in bdrv_drain_all_begin_nopoll()
591 AioContext *aio_context = bdrv_get_aio_context(bs); in bdrv_drain_all_end() local
593 aio_context_acquire(aio_context); in bdrv_drain_all_end()
595 aio_context_release(aio_context); in bdrv_drain_all_end()
2374 aio_context_acquire(aio_context); in bdrv_flush_all()
[all …]
H A Dcommit.c391 s->base = blk_new(s->common.job.aio_context, in commit_start()
403 s->top = blk_new(s->common.job.aio_context, 0, BLK_PERM_ALL); in commit_start()
/openbmc/qemu/
H A Dblockdev.c1051 AioContext *aio_context; in qmp_get_root_bs() local
1144 AioContext *aio_context; in qmp_blockdev_snapshot_delete_internal_sync() local
1235 AioContext *aio_context; in internal_snapshot_action() local
1326 AioContext *aio_context; in internal_snapshot_abort() local
1353 AioContext *aio_context; in internal_snapshot_clean() local
1398 AioContext *aio_context; in external_snapshot_action() local
1564 AioContext *aio_context; in external_snapshot_commit() local
1629 AioContext *aio_context; in external_snapshot_clean() local
1672 AioContext *aio_context; in drive_backup_action() local
1825 AioContext *aio_context; in drive_backup_commit() local
[all …]
H A Djob.c374 job->aio_context = ctx; in job_set_aio_context()
415 job->aio_context = ctx; in job_create()
467 AioContext *aio_context = job->aio_context; in job_unref_locked() local
470 aio_context_acquire(aio_context); in job_unref_locked()
472 aio_context_release(aio_context); in job_unref_locked()
589 next_aio_context = job->aio_context; in job_do_yield_locked()
599 next_aio_context = job->aio_context; in job_do_yield_locked()
848 AioContext *ctx = job->aio_context; in job_finalize_single_locked()
893 AioContext *ctx = job->aio_context; in job_cancel_async_locked()
982 AioContext *ctx = job->aio_context; in job_prepare_locked()
[all …]
H A Dblockjob.c179 return job->job.aio_context; in child_job_get_parent_aio_context()
201 aio_context_release(job->job.aio_context); in block_job_remove_all_bdrv()
203 aio_context_acquire(job->job.aio_context); in block_job_remove_all_bdrv()
215 bdrv_graph_wrunlock_ctx(job->job.aio_context); in block_job_remove_all_bdrv()
243 need_context_ops = ctx != job->job.aio_context; in block_job_add_bdrv()
246 if (job->job.aio_context != qemu_get_aio_context()) { in block_job_add_bdrv()
247 aio_context_release(job->job.aio_context); in block_job_add_bdrv()
255 if (job->job.aio_context != qemu_get_aio_context()) { in block_job_add_bdrv()
256 aio_context_acquire(job->job.aio_context); in block_job_add_bdrv()
647 return job->job.aio_context; in block_job_get_aio_context()
/openbmc/qemu/block/monitor/
H A Dbitmap-qmp-cmds.c98 AioContext *aio_context; in qmp_block_dirty_bitmap_add() local
110 aio_context = bdrv_get_aio_context(bs); in qmp_block_dirty_bitmap_add()
111 aio_context_acquire(aio_context); in qmp_block_dirty_bitmap_add()
150 aio_context_release(aio_context); in qmp_block_dirty_bitmap_add()
160 AioContext *aio_context; in block_dirty_bitmap_remove() local
169 aio_context = bdrv_get_aio_context(bs); in block_dirty_bitmap_remove()
170 aio_context_acquire(aio_context); in block_dirty_bitmap_remove()
174 aio_context_release(aio_context); in block_dirty_bitmap_remove()
181 aio_context_release(aio_context); in block_dirty_bitmap_remove()
193 aio_context_release(aio_context); in block_dirty_bitmap_remove()
H A Dblock-hmp-cmds.c144 AioContext *aio_context; in hmp_drive_del() local
171 aio_context = blk_get_aio_context(blk); in hmp_drive_del()
172 aio_context_acquire(aio_context); in hmp_drive_del()
178 aio_context_release(aio_context); in hmp_drive_del()
200 aio_context_release(aio_context); in hmp_drive_del()
216 AioContext *aio_context; in hmp_commit() local
226 aio_context_acquire(aio_context); in hmp_commit()
236 aio_context_release(aio_context); in hmp_commit()
885 AioContext *aio_context; in hmp_info_snapshots() local
914 aio_context_acquire(aio_context); in hmp_info_snapshots()
[all …]
/openbmc/qemu/block/export/
H A Dexport.c221 AioContext *aio_context = exp->ctx; in blk_exp_delete_bh() local
223 aio_context_acquire(aio_context); in blk_exp_delete_bh()
234 aio_context_release(aio_context); in blk_exp_delete_bh()
257 AioContext *aio_context = exp->ctx; in blk_exp_request_shutdown() local
259 aio_context_acquire(aio_context); in blk_exp_request_shutdown()
277 aio_context_release(aio_context); in blk_exp_request_shutdown()
/openbmc/qemu/replay/
H A Dreplay-debugging.c147 AioContext *aio_context; in replay_find_nearest_snapshot() local
155 aio_context = bdrv_get_aio_context(bs); in replay_find_nearest_snapshot()
157 aio_context_acquire(aio_context); in replay_find_nearest_snapshot()
159 aio_context_release(aio_context); in replay_find_nearest_snapshot()
/openbmc/qemu/include/block/
H A Dthrottle-groups.h37 AioContext *aio_context; member
/openbmc/qemu/include/qemu/
H A Dthrottle.h126 AioContext *aio_context,
H A Djob.h88 AioContext *aio_context; member
/openbmc/qemu/migration/
H A Dsavevm.c3052 AioContext *aio_context; in save_snapshot() local
3104 aio_context_acquire(aio_context); in save_snapshot()
3147 aio_context_release(aio_context); in save_snapshot()
3148 aio_context = NULL; in save_snapshot()
3160 if (aio_context) { in save_snapshot()
3161 aio_context_release(aio_context); in save_snapshot()
3261 AioContext *aio_context; in load_snapshot() local
3284 aio_context_acquire(aio_context); in load_snapshot()
3286 aio_context_release(aio_context); in load_snapshot()
3323 aio_context_acquire(aio_context); in load_snapshot()
[all …]
/openbmc/qemu/tests/unit/
H A Dtest-block-iothread.c519 g_assert(qemu_get_current_aio_context() == job->aio_context); in test_job_run()
530 g_assert(qemu_get_current_aio_context() == job->aio_context); in test_job_run()
785 g_assert(job->aio_context == ctx); in test_propagate_mirror()

12