include/block/aio.h

61 bool aio_poll_disabled(AioContext *ctx);
77     void (*update)(AioContext *ctx, AioHandler *old_node, AioHandler *new_node);
91     int (*wait)(AioContext *ctx, AioHandlerList *ready_list, int64_t timeout);
107     bool (*need_wait)(AioContext *ctx);
125 struct AioContext {  struct
263 AioContext *aio_context_new(Error **errp);
271 void aio_context_ref(AioContext *ctx);
279 void aio_context_unref(AioContext *ctx);
287 void aio_bh_schedule_oneshot_full(AioContext *ctx, QEMUBHFunc *cb, void *opaque,
311 QEMUBH *aio_bh_new_full(AioContext *ctx, QEMUBHFunc *cb, void *opaque,
346 void aio_notify(AioContext *ctx);
364 void aio_notify_accept(AioContext *ctx);
378 int aio_bh_poll(AioContext *ctx);
425 bool aio_prepare(AioContext *ctx);
432 bool aio_pending(AioContext *ctx);
438 void aio_dispatch(AioContext *ctx);
453 bool no_coroutine_fn aio_poll(AioContext *ctx, bool blocking);
462 void aio_set_fd_handler(AioContext *ctx,
477 void aio_set_event_notifier(AioContext *ctx,
492 void aio_set_event_notifier_poll(AioContext *ctx,
500 GSource *aio_get_g_source(AioContext *ctx);
503 struct ThreadPool *aio_get_thread_pool(AioContext *ctx);
506 struct LinuxAioState *aio_setup_linux_aio(AioContext *ctx, Error **errp);
509 struct LinuxAioState *aio_get_linux_aio(AioContext *ctx);
512 LuringState *aio_setup_linux_io_uring(AioContext *ctx, Error **errp);
515 LuringState *aio_get_linux_io_uring(AioContext *ctx);
534 static inline QEMUTimer *aio_timer_new_with_attrs(AioContext *ctx,  in aio_timer_new_with_attrs()
555 static inline QEMUTimer *aio_timer_new(AioContext *ctx, QEMUClockType type,  in aio_timer_new()
576 static inline void aio_timer_init_with_attrs(AioContext *ctx,  in aio_timer_init_with_attrs()
596 static inline void aio_timer_init(AioContext *ctx,  in aio_timer_init()
610 int64_t aio_compute_timeout(AioContext *ctx);
624 void aio_co_schedule(AioContext *ctx, Coroutine *co);
633 void coroutine_fn aio_co_reschedule_self(AioContext *new_ctx);
656 void aio_co_enter(AioContext *ctx, Coroutine *co);
665 AioContext *qemu_get_current_aio_context(void);
667 void qemu_set_current_aio_context(AioContext *ctx);
675 void aio_context_setup(AioContext *ctx);
683 void aio_context_destroy(AioContext *ctx);
686 void aio_context_use_g_source(AioContext *ctx);
697 void aio_context_set_poll_params(AioContext *ctx, int64_t max_ns,
707 void aio_context_set_aio_params(AioContext *ctx, int64_t max_batch);
715 void aio_context_set_thread_pool_params(AioContext *ctx, int64_t min,