Lines Matching refs:ready_list
36 void aio_add_ready_handler(AioHandlerList *ready_list, in aio_add_ready_handler() argument
42 QLIST_INSERT_HEAD(ready_list, node, node_ready); in aio_add_ready_handler()
45 static void aio_add_poll_ready_handler(AioHandlerList *ready_list, in aio_add_poll_ready_handler() argument
50 QLIST_INSERT_HEAD(ready_list, node, node_ready); in aio_add_poll_ready_handler()
217 static bool poll_set_started(AioContext *ctx, AioHandlerList *ready_list, in poll_set_started() argument
249 aio_add_poll_ready_handler(ready_list, node); in poll_set_started()
261 AioHandlerList ready_list = QLIST_HEAD_INITIALIZER(ready_list); in aio_prepare() local
264 poll_set_started(ctx, &ready_list, false); in aio_prepare()
395 AioHandlerList *ready_list) in aio_dispatch_ready_handlers() argument
400 while ((node = QLIST_FIRST(ready_list))) { in aio_dispatch_ready_handlers()
433 AioHandlerList *ready_list, in run_poll_handlers_once() argument
443 aio_add_poll_ready_handler(ready_list, node); in run_poll_handlers_once()
469 AioHandlerList *ready_list, in remove_idle_poll_handlers() argument
502 aio_add_poll_ready_handler(ready_list, node); in remove_idle_poll_handlers()
523 static bool run_poll_handlers(AioContext *ctx, AioHandlerList *ready_list, in run_poll_handlers() argument
545 progress = run_poll_handlers_once(ctx, ready_list, in run_poll_handlers()
552 if (remove_idle_poll_handlers(ctx, ready_list, in run_poll_handlers()
579 static bool try_poll_mode(AioContext *ctx, AioHandlerList *ready_list, in try_poll_mode() argument
594 poll_set_started(ctx, ready_list, true); in try_poll_mode()
596 if (run_poll_handlers(ctx, ready_list, max_ns, timeout)) { in try_poll_mode()
605 AioHandlerList ready_list = QLIST_HEAD_INITIALIZER(ready_list); in aio_poll() local
630 progress = try_poll_mode(ctx, &ready_list, &timeout); in aio_poll()
666 if (poll_set_started(ctx, &ready_list, false)) { in aio_poll()
671 ctx->fdmon_ops->wait(ctx, &ready_list, timeout); in aio_poll()
724 progress |= aio_dispatch_ready_handlers(ctx, &ready_list); in aio_poll()