45 struct io_worker {  struct
137 static void io_wq_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_wq_acct *io_wq_get_acct(struct io_worker *worker)  in io_wq_get_acct()
179 	struct io_worker *worker = current->worker_private;  in io_wq_worker_stopped()
187 static void io_worker_cancel_cb(struct io_worker *worker)  in io_worker_cancel_cb()
203 	struct io_worker *worker;  in io_task_worker_match()
207 	worker = container_of(cb, struct io_worker, create_work);  in io_task_worker_match()
211 static void io_worker_exit(struct io_worker *worker)  in io_worker_exit()
275 	struct io_worker *worker;  in io_wq_activate_free_worker()
327 static void io_wq_inc_running(struct io_worker *worker)  in io_wq_inc_running()
336 	struct io_worker *worker;  in create_worker_cb()
342 	worker = container_of(cb, struct io_worker, create_work);  in create_worker_cb()
362 static bool io_queue_worker_create(struct io_worker *worker,  in io_queue_worker_create()
408 static void io_wq_dec_running(struct io_worker *worker)  in io_wq_dec_running()
431 static void __io_worker_busy(struct io_wq *wq, struct io_worker *worker)  in __io_worker_busy()
444 static void __io_worker_idle(struct io_wq *wq, struct io_worker *worker)  in __io_worker_idle()
476 					   struct io_worker *worker)  in io_get_next_work()
532 static void io_assign_current_work(struct io_worker *worker,  in io_assign_current_work()
550 				  struct io_worker *worker)  in io_worker_handle_work()
628 	struct io_worker *worker = data;  in io_wq_worker()
694 	struct io_worker *worker = tsk->worker_private;  in io_wq_worker_running()
712 	struct io_worker *worker = tsk->worker_private;  in io_wq_worker_sleeping()
725 static void io_init_new_worker(struct io_wq *wq, struct io_worker *worker,  in io_init_new_worker()
767 	struct io_worker *worker;  in create_worker_cont()
771 	worker = container_of(cb, struct io_worker, create_work);  in create_worker_cont()
809 	struct io_worker *worker = container_of(work, struct io_worker, work);  in io_workqueue_create()
819 	struct io_worker *worker;  in create_io_worker()
862 				  bool (*func)(struct io_worker *, void *),  in io_wq_for_each_worker()  argument
865 	struct io_worker *worker;  in io_wq_for_each_worker()
882 static bool io_wq_worker_wake(struct io_worker *worker, void *data)  in io_wq_worker_wake()
986 static bool __io_wq_worker_cancel(struct io_worker *worker,  in __io_wq_worker_cancel()
999 static bool io_wq_worker_cancel(struct io_worker *worker, void *data)  in io_wq_worker_cancel()
1200 	struct io_worker *worker;  in io_task_work_match()
1204 	worker = container_of(cb, struct io_worker, create_work);  in io_task_work_match()
1218 		struct io_worker *worker;  in io_wq_cancel_tw_create()
1220 		worker = container_of(cb, struct io_worker, create_work);  in io_wq_cancel_tw_create()
1279 static bool io_wq_worker_affinity(struct io_worker *worker, void *data)  in io_wq_worker_affinity()