Lines Matching refs:io_wq

101 	struct io_wq *wq;
110 struct io_wq { struct
138 static bool create_io_worker(struct io_wq *wq, struct io_wqe *wqe, int index); argument
144 static void io_wq_cancel_tw_create(struct io_wq *wq);
173 static void io_worker_ref_put(struct io_wq *wq) in io_worker_ref_put()
183 struct io_wq *wq = wqe->wq; in io_worker_cancel_cb()
207 struct io_wq *wq = wqe->wq; in io_worker_exit()
314 struct io_wq *wq; in create_worker_cb()
344 struct io_wq *wq = wqe->wq; in io_queue_worker_create()
441 struct io_wq *wq = wqe->wq; in io_wait_on_hash()
544 struct io_wq *wq = wqe->wq; in io_worker_handle_work()
614 struct io_wq *wq = wqe->wq; in io_wqe_worker()
794 static bool create_io_worker(struct io_wq *wq, struct io_wqe *wqe, int index) in create_io_worker()
869 struct io_wq *wq = wqe->wq; in io_run_cancel()
954 void io_wq_enqueue(struct io_wq *wq, struct io_wq_work *work) in io_wq_enqueue()
1060 enum io_wq_cancel io_wq_cancel_cb(struct io_wq *wq, work_cancel_fn *cancel, in io_wq_cancel_cb()
1123 struct io_wq *io_wq_create(unsigned bounded, struct io_wq_data *data) in io_wq_create()
1126 struct io_wq *wq; in io_wq_create()
1206 void io_wq_exit_start(struct io_wq *wq) in io_wq_exit_start()
1211 static void io_wq_cancel_tw_create(struct io_wq *wq) in io_wq_cancel_tw_create()
1223 static void io_wq_exit_workers(struct io_wq *wq) in io_wq_exit_workers()
1251 static void io_wq_destroy(struct io_wq *wq) in io_wq_destroy()
1271 void io_wq_put_and_exit(struct io_wq *wq) in io_wq_put_and_exit()
1295 static int __io_wq_cpu_online(struct io_wq *wq, unsigned int cpu, bool online) in __io_wq_cpu_online()
1312 struct io_wq *wq = hlist_entry_safe(node, struct io_wq, cpuhp_node); in io_wq_cpu_online()
1319 struct io_wq *wq = hlist_entry_safe(node, struct io_wq, cpuhp_node); in io_wq_cpu_offline()
1324 int io_wq_cpu_affinity(struct io_wq *wq, cpumask_var_t mask) in io_wq_cpu_affinity()
1345 int io_wq_max_workers(struct io_wq *wq, int *new_count) in io_wq_max_workers()