Lines Matching refs:io_worker

41 struct io_worker {  struct
139 static void io_wqe_dec_running(struct io_worker *worker);
144 static bool io_worker_get(struct io_worker *worker) in io_worker_get()
149 static void io_worker_release(struct io_worker *worker) in io_worker_release()
166 static inline struct io_wqe_acct *io_wqe_get_acct(struct io_worker *worker) in io_wqe_get_acct()
177 static void io_worker_exit(struct io_worker *worker) in io_worker_exit()
218 struct io_worker *worker; in io_wqe_activate_free_worker()
267 static void io_wqe_inc_running(struct io_worker *worker) in io_wqe_inc_running()
276 struct io_worker *worker; in create_worker_cb()
282 worker = container_of(cb, struct io_worker, create_work); in create_worker_cb()
302 static bool io_queue_worker_create(struct io_worker *worker, in io_queue_worker_create()
337 static void io_wqe_dec_running(struct io_worker *worker) in io_wqe_dec_running()
357 static void __io_worker_busy(struct io_wqe *wqe, struct io_worker *worker, in __io_worker_busy()
374 static void __io_worker_idle(struct io_wqe *wqe, struct io_worker *worker) in __io_worker_idle()
404 struct io_worker *worker) in io_get_next_work()
463 static void io_assign_current_work(struct io_worker *worker, in io_assign_current_work()
478 static void io_worker_handle_work(struct io_worker *worker) in io_worker_handle_work()
547 struct io_worker *worker = data; in io_wqe_worker()
606 struct io_worker *worker = tsk->pf_io_worker; in io_wq_worker_running()
624 struct io_worker *worker = tsk->pf_io_worker; in io_wq_worker_sleeping()
640 static void io_init_new_worker(struct io_wqe *wqe, struct io_worker *worker, in io_init_new_worker()
676 struct io_worker *worker; in create_worker_cont()
680 worker = container_of(cb, struct io_worker, create_work); in create_worker_cont()
716 struct io_worker *worker = container_of(work, struct io_worker, work); in io_workqueue_create()
729 struct io_worker *worker; in create_io_worker()
772 bool (*func)(struct io_worker *, void *), in io_wq_for_each_worker() argument
775 struct io_worker *worker; in io_wq_for_each_worker()
792 static bool io_wq_worker_wake(struct io_worker *worker, void *data) in io_wq_worker_wake()
905 static bool io_wq_worker_cancel(struct io_worker *worker, void *data) in io_wq_worker_cancel()
1130 struct io_worker *worker; in io_task_work_match()
1134 worker = container_of(cb, struct io_worker, create_work); in io_task_work_match()
1152 struct io_worker *worker; in io_wq_exit_workers()
1155 worker = container_of(cb, struct io_worker, create_work); in io_wq_exit_workers()
1218 static bool io_wq_worker_affinity(struct io_worker *worker, void *data) in io_wq_worker_affinity()