Lines Matching defs:wqe

56 	struct io_wqe *wqe;  member
151 static bool __io_worker_unuse(struct io_wqe *wqe, struct io_worker *worker) in __io_worker_unuse()
201 static inline struct io_wqe_acct *io_work_get_acct(struct io_wqe *wqe, in io_work_get_acct()
210 static inline struct io_wqe_acct *io_wqe_get_acct(struct io_wqe *wqe, in io_wqe_get_acct()
221 struct io_wqe *wqe = worker->wqe; in io_worker_exit() local
257 static inline bool io_wqe_run_queue(struct io_wqe *wqe) in io_wqe_run_queue()
270 static bool io_wqe_activate_free_worker(struct io_wqe *wqe) in io_wqe_activate_free_worker()
294 static void io_wqe_wake_worker(struct io_wqe *wqe, struct io_wqe_acct *acct) in io_wqe_wake_worker()
312 static void io_wqe_inc_running(struct io_wqe *wqe, struct io_worker *worker) in io_wqe_inc_running()
319 static void io_wqe_dec_running(struct io_wqe *wqe, struct io_worker *worker) in io_wqe_dec_running()
328 static void io_worker_start(struct io_wqe *wqe, struct io_worker *worker) in io_worker_start()
345 static void __io_worker_busy(struct io_wqe *wqe, struct io_worker *worker, in __io_worker_busy()
386 static bool __io_worker_idle(struct io_wqe *wqe, struct io_worker *worker) in __io_worker_idle()
402 static struct io_wq_work *io_get_next_work(struct io_wqe *wqe) in io_get_next_work()
533 struct io_wqe *wqe = worker->wqe; in io_worker_handle_work() local
603 struct io_wqe *wqe = worker->wqe; in io_wqe_worker() local
651 struct io_wqe *wqe = worker->wqe; in io_wq_worker_running() local
669 struct io_wqe *wqe = worker->wqe; in io_wq_worker_sleeping() local
683 static bool create_io_worker(struct io_wq *wq, struct io_wqe *wqe, int index) in create_io_worker()
724 static inline bool io_wqe_need_worker(struct io_wqe *wqe, int index) in io_wqe_need_worker()
745 static bool io_wq_for_each_worker(struct io_wqe *wqe, in io_wq_for_each_worker()
799 struct io_wqe *wqe = wq->wqes[node]; in io_wq_manager() local
838 static bool io_wq_can_queue(struct io_wqe *wqe, struct io_wqe_acct *acct, in io_wq_can_queue()
861 static void io_run_cancel(struct io_wq_work *work, struct io_wqe *wqe) in io_run_cancel()
874 static void io_wqe_insert_work(struct io_wqe *wqe, struct io_wq_work *work) in io_wqe_insert_work()
894 static void io_wqe_enqueue(struct io_wqe *wqe, struct io_wq_work *work) in io_wqe_enqueue()
924 struct io_wqe *wqe = wq->wqes[numa_node_id()]; in io_wq_enqueue() local
949 struct io_wqe *wqe = wq->wqes[node]; in io_wq_cancel_all() local
985 static inline void io_wqe_remove_pending(struct io_wqe *wqe, in io_wqe_remove_pending()
1003 static void io_wqe_cancel_pending_work(struct io_wqe *wqe, in io_wqe_cancel_pending_work()
1029 static void io_wqe_cancel_running_work(struct io_wqe *wqe, in io_wqe_cancel_running_work()
1053 struct io_wqe *wqe = wq->wqes[node]; in io_wq_cancel_cb() local
1067 struct io_wqe *wqe = wq->wqes[node]; in io_wq_cancel_cb() local
1119 struct io_wqe *wqe; in io_wq_create() local