Lines Matching defs:wq

54 	struct io_wq *wq;  member
158 static inline struct io_wq_acct *io_get_acct(struct io_wq *wq, bool bound) in io_get_acct()
163 static inline struct io_wq_acct *io_work_get_acct(struct io_wq *wq, in io_work_get_acct()
174 static void io_worker_ref_put(struct io_wq *wq) in io_worker_ref_put()
193 struct io_wq *wq = worker->wq; in io_worker_cancel_cb() local
216 struct io_wq *wq = worker->wq; in io_worker_exit() local
273 static bool io_wq_activate_free_worker(struct io_wq *wq, in io_wq_activate_free_worker()
309 static bool io_wq_create_worker(struct io_wq *wq, struct io_wq_acct *acct) in io_wq_create_worker()
340 struct io_wq *wq; in create_worker_cb() local
369 struct io_wq *wq = worker->wq; in io_queue_worker_create() local
414 struct io_wq *wq = worker->wq; in io_wq_dec_running() local
434 static void __io_worker_busy(struct io_wq *wq, struct io_worker *worker) in __io_worker_busy()
447 static void __io_worker_idle(struct io_wq *wq, struct io_worker *worker) in __io_worker_idle()
461 static bool io_wait_on_hash(struct io_wq *wq, unsigned int hash) in io_wait_on_hash()
485 struct io_wq *wq = worker->wq; in io_get_next_work() local
556 struct io_wq *wq = worker->wq; in io_worker_handle_work() local
636 struct io_wq *wq = worker->wq; in io_wq_worker() local
732 static void io_init_new_worker(struct io_wq *wq, struct io_worker *worker, in io_init_new_worker()
778 struct io_wq *wq; in create_worker_cont() local
825 static bool create_io_worker(struct io_wq *wq, int index) in create_io_worker()
870 static bool io_wq_for_each_worker(struct io_wq *wq, in io_wq_for_each_worker()
898 static void io_run_cancel(struct io_wq_work *work, struct io_wq *wq) in io_run_cancel()
907 static void io_wq_insert_work(struct io_wq *wq, struct io_wq_work *work) in io_wq_insert_work()
933 void io_wq_enqueue(struct io_wq *wq, struct io_wq_work *work) in io_wq_enqueue()
1025 static inline void io_wq_remove_pending(struct io_wq *wq, in io_wq_remove_pending()
1044 static bool io_acct_cancel_pending_work(struct io_wq *wq, in io_acct_cancel_pending_work()
1068 static void io_wq_cancel_pending_work(struct io_wq *wq, in io_wq_cancel_pending_work()
1084 static void io_wq_cancel_running_work(struct io_wq *wq, in io_wq_cancel_running_work()
1092 enum io_wq_cancel io_wq_cancel_cb(struct io_wq *wq, work_cancel_fn *cancel, in io_wq_cancel_cb()
1134 struct io_wq *wq = container_of(wait, struct io_wq, wait); in io_wq_hash_wake() local
1153 struct io_wq *wq; in io_wq_create() local
1217 void io_wq_exit_start(struct io_wq *wq) in io_wq_exit_start()
1222 static void io_wq_cancel_tw_create(struct io_wq *wq) in io_wq_cancel_tw_create()
1240 static void io_wq_exit_workers(struct io_wq *wq) in io_wq_exit_workers()
1261 static void io_wq_destroy(struct io_wq *wq) in io_wq_destroy()
1275 void io_wq_put_and_exit(struct io_wq *wq) in io_wq_put_and_exit()
1299 static int __io_wq_cpu_online(struct io_wq *wq, unsigned int cpu, bool online) in __io_wq_cpu_online()
1314 struct io_wq *wq = hlist_entry_safe(node, struct io_wq, cpuhp_node); in io_wq_cpu_online() local
1321 struct io_wq *wq = hlist_entry_safe(node, struct io_wq, cpuhp_node); in io_wq_cpu_offline() local
1357 int io_wq_max_workers(struct io_wq *wq, int *new_count) in io_wq_max_workers()