Home
last modified time | relevance | path

Searched refs:iowq (Results 1 - 2 of 2) sorted by relevance

/kernel/linux/linux-6.6/io_uring/
H A Dio_uring.c1914 /* either cancelled or io-wq is dying, so don't touch tctx->iowq */ in io_wq_submit_work()
2450 static inline bool io_should_wake(struct io_wait_queue *iowq) in io_should_wake() argument
2452 struct io_ring_ctx *ctx = iowq->ctx; in io_should_wake()
2453 int dist = READ_ONCE(ctx->rings->cq.tail) - (int) iowq->cq_tail; in io_should_wake()
2460 return dist >= 0 || atomic_read(&ctx->cq_timeouts) != iowq->nr_timeouts; in io_should_wake()
2466 struct io_wait_queue *iowq = container_of(curr, struct io_wait_queue, wq); in io_wake_function() local
2472 if (io_should_wake(iowq) || io_has_work(iowq->ctx)) in io_wake_function()
2502 struct io_wait_queue *iowq) in io_cqring_wait_schedule()
2514 if (unlikely(io_should_wake(iowq))) in io_cqring_wait_schedule()
2501 io_cqring_wait_schedule(struct io_ring_ctx *ctx, struct io_wait_queue *iowq) io_cqring_wait_schedule() argument
2541 struct io_wait_queue iowq; io_cqring_wait() local
[all...]
/kernel/linux/linux-5.10/io_uring/
H A Dio_uring.c6894 /* either cancelled or io-wq is dying, so don't touch tctx->iowq */ in io_wq_submit_work()
7606 static inline bool io_should_wake(struct io_wait_queue *iowq) in io_should_wake() argument
7608 struct io_ring_ctx *ctx = iowq->ctx; in io_should_wake()
7609 int dist = ctx->cached_cq_tail - (int) iowq->cq_tail; in io_should_wake()
7616 return dist >= 0 || atomic_read(&ctx->cq_timeouts) != iowq->nr_timeouts; in io_should_wake()
7622 struct io_wait_queue *iowq = container_of(curr, struct io_wait_queue, in io_wake_function() local
7629 if (io_should_wake(iowq) || test_bit(0, &iowq->ctx->check_cq_overflow)) in io_wake_function()
7656 struct io_wait_queue *iowq, in io_cqring_wait_schedule()
7663 if (ret || io_should_wake(iowq)) in io_cqring_wait_schedule()
7655 io_cqring_wait_schedule(struct io_ring_ctx *ctx, struct io_wait_queue *iowq, ktime_t *timeout) io_cqring_wait_schedule() argument
7692 struct io_wait_queue iowq; io_cqring_wait() local
[all...]

Completed in 30 milliseconds