Lines Matching defs:worker
151 static bool io_worker_get(struct io_worker *worker) in io_worker_get()
156 static void io_worker_release(struct io_worker *worker) in io_worker_release()
173 static inline struct io_wqe_acct *io_wqe_get_acct(struct io_worker *worker) in io_wqe_get_acct()
184 static void io_worker_cancel_cb(struct io_worker *worker) in io_worker_cancel_cb()
201 struct io_worker *worker; in io_task_worker_match() local
209 static void io_worker_exit(struct io_worker *worker) in io_worker_exit()
264 struct io_worker *worker; in io_wqe_activate_free_worker() local
313 static void io_wqe_inc_running(struct io_worker *worker) in io_wqe_inc_running()
322 struct io_worker *worker; in create_worker_cb() local
348 static bool io_queue_worker_create(struct io_worker *worker, in io_queue_worker_create()
395 static void io_wqe_dec_running(struct io_worker *worker) in io_wqe_dec_running()
417 static void __io_worker_busy(struct io_wqe *wqe, struct io_worker *worker) in __io_worker_busy()
434 static void __io_worker_idle(struct io_wqe *wqe, struct io_worker *worker) in __io_worker_idle()
467 struct io_worker *worker) in io_get_next_work()
523 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()
615 struct io_worker *worker = data; in io_wqe_worker() local
670 struct io_worker *worker = tsk->worker_private; in io_wq_worker_running() local
688 struct io_worker *worker = tsk->worker_private; in io_wq_worker_sleeping() local
701 static void io_init_new_worker(struct io_wqe *wqe, struct io_worker *worker, in io_init_new_worker()
744 struct io_worker *worker; in create_worker_cont() local
786 struct io_worker *worker = container_of(work, struct io_worker, work); in io_workqueue_create() local
796 struct io_worker *worker; in create_io_worker() local
842 struct io_worker *worker; in io_wq_for_each_worker() local
859 static bool io_wq_worker_wake(struct io_worker *worker, void *data) in io_wq_worker_wake()
975 static bool __io_wq_worker_cancel(struct io_worker *worker, in __io_wq_worker_cancel()
988 static bool io_wq_worker_cancel(struct io_worker *worker, void *data) in io_wq_worker_cancel()
1211 struct io_worker *worker; in io_task_work_match() local
1229 struct io_worker *worker; in io_wq_cancel_tw_create() local
1297 static bool io_wq_worker_affinity(struct io_worker *worker, void *data) in io_wq_worker_affinity()