Searched refs:wqe (Results 1 – 2 of 2) sorted by relevance
50 struct io_wqe *wqe; member143 static bool create_io_worker(struct io_wq *wq, struct io_wqe *wqe, int index);145 static bool io_acct_cancel_pending_work(struct io_wqe *wqe,162 static inline struct io_wqe_acct *io_get_acct(struct io_wqe *wqe, bool bound) in io_get_acct() argument164 return &wqe->acct[bound ? IO_WQ_ACCT_BOUND : IO_WQ_ACCT_UNBOUND]; in io_get_acct()167 static inline struct io_wqe_acct *io_work_get_acct(struct io_wqe *wqe, in io_work_get_acct() argument170 return io_get_acct(wqe, !(work->flags & IO_WQ_WORK_UNBOUND)); in io_work_get_acct()175 return io_get_acct(worker->wqe, worker->flags & IO_WORKER_F_BOUND); in io_wqe_get_acct()191 return test_bit(IO_WQ_BIT_EXIT, &worker->wqe->wq->state); in io_wq_worker_stopped()197 struct io_wqe *wqe = worker->wqe; in io_worker_cancel_cb() local[all …]
54 static inline struct io_kiocb *wqe_to_req(struct wait_queue_entry *wqe) in wqe_to_req() argument56 unsigned long priv = (unsigned long)wqe->private; in wqe_to_req()61 static inline bool wqe_is_double(struct wait_queue_entry *wqe) in wqe_is_double() argument63 unsigned long priv = (unsigned long)wqe->private; in wqe_is_double()