提交 84914a4c 编写于 作者: J Jens Axboe 提交者: Cheng Jian

io_uring: cleanup return values from the queueing functions

mainline inclusion
from mainline-5.5-rc1
commit 0e0702da
category: feature
bugzilla: https://bugzilla.openeuler.org/show_bug.cgi?id=27
CVE: NA
---------------------------

__io_queue_sqe(), io_queue_sqe(), io_queue_link_head() all return 0/err,
but the caller doesn't care since the errors are handled inline. Clean
these up and just make them void.
Signed-off-by: NJens Axboe <axboe@kernel.dk>
Signed-off-by: NZhihao Cheng <chengzhihao1@huawei.com>
Signed-off-by: Nyangerkun <yangerkun@huawei.com>
Reviewed-by: Nzhangyi (F) <yi.zhang@huawei.com>
Signed-off-by: NCheng Jian <cj.chengjian@huawei.com>
上级 a6caf01e
...@@ -2839,7 +2839,7 @@ static struct io_kiocb *io_prep_linked_timeout(struct io_kiocb *req, ...@@ -2839,7 +2839,7 @@ static struct io_kiocb *io_prep_linked_timeout(struct io_kiocb *req,
return nxt; return nxt;
} }
static int __io_queue_sqe(struct io_kiocb *req) static void __io_queue_sqe(struct io_kiocb *req)
{ {
enum hrtimer_mode mode; enum hrtimer_mode mode;
struct io_kiocb *nxt; struct io_kiocb *nxt;
...@@ -2884,7 +2884,7 @@ static int __io_queue_sqe(struct io_kiocb *req) ...@@ -2884,7 +2884,7 @@ static int __io_queue_sqe(struct io_kiocb *req)
if (nxt) if (nxt)
io_queue_linked_timeout(nxt, &ts, &mode); io_queue_linked_timeout(nxt, &ts, &mode);
return 0; return;
} }
} }
...@@ -2906,11 +2906,9 @@ static int __io_queue_sqe(struct io_kiocb *req) ...@@ -2906,11 +2906,9 @@ static int __io_queue_sqe(struct io_kiocb *req)
req->flags |= REQ_F_FAIL_LINK; req->flags |= REQ_F_FAIL_LINK;
io_put_req(req); io_put_req(req);
} }
return ret;
} }
static int io_queue_sqe(struct io_kiocb *req) static void io_queue_sqe(struct io_kiocb *req)
{ {
int ret; int ret;
...@@ -2920,20 +2918,20 @@ static int io_queue_sqe(struct io_kiocb *req) ...@@ -2920,20 +2918,20 @@ static int io_queue_sqe(struct io_kiocb *req)
io_cqring_add_event(req, ret); io_cqring_add_event(req, ret);
io_double_put_req(req); io_double_put_req(req);
} }
return 0; } else
} __io_queue_sqe(req);
return __io_queue_sqe(req);
} }
static int io_queue_link_head(struct io_kiocb *req, struct io_kiocb *shadow) static void io_queue_link_head(struct io_kiocb *req, struct io_kiocb *shadow)
{ {
int ret; int ret;
int need_submit = false; int need_submit = false;
struct io_ring_ctx *ctx = req->ctx; struct io_ring_ctx *ctx = req->ctx;
if (!shadow) if (!shadow) {
return io_queue_sqe(req); io_queue_sqe(req);
return;
}
/* /*
* Mark the first IO in link list as DRAIN, let all the following * Mark the first IO in link list as DRAIN, let all the following
...@@ -2947,7 +2945,7 @@ static int io_queue_link_head(struct io_kiocb *req, struct io_kiocb *shadow) ...@@ -2947,7 +2945,7 @@ static int io_queue_link_head(struct io_kiocb *req, struct io_kiocb *shadow)
io_cqring_add_event(req, ret); io_cqring_add_event(req, ret);
io_double_put_req(req); io_double_put_req(req);
__io_free_req(shadow); __io_free_req(shadow);
return 0; return;
} }
} else { } else {
/* /*
...@@ -2964,9 +2962,7 @@ static int io_queue_link_head(struct io_kiocb *req, struct io_kiocb *shadow) ...@@ -2964,9 +2962,7 @@ static int io_queue_link_head(struct io_kiocb *req, struct io_kiocb *shadow)
spin_unlock_irq(&ctx->completion_lock); spin_unlock_irq(&ctx->completion_lock);
if (need_submit) if (need_submit)
return __io_queue_sqe(req); __io_queue_sqe(req);
return 0;
} }
#define SQE_VALID_FLAGS (IOSQE_FIXED_FILE|IOSQE_IO_DRAIN|IOSQE_IO_LINK) #define SQE_VALID_FLAGS (IOSQE_FIXED_FILE|IOSQE_IO_DRAIN|IOSQE_IO_LINK)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册