Searched refs:iowq (Results 1 – 1 of 1) sorted by relevance
1943 /* either cancelled or io-wq is dying, so don't touch tctx->iowq */ in io_wq_submit_work() 2488 static inline bool io_should_wake(struct io_wait_queue *iowq)2490 struct io_ring_ctx *ctx = iowq->ctx; in io_should_wake() 2491 int dist = READ_ONCE(ctx->rings->cq.tail) - (int) iowq->cq_tail; in io_should_wake() 2498 return dist >= 0 || atomic_read(&ctx->cq_timeouts) != iowq->nr_timeouts; in io_should_wake() 2504 struct io_wait_queue *iowq = container_of(curr, struct io_wait_queue, wq); in io_wake_function() 2510 if (io_should_wake(iowq) || io_has_work(iowq->ctx)) in io_wake_function() 2540 struct io_wait_queue *iowq) in io_cqring_wait_schedule() 2552 if (unlikely(io_should_wake(iowq))) in io_cqring_wait_schedule() 2489 io_should_wake(struct io_wait_queue * iowq) io_should_wake() argument 2505 struct io_wait_queue *iowq = container_of(curr, struct io_wait_queue, wq); io_wake_function() local 2541 io_cqring_wait_schedule(struct io_ring_ctx * ctx,struct io_wait_queue * iowq) io_cqring_wait_schedule() argument 2580 struct io_wait_queue iowq; io_cqring_wait() local [all...]