Lines Matching defs:worker

146 static bool io_worker_get(struct io_worker *worker)  in io_worker_get()
151 static void io_worker_release(struct io_worker *worker) in io_worker_release()
168 static inline struct io_wq_acct *io_wq_get_acct(struct io_worker *worker) in io_wq_get_acct()
181 struct io_worker *worker = current->worker_private; in io_wq_worker_stopped() local
189 static void io_worker_cancel_cb(struct io_worker *worker) in io_worker_cancel_cb()
205 struct io_worker *worker; in io_task_worker_match() local
213 static void io_worker_exit(struct io_worker *worker) in io_worker_exit()
277 struct io_worker *worker; in io_wq_activate_free_worker() local
329 static void io_wq_inc_running(struct io_worker *worker) in io_wq_inc_running()
338 struct io_worker *worker; in create_worker_cb() local
364 static bool io_queue_worker_create(struct io_worker *worker, in io_queue_worker_create()
410 static void io_wq_dec_running(struct io_worker *worker) in io_wq_dec_running()
433 static void __io_worker_busy(struct io_wq *wq, struct io_worker *worker) in __io_worker_busy()
446 static void __io_worker_idle(struct io_wq *wq, struct io_worker *worker) in __io_worker_idle()
483 struct io_worker *worker) in io_get_next_work()
541 static void io_assign_current_work(struct io_worker *worker, in io_assign_current_work()
558 struct io_worker *worker) in io_worker_handle_work()
643 struct io_worker *worker = data; in io_wq_worker() local
710 struct io_worker *worker = tsk->worker_private; in io_wq_worker_running() local
728 struct io_worker *worker = tsk->worker_private; in io_wq_worker_sleeping() local
741 static void io_init_new_worker(struct io_wq *wq, struct io_worker *worker, in io_init_new_worker()
761 static inline bool io_should_retry_thread(struct io_worker *worker, long err) in io_should_retry_thread()
783 static void queue_create_worker_retry(struct io_worker *worker) in queue_create_worker_retry()
797 struct io_worker *worker; in create_worker_cont() local
839 struct io_worker *worker = container_of(work, struct io_worker, in io_workqueue_create() local
850 struct io_worker *worker; in create_io_worker() local
896 struct io_worker *worker; in io_wq_for_each_worker() local
913 static bool io_wq_worker_wake(struct io_worker *worker, void *data) in io_wq_worker_wake()
1017 static bool __io_wq_worker_cancel(struct io_worker *worker, in __io_wq_worker_cancel()
1030 static bool io_wq_worker_cancel(struct io_worker *worker, void *data) in io_wq_worker_cancel()
1230 struct io_worker *worker; in io_task_work_match() local
1248 struct io_worker *worker; in io_wq_cancel_tw_create() local
1309 static bool io_wq_worker_affinity(struct io_worker *worker, void *data) in io_wq_worker_affinity()