Lines Matching refs:io_worker
44 struct io_worker { struct
144 static void io_wqe_dec_running(struct io_worker *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()
205 worker = container_of(cb, struct io_worker, create_work); in io_task_worker_match()
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()
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()
328 worker = container_of(cb, struct io_worker, create_work); in create_worker_cb()
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()
670 struct io_worker *worker = tsk->worker_private; in io_wq_worker_running()
688 struct io_worker *worker = tsk->worker_private; in io_wq_worker_sleeping()
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()
748 worker = container_of(cb, struct io_worker, create_work); in create_worker_cont()
786 struct io_worker *worker = container_of(work, struct io_worker, work); in io_workqueue_create()
796 struct io_worker *worker; in create_io_worker()
839 bool (*func)(struct io_worker *, void *), in io_wq_for_each_worker() argument
842 struct io_worker *worker; in io_wq_for_each_worker()
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()
1215 worker = container_of(cb, struct io_worker, create_work); in io_task_work_match()
1229 struct io_worker *worker; in io_wq_cancel_tw_create()
1231 worker = container_of(cb, struct io_worker, create_work); in io_wq_cancel_tw_create()
1297 static bool io_wq_worker_affinity(struct io_worker *worker, void *data) in io_wq_worker_affinity()