Lines Matching refs:io_wqe
47 struct io_wqe *wqe;
90 struct io_wqe {
125 struct io_wqe *wqes[];
138 static bool create_io_worker(struct io_wq *wq, struct io_wqe *wqe, int index);
140 static bool io_acct_cancel_pending_work(struct io_wqe *wqe,
157 static inline struct io_wqe_acct *io_get_acct(struct io_wqe *wqe, bool bound)
162 static inline struct io_wqe_acct *io_work_get_acct(struct io_wqe *wqe,
192 struct io_wqe *wqe = worker->wqe;
216 struct io_wqe *wqe = worker->wqe;
260 static bool io_wqe_activate_free_worker(struct io_wqe *wqe,
293 static bool io_wqe_create_worker(struct io_wqe *wqe, struct io_wqe_acct *acct)
325 struct io_wqe *wqe;
353 struct io_wqe *wqe = worker->wqe;
400 struct io_wqe *wqe = worker->wqe;
418 static void __io_worker_busy(struct io_wqe *wqe, struct io_worker *worker,
435 static void __io_worker_idle(struct io_wqe *wqe, struct io_worker *worker)
449 static bool io_wait_on_hash(struct io_wqe *wqe, unsigned int hash)
474 struct io_wqe *wqe = worker->wqe;
547 static void io_wqe_enqueue(struct io_wqe *wqe, struct io_wq_work *work);
553 struct io_wqe *wqe = worker->wqe;
623 struct io_wqe *wqe = worker->wqe;
714 static void io_init_new_worker(struct io_wqe *wqe, struct io_worker *worker,
759 struct io_wqe *wqe;
804 static bool create_io_worker(struct io_wq *wq, struct io_wqe *wqe, int index)
849 static bool io_wq_for_each_worker(struct io_wqe *wqe,
877 static void io_run_cancel(struct io_wq_work *work, struct io_wqe *wqe)
888 static void io_wqe_insert_work(struct io_wqe *wqe, struct io_wq_work *work)
914 static void io_wqe_enqueue(struct io_wqe *wqe, struct io_wq_work *work)
966 struct io_wqe *wqe = wq->wqes[numa_node_id()];
1002 static inline void io_wqe_remove_pending(struct io_wqe *wqe,
1021 static bool io_acct_cancel_pending_work(struct io_wqe *wqe,
1044 static void io_wqe_cancel_pending_work(struct io_wqe *wqe,
1062 static void io_wqe_cancel_running_work(struct io_wqe *wqe,
1086 struct io_wqe *wqe = wq->wqes[node];
1100 struct io_wqe *wqe = wq->wqes[node];
1117 struct io_wqe *wqe = container_of(wait, struct io_wqe, wait);
1157 struct io_wqe *wqe;
1162 wqe = kzalloc_node(sizeof(struct io_wqe), GFP_KERNEL, alloc_node);
1250 struct io_wqe *wqe = wq->wqes[node];
1274 struct io_wqe *wqe = wq->wqes[node];
1346 struct io_wqe *wqe = wq->wqes[i];
1381 struct io_wqe *wqe = wq->wqes[node];