| /linux/io_uring/ |
| H A D | tctx.c | 48 struct io_uring_task *tctx = tsk->io_uring; in io_uring_free_tctx() 82 __cold struct io_uring_task *io_uring_alloc_task_context(struct task_struct *task, in io_uring_alloc_task_context() 85 struct io_uring_task *tctx; in io_uring_alloc_task_context() 118 struct io_uring_task *tctx) in io_tctx_install_node() 147 struct io_uring_task *tctx = current->io_uring; in __io_uring_add_tctx_node() 219 struct io_uring_task *tctx = current->io_uring; in io_uring_del_tctx_node() 243 __cold void io_uring_clean_tctx(struct io_uring_task *tctx) in io_uring_clean_tctx() 265 struct io_uring_task *tctx = current->io_uring; in io_uring_unreg_ringfd() 276 int io_ring_add_registered_file(struct io_uring_task *tctx, struct file *file, in io_ring_add_registered_file() 291 static int io_ring_add_registered_fd(struct io_uring_task *tctx, int fd, in io_ring_add_registered_fd() [all …]
|
| H A D | tctx.h | 9 struct io_uring_task *io_uring_alloc_task_context(struct task_struct *task, 14 void io_uring_clean_tctx(struct io_uring_task *tctx); 28 struct io_uring_task *tctx = current->io_uring; in io_uring_add_tctx_node()
|
| H A D | tw.c | 33 struct io_uring_task *tctx = container_of(work, struct io_uring_task, in io_tctx_fallback_work() 46 static void io_fallback_tw(struct io_uring_task *tctx) in io_fallback_tw() 63 void tctx_task_work_run(struct io_uring_task *tctx, unsigned int max_entries, in tctx_task_work_run() 129 struct io_uring_task *tctx; in tctx_task_work() 132 tctx = container_of(cb, struct io_uring_task, task_work); in tctx_task_work() 210 struct io_uring_task *tctx = req->tctx; in io_req_normal_work_add()
|
| H A D | cancel.c | 78 static int io_async_cancel_one(struct io_uring_task *tctx, in io_async_cancel_one() 105 int io_try_cancel(struct io_uring_task *tctx, struct io_cancel_data *cd, in io_try_cancel() 175 struct io_uring_task *tctx, in __io_async_cancel() 220 struct io_uring_task *tctx = req->tctx; in io_async_cancel() 247 static int __io_sync_cancel(struct io_uring_task *tctx, in __io_sync_cancel() 357 bool io_cancel_remove_all(struct io_ring_ctx *ctx, struct io_uring_task *tctx, in io_cancel_remove_all() 414 bool io_match_task_safe(struct io_kiocb *head, struct io_uring_task *tctx, in io_match_task_safe() 444 struct io_uring_task *tctx; 457 struct io_uring_task *tctx, in io_cancel_defer_files() 498 struct io_uring_task *tctx = node->task->io_uring; in io_uring_try_cancel_iowq() [all …]
|
| H A D | futex.h | 15 bool io_futex_remove_all(struct io_ring_ctx *ctx, struct io_uring_task *tctx, 27 struct io_uring_task *tctx, bool cancel_all) in io_futex_remove_all()
|
| H A D | uring_cmd.h | 17 struct io_uring_task *tctx, bool cancel_all);
|
| H A D | io_uring.h | 197 int io_ring_add_registered_file(struct io_uring_task *tctx, struct file *file, 212 void io_task_refs_refill(struct io_uring_task *tctx); 511 struct io_uring_task *tctx = current->io_uring; in io_get_task_refs()
|
| H A D | sqpoll.c | 269 struct io_uring_task *tctx = current->io_uring; in io_sq_tw() 280 struct io_uring_task *tctx = current->io_uring; in io_sq_tw_pending() 456 struct io_uring_task *tctx; in io_sq_offload_create()
|
| H A D | futex.c | 121 bool io_futex_remove_all(struct io_ring_ctx *ctx, struct io_uring_task *tctx, in io_futex_remove_all()
|
| H A D | timeout.c | 714 static bool io_match_task(struct io_kiocb *head, struct io_uring_task *tctx, in io_match_task() 733 __cold bool io_kill_timeouts(struct io_ring_ctx *ctx, struct io_uring_task *tctx, in io_kill_timeouts()
|
| H A D | io_uring.c | 412 struct io_uring_task *tctx = req->tctx; in io_queue_iowq() 593 struct io_uring_task *tctx = req->tctx; in io_put_task() 605 void io_task_refs_refill(struct io_uring_task *tctx) in io_task_refs_refill() 616 struct io_uring_task *tctx = task->io_uring; in io_uring_drop_tctx_refs() 2294 struct io_uring_task *tctx = current->io_uring; in io_tctx_exit_cb() 2566 struct io_uring_task *tctx = current->io_uring; in io_uring_ctx_get_file() 2968 struct io_uring_task *tctx; in io_uring_create()
|
| H A D | waitid.c | 173 bool io_waitid_remove_all(struct io_ring_ctx *ctx, struct io_uring_task *tctx, in io_waitid_remove_all()
|
| H A D | uring_cmd.c | 52 struct io_uring_task *tctx, bool cancel_all) in io_uring_try_cancel_uring_cmd()
|
| H A D | poll.c | 734 __cold bool io_poll_remove_all(struct io_ring_ctx *ctx, struct io_uring_task *tctx, in io_poll_remove_all()
|
| H A D | register.c | 357 struct io_uring_task *tctx = NULL; in io_register_iowq_max_workers()
|
| H A D | io-wq.c | 1454 int io_wq_cpu_affinity(struct io_uring_task *tctx, cpumask_var_t mask) in io_wq_cpu_affinity()
|
| /linux/include/linux/ |
| H A D | io_uring_types.h | 137 struct io_uring_task { struct 775 struct io_uring_task *tctx;
|
| H A D | sched.h | 69 struct io_uring_task; 1210 struct io_uring_task *io_uring;
|