aboutsummaryrefslogtreecommitdiff
path: root/io_uring/io_uring.c
diff options
context:
space:
mode:
authorGravatar Jens Axboe <axboe@kernel.dk> 2024-04-25 09:04:32 -0600
committerGravatar Jens Axboe <axboe@kernel.dk> 2024-04-25 09:04:32 -0600
commit039a2e800bcd5beb89909d1a488abf3d647642cf (patch)
tree8e59e54518aa9890b4814efb67fc77651af60337 /io_uring/io_uring.c
parentio_uring/notif: implement notification stacking (diff)
downloadlinux-039a2e800bcd5beb89909d1a488abf3d647642cf.tar.gz
linux-039a2e800bcd5beb89909d1a488abf3d647642cf.tar.bz2
linux-039a2e800bcd5beb89909d1a488abf3d647642cf.zip
io_uring/rw: reinstate thread check for retries
Allowing retries for everything is arguably the right thing to do, now that every command type is async read from the start. But it's exposed a few issues around missing check for a retry (which cca6571381a0 exposed), and the fixup commit for that isn't necessarily 100% sound in terms of iov_iter state. For now, just revert these two commits. This unfortunately then re-opens the fact that -EAGAIN can get bubbled to userspace for some cases where the kernel very well could just sanely retry them. But until we have all the conditions covered around that, we cannot safely enable that. This reverts commit df604d2ad480fcf7b39767280c9093e13b1de952. This reverts commit cca6571381a0bdc88021a1f7a4c2349df21279f7. Signed-off-by: Jens Axboe <axboe@kernel.dk>
Diffstat (limited to 'io_uring/io_uring.c')
-rw-r--r--io_uring/io_uring.c13
1 files changed, 0 insertions, 13 deletions
diff --git a/io_uring/io_uring.c b/io_uring/io_uring.c
index 64845634d89f..2675cffbd9a4 100644
--- a/io_uring/io_uring.c
+++ b/io_uring/io_uring.c
@@ -527,19 +527,6 @@ static void io_queue_iowq(struct io_kiocb *req)
io_queue_linked_timeout(link);
}
-static void io_tw_requeue_iowq(struct io_kiocb *req, struct io_tw_state *ts)
-{
- req->flags &= ~REQ_F_REISSUE;
- io_queue_iowq(req);
-}
-
-void io_tw_queue_iowq(struct io_kiocb *req)
-{
- req->flags |= REQ_F_REISSUE | REQ_F_BL_NO_RECYCLE;
- req->io_task_work.func = io_tw_requeue_iowq;
- io_req_task_work_add(req);
-}
-
static __cold void io_queue_deferred(struct io_ring_ctx *ctx)
{
while (!list_empty(&ctx->defer_list)) {