Home
last modified time | relevance | path

Searched refs:ready_list (Results 1 – 6 of 6) sorted by relevance

/qemu/util/
H A Daio-posix.c35 void aio_add_ready_handler(AioHandlerList *ready_list, in aio_add_ready_handler() argument
41 QLIST_INSERT_HEAD(ready_list, node, node_ready); in aio_add_ready_handler()
49 QLIST_INSERT_HEAD(ready_list, node, node_ready); in aio_add_poll_ready_handler()
248 aio_add_poll_ready_handler(ready_list, node); in poll_set_started()
260 AioHandlerList ready_list = QLIST_HEAD_INITIALIZER(ready_list); in aio_prepare() local
263 poll_set_started(ctx, &ready_list, false); in aio_prepare()
399 while ((node = QLIST_FIRST(ready_list))) { in aio_dispatch_ready_handlers()
551 if (remove_idle_poll_handlers(ctx, ready_list, in run_poll_handlers()
593 poll_set_started(ctx, ready_list, true); in try_poll_mode()
604 AioHandlerList ready_list = QLIST_HEAD_INITIALIZER(ready_list); in aio_poll() local
[all …]
H A Dfdmon-io_uring.c226 AioHandlerList *ready_list, in process_cqe() argument
248 aio_add_ready_handler(ready_list, node, pfd_events_from_poll(cqe->res)); in process_cqe()
255 static int process_cq_ring(AioContext *ctx, AioHandlerList *ready_list) in process_cq_ring() argument
264 if (process_cqe(ctx, ready_list, cqe)) { in process_cq_ring()
275 static int fdmon_io_uring_wait(AioContext *ctx, AioHandlerList *ready_list, in fdmon_io_uring_wait() argument
295 return process_cq_ring(ctx, ready_list); in fdmon_io_uring_wait()
H A Dfdmon-poll.c59 static int fdmon_poll_wait(AioContext *ctx, AioHandlerList *ready_list, in fdmon_poll_wait() argument
76 return ctx->fdmon_ops->wait(ctx, ready_list, timeout); in fdmon_poll_wait()
87 aio_add_ready_handler(ready_list, nodes[i], revents); in fdmon_poll_wait()
H A Dfdmon-epoll.c56 static int fdmon_epoll_wait(AioContext *ctx, AioHandlerList *ready_list, in fdmon_epoll_wait() argument
88 aio_add_ready_handler(ready_list, node, revents); in fdmon_epoll_wait()
H A Daio-posix.h44 void aio_add_ready_handler(AioHandlerList *ready_list, AioHandler *node,
/qemu/include/block/
H A Daio.h91 int (*wait)(AioContext *ctx, AioHandlerList *ready_list, int64_t timeout);