Searched refs:tsk (Results 1 – 3 of 3) sorted by relevance
678 void io_wq_worker_running(struct task_struct *tsk) in io_wq_worker_running() argument680 struct io_worker *worker = tsk->pf_io_worker; in io_wq_worker_running()696 void io_wq_worker_sleeping(struct task_struct *tsk) in io_wq_worker_sleeping() argument698 struct io_worker *worker = tsk->pf_io_worker; in io_wq_worker_sleeping()715 struct task_struct *tsk) in io_init_new_worker() argument717 tsk->pf_io_worker = worker; in io_init_new_worker()718 worker->task = tsk; in io_init_new_worker()719 set_cpus_allowed_ptr(tsk, wqe->cpu_mask); in io_init_new_worker()720 tsk->flags |= PF_NO_SETAFFINITY; in io_init_new_worker()727 wake_up_new_task(tsk); in io_init_new_worker()[all …]
2244 struct task_struct *tsk = req->task; in io_req_task_work_add() local2245 struct io_uring_task *tctx = tsk->io_uring; in io_req_task_work_add()2271 if (!task_work_add(tsk, &tctx->task_work, notify)) { in io_req_task_work_add()2272 wake_up_process(tsk); in io_req_task_work_add()5868 static bool io_poll_remove_all(struct io_ring_ctx *ctx, struct task_struct *tsk, in io_poll_remove_all() argument5882 if (io_match_task_safe(req, tsk, cancel_all)) { in io_poll_remove_all()8713 void __io_uring_free(struct task_struct *tsk) in __io_uring_free() argument8715 struct io_uring_task *tctx = tsk->io_uring; in __io_uring_free()8723 tsk->io_uring = NULL; in __io_uring_free()8746 struct task_struct *tsk; in io_sq_offload_create() local[all …]
159 static inline void io_wq_worker_sleeping(struct task_struct *tsk) in io_wq_worker_sleeping() argument162 static inline void io_wq_worker_running(struct task_struct *tsk) in io_wq_worker_running() argument