summaryrefslogtreecommitdiff
path: root/io_uring/wait.c
diff options
context:
space:
mode:
Diffstat (limited to 'io_uring/wait.c')
-rw-r--r--io_uring/wait.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/io_uring/wait.c b/io_uring/wait.c
index ec01e78a216d..a48523c2f356 100644
--- a/io_uring/wait.c
+++ b/io_uring/wait.c
@@ -98,12 +98,12 @@ static enum hrtimer_restart io_cqring_min_timer_wakeup(struct hrtimer *timer)
if (ctx->flags & IORING_SETUP_DEFER_TASKRUN) {
atomic_set(&ctx->cq_wait_nr, 1);
smp_mb();
- if (!llist_empty(&ctx->work_llist))
+ if (io_local_work_pending(ctx))
goto out_wake;
}
/* any generated CQE posted past this time should wake us up */
- iowq->cq_tail = iowq->cq_min_tail;
+ iowq->cq_tail = iowq->cq_min_tail + 1;
hrtimer_update_function(&iowq->t, io_cqring_timer_wakeup);
hrtimer_set_expires(timer, iowq->timeout);