Lines Matching defs:io_wq
101 struct io_wq *wq;
108 * Per io_wq state
110 struct io_wq {
138 static bool create_io_worker(struct io_wq *wq, struct io_wqe *wqe, int index);
144 static void io_wq_cancel_tw_create(struct io_wq *wq);
173 static void io_worker_ref_put(struct io_wq *wq)
193 struct io_wq *wq = wqe->wq;
217 struct io_wq *wq = wqe->wq;
296 * Most likely an attempt to queue unbounded work on an io_wq that
324 struct io_wq *wq;
354 struct io_wq *wq = wqe->wq;
451 struct io_wq *wq = wqe->wq;
554 struct io_wq *wq = wqe->wq;
624 struct io_wq *wq = wqe->wq;
804 static bool create_io_worker(struct io_wq *wq, struct io_wqe *wqe, int index)
879 struct io_wq *wq = wqe->wq;
964 void io_wq_enqueue(struct io_wq *wq, struct io_wq_work *work)
1070 enum io_wq_cancel io_wq_cancel_cb(struct io_wq *wq, work_cancel_fn *cancel,
1133 struct io_wq *io_wq_create(unsigned bounded, struct io_wq_data *data)
1136 struct io_wq *wq;
1216 void io_wq_exit_start(struct io_wq *wq)
1221 static void io_wq_cancel_tw_create(struct io_wq *wq)
1239 static void io_wq_exit_workers(struct io_wq *wq)
1267 static void io_wq_destroy(struct io_wq *wq)
1287 void io_wq_put_and_exit(struct io_wq *wq)
1311 static int __io_wq_cpu_online(struct io_wq *wq, unsigned int cpu, bool online)
1328 struct io_wq *wq = hlist_entry_safe(node, struct io_wq, cpuhp_node);
1335 struct io_wq *wq = hlist_entry_safe(node, struct io_wq, cpuhp_node);
1340 int io_wq_cpu_affinity(struct io_wq *wq, cpumask_var_t mask)
1361 int io_wq_max_workers(struct io_wq *wq, int *new_count)