Searched refs:task (Results 1 – 3 of 3) sorted by relevance
| /io_uring/ |
| D | io-wq.c | 46 struct task_struct *task; member
123 struct task_struct *task; member
220 struct callback_head *cb = task_work_cancel_match(wq->task, in io_worker_exit()
279 if (wake_up_process(worker->task)) { in io_wqe_activate_free_worker()
374 if (!task_work_add(wq->task, &worker->create_work, TWA_SIGNAL)) { in io_queue_worker_create()
630 snprintf(buf, sizeof(buf), "iou-wrk-%d", wq->task->pid); in io_wqe_worker()
718 worker->task = tsk; in io_init_new_worker()
859 if (worker->task) in io_wq_for_each_worker()
872 set_notify_signal(worker->task); in io_wq_worker_wake()
873 wake_up_process(worker->task); in io_wq_worker_wake()
[all …]
|
| D | io_uring.c | 875 struct task_struct *task; member
899 struct task_struct *task; member
1085 struct task_struct *task,
1207 static bool io_match_task(struct io_kiocb *head, struct task_struct *task, in io_match_task() argument
1213 if (task && head->task != task) in io_match_task()
1240 static bool io_match_task_safe(struct io_kiocb *head, struct task_struct *task, in io_match_task_safe() argument
1245 if (task && head->task != task) in io_match_task_safe()
1410 atomic_inc(&req->task->io_uring->inflight_tracked); in io_req_track_inflight()
1480 struct io_uring_task *tctx = req->task->io_uring; in io_queue_async_work()
1498 if (WARN_ON_ONCE(!same_thread_group(req->task, current))) in io_queue_async_work()
[all …]
|
| D | io-wq.h | 118 struct task_struct *task; member
|