diff options
| -rw-r--r-- | io_uring/io_uring.c | 15 |
1 files changed, 3 insertions, 12 deletions
diff --git a/io_uring/io_uring.c b/io_uring/io_uring.c index 6b606e9dffa3..f83abdf8a056 100644 --- a/io_uring/io_uring.c +++ b/io_uring/io_uring.c @@ -1674,17 +1674,6 @@ static __cold void io_drain_req(struct io_kiocb *req) struct io_defer_entry *de; u32 seq = io_get_sequence(req); - /* Still need defer if there is pending req in defer list. */ - spin_lock(&ctx->completion_lock); - if (!req_need_defer(req, seq) && list_empty_careful(&ctx->defer_list)) { - spin_unlock(&ctx->completion_lock); -queue: - ctx->drain_active = false; - io_req_task_queue(req); - return; - } - spin_unlock(&ctx->completion_lock); - io_prep_async_link(req); de = kmalloc(sizeof(*de), GFP_KERNEL_ACCOUNT); if (!de) { @@ -1696,7 +1685,9 @@ queue: if (!req_need_defer(req, seq) && list_empty(&ctx->defer_list)) { spin_unlock(&ctx->completion_lock); kfree(de); - goto queue; + ctx->drain_active = false; + io_req_task_queue(req); + return; } trace_io_uring_defer(req); |