Lines Matching defs:worker
147 static bool io_worker_get(struct io_worker *worker) in io_worker_get()
152 static void io_worker_release(struct io_worker *worker) in io_worker_release()
169 static inline struct io_wqe_acct *io_wqe_get_acct(struct io_worker *worker) in io_wqe_get_acct()
180 static void io_worker_cancel_cb(struct io_worker *worker) in io_worker_cancel_cb()
197 struct io_worker *worker; in io_task_worker_match() local
205 static void io_worker_exit(struct io_worker *worker) in io_worker_exit()
255 struct io_worker *worker; in io_wqe_activate_free_worker() local
304 static void io_wqe_inc_running(struct io_worker *worker) in io_wqe_inc_running()
313 struct io_worker *worker; in create_worker_cb() local
339 static bool io_queue_worker_create(struct io_worker *worker, in io_queue_worker_create()
386 static void io_wqe_dec_running(struct io_worker *worker) in io_wqe_dec_running()
408 static void __io_worker_busy(struct io_wqe *wqe, struct io_worker *worker, in __io_worker_busy()
425 static void __io_worker_idle(struct io_wqe *wqe, struct io_worker *worker) in __io_worker_idle()
458 struct io_worker *worker) in io_get_next_work()
524 static void io_assign_current_work(struct io_worker *worker, in io_assign_current_work()
539 static void io_worker_handle_work(struct io_worker *worker) in io_worker_handle_work()
611 struct io_worker *worker = data; in io_wqe_worker() local
673 struct io_worker *worker = tsk->pf_io_worker; in io_wq_worker_running() local
691 struct io_worker *worker = tsk->pf_io_worker; in io_wq_worker_sleeping() local
707 static void io_init_new_worker(struct io_wqe *wqe, struct io_worker *worker, in io_init_new_worker()
750 struct io_worker *worker; in create_worker_cont() local
790 struct io_worker *worker = container_of(work, struct io_worker, work); in io_workqueue_create() local
800 struct io_worker *worker; in create_io_worker() local
846 struct io_worker *worker; in io_wq_for_each_worker() local
863 static bool io_wq_worker_wake(struct io_worker *worker, void *data) in io_wq_worker_wake()
976 static bool io_wq_worker_cancel(struct io_worker *worker, void *data) in io_wq_worker_cancel()
1201 struct io_worker *worker; in io_task_work_match() local
1219 struct io_worker *worker; in io_wq_cancel_tw_create() local
1287 static bool io_wq_worker_affinity(struct io_worker *worker, void *data) in io_wq_worker_affinity()