Searched refs:io_task_work (Results 1 - 9 of 9) sorted by relevance
| /kernel/linux/linux-6.6/io_uring/ |
| H A D | notif.c | 61 notif->io_task_work.func = io_notif_complete_tw_ext; in io_notif_set_extended()
79 notif->io_task_work.func = io_req_task_complete;
|
| H A D | timeout.c | 179 link->io_task_work.func = io_req_tw_fail_links;
255 req->io_task_work.func = io_timeout_complete; in io_timeout_fn()
353 req->io_task_work.func = io_req_task_link_timeout; in io_link_timeout_fn()
|
| H A D | io_uring.c | 260 llist_for_each_entry_safe(req, tmp, node, io_task_work.node) in io_fallback_req_func()
261 req->io_task_work.func(req, &ts); in io_fallback_req_func()
1020 req->io_task_work.func = io_req_task_complete; in io_req_complete_post()
1124 req->io_task_work.func = io_req_task_complete; in io_free_req()
1177 io_task_work.node); in handle_tw_list()
1179 prefetch(container_of(next, struct io_kiocb, io_task_work.node)); in handle_tw_list()
1188 INDIRECT_CALL_2(req->io_task_work.func, in handle_tw_list()
1224 req = container_of(node, struct io_kiocb, io_task_work.node); in io_fallback_tw()
1234 if (llist_add(&req->io_task_work.node, in io_fallback_tw()
1287 io_task_work in io_req_local_work_add()
[all...] |
| H A D | uring_cmd.c | 31 req->io_task_work.func = io_uring_cmd_work; in __io_uring_cmd_do_in_task()
|
| H A D | io_uring.h | 389 req->io_task_work.func = io_req_task_complete; in io_req_queue_tw_complete()
|
| H A D | poll.c | 235 req->io_task_work.func = io_poll_task_func; in __io_poll_execute()
1032 preq->io_task_work.func = io_req_task_complete; in io_poll_remove()
|
| H A D | rw.c | 173 req->io_task_work.func = io_queue_iowq; in io_req_task_queue_reissue()
313 req->io_task_work.func = io_req_rw_complete; in io_complete_rw()
|
| /kernel/linux/linux-6.6/include/linux/ |
| H A D | io_uring_types.h | 494 struct io_task_work { struct
581 struct io_task_work io_task_work; member
|
| /kernel/linux/linux-5.10/io_uring/ |
| H A D | io_uring.c | 812 struct io_task_work { struct
883 struct io_task_work io_task_work; member
1292 llist_for_each_entry_safe(req, tmp, node, io_task_work.fallback_node) in io_fallback_req_func()
1293 req->io_task_work.func(req, &locked); in io_fallback_req_func()
2206 io_task_work.node); in tctx_task_work()
2215 req->io_task_work.func(req, &locked); in tctx_task_work()
2244 wq_list_add_tail(&req->io_task_work.node, &tctx->task_list); in io_req_task_work_add()
2273 req = container_of(node, struct io_kiocb, io_task_work.node); in io_req_task_work_add()
2275 if (llist_add(&req->io_task_work in io_req_task_work_add()
[all...] |
Completed in 23 milliseconds