Lines Matching refs:tsk
678 void io_wq_worker_running(struct task_struct *tsk) in io_wq_worker_running() argument
680 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() argument
698 struct io_worker *worker = tsk->pf_io_worker; in io_wq_worker_sleeping()
715 struct task_struct *tsk) in io_init_new_worker() argument
717 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()
758 struct task_struct *tsk; in create_worker_cont() local
764 tsk = create_io_thread(io_wqe_worker, worker, wqe->node); in create_worker_cont()
765 if (!IS_ERR(tsk)) { in create_worker_cont()
766 io_init_new_worker(wqe, worker, tsk); in create_worker_cont()
769 } else if (!io_should_retry_thread(PTR_ERR(tsk))) { in create_worker_cont()
808 struct task_struct *tsk; in create_io_worker() local
831 tsk = create_io_thread(io_wqe_worker, worker, wqe->node); in create_io_worker()
832 if (!IS_ERR(tsk)) { in create_io_worker()
833 io_init_new_worker(wqe, worker, tsk); in create_io_worker()
834 } else if (!io_should_retry_thread(PTR_ERR(tsk))) { in create_io_worker()