Lines Matching refs:io_task_work
249 llist_for_each_entry_safe(req, tmp, node, io_task_work.node) in io_fallback_req_func()
250 req->io_task_work.func(req, &locked); in io_fallback_req_func()
1031 io_task_work.node); in handle_tw_list()
1033 prefetch(container_of(next, struct io_kiocb, io_task_work.node)); in handle_tw_list()
1042 req->io_task_work.func(req, locked); in handle_tw_list()
1112 if (!llist_add(&req->io_task_work.node, &ctx->work_llist)) in io_req_local_work_add()
1142 if (!llist_add(&req->io_task_work.node, &tctx->task_list)) in __io_req_task_work_add()
1154 req = container_of(node, struct io_kiocb, io_task_work.node); in __io_req_task_work_add()
1156 if (llist_add(&req->io_task_work.node, in __io_req_task_work_add()
1174 io_task_work.node); in io_move_task_work_from_local()
1198 io_task_work.node); in __io_run_local_work()
1199 prefetch(container_of(next, struct io_kiocb, io_task_work.node)); in __io_run_local_work()
1200 req->io_task_work.func(req, locked); in __io_run_local_work()
1248 req->io_task_work.func = io_req_tw_post; in io_req_tw_post_queue()
1272 req->io_task_work.func = io_req_task_cancel; in io_req_task_queue_fail()
1278 req->io_task_work.func = io_req_task_submit; in io_req_task_queue()