Searched refs:task (Results 1 – 11 of 11) sorted by relevance
| /io_uring/ |
| A D | tctx.c | 16 struct task_struct *task) in io_init_wq_offload() argument
37 data.task = task; in io_init_wq_offload()
69 __cold int io_uring_alloc_task_context(struct task_struct *task, in io_uring_alloc_task_context() argument
85 tctx->io_wq = io_init_wq_offload(ctx, task); in io_uring_alloc_task_context()
93 tctx->task = task; in io_uring_alloc_task_context()
98 task->io_uring = tctx; in io_uring_alloc_task_context()
130 node->task = current; in __io_uring_add_tctx_node()
176 WARN_ON_ONCE(current != node->task); in io_uring_del_tctx_node()
|
| A D | io-wq.c | 51 struct task_struct *task; member
124 struct task_struct *task; member
309 wake_up_process(worker->task); in io_acct_activate_free_worker()
784 worker->task = tsk; in io_init_new_worker()
938 if (worker->task) in io_acct_for_each_worker()
964 wake_up_process(worker->task); in io_wq_worker_wake()
1266 wq->task = get_task_struct(data->task); in io_wq_create()
1271 put_task_struct(wq->task); in io_wq_create()
1318 if (!wq->task) in io_wq_exit_workers()
1333 put_task_struct(wq->task); in io_wq_exit_workers()
[all …]
|
| A D | tctx.h | 5 struct task_struct *task; member
9 int io_uring_alloc_task_context(struct task_struct *task,
|
| A D | msg_ring.c | 245 struct task_struct *task = READ_ONCE(ctx->submitter_task); in io_msg_fd_remote() local
247 if (unlikely(!task)) in io_msg_fd_remote()
251 if (task_work_add(task, &msg->tw, TWA_SIGNAL)) in io_msg_fd_remote()
|
| A D | io-wq.h | 38 struct task_struct *task; member
|
| A D | fdinfo.c | 202 task_work_pending(req->tctx->task)); in __io_uring_show_fdinfo()
|
| A D | io_uring.c | 504 if (WARN_ON_ONCE(!same_thread_group(tctx->task, current))) in io_queue_iowq()
670 if (likely(tctx->task == current)) { in io_put_task()
676 put_task_struct(tctx->task); in io_put_task()
689 static __cold void io_uring_drop_tctx_refs(struct task_struct *task) in io_uring_drop_tctx_refs() argument
691 struct io_uring_task *tctx = task->io_uring; in io_uring_drop_tctx_refs()
697 put_task_struct_many(task, refs); in io_uring_drop_tctx_refs()
1274 __set_notify_signal(tctx->task); in io_req_normal_work_add()
1278 if (likely(!task_work_add(tctx->task, &tctx->task_work, ctx->notify_method))) in io_req_normal_work_add()
3010 ret = task_work_add(node->task, &exit.task_work, TWA_SIGNAL); in io_ring_exit_work()
3113 struct io_uring_task *tctx = node->task->io_uring; in io_uring_try_cancel_iowq()
|
| A D | waitid.c | 294 iwa->wo.child_wait.private = req->tctx->task; in io_waitid()
|
| A D | cancel.c | 187 ret = io_async_cancel_one(node->task->io_uring, cd); in __io_async_cancel()
|
| A D | register.c | 326 tctx = node->task->io_uring; in io_register_iowq_max_workers()
|
| A D | rw.c | 1280 if (timer.task) in io_hybrid_iopoll_delay()
|
Completed in 1022 milliseconds