* [PATCH liburing] fix test_buf_select_pipe on older kernels
@ 2022-07-04 16:06 Dylan Yudaken
2022-07-05 14:38 ` Jens Axboe
0 siblings, 1 reply; 2+ messages in thread
From: Dylan Yudaken @ 2022-07-04 16:06 UTC (permalink / raw)
To: io-uring; +Cc: axboe, asml.silence, Dylan Yudaken
timing issues might cause out of order completes on older kernels,
especially regarding selecting a buffer before queueing up IO (as it can
complete with ENOBUFS being queued).
Theres no reason to test ENOBUFS for this problem, so remove those checks.
Signed-off-by: Dylan Yudaken <[email protected]>
---
test/read-write.c | 24 +++++++-----------------
1 file changed, 7 insertions(+), 17 deletions(-)
diff --git a/test/read-write.c b/test/read-write.c
index eadeb78..c5cc469 100644
--- a/test/read-write.c
+++ b/test/read-write.c
@@ -428,28 +428,25 @@ static int test_buf_select_short(const char *filename, int nonvec)
return ret;
}
-static int provide_buffers_iovec(struct io_uring *ring, int bgid, int count)
+static int provide_buffers_iovec(struct io_uring *ring, int bgid)
{
struct io_uring_sqe *sqe;
struct io_uring_cqe *cqe;
int i, ret;
- if (count <= 0)
- count = BUFFERS;
-
- for (i = 0; i < count; i++) {
+ for (i = 0; i < BUFFERS; i++) {
sqe = io_uring_get_sqe(ring);
io_uring_prep_provide_buffers(sqe, vecs[i].iov_base,
vecs[i].iov_len, 1, bgid, i);
}
ret = io_uring_submit(ring);
- if (ret != count) {
+ if (ret != BUFFERS) {
fprintf(stderr, "submit: %d\n", ret);
return -1;
}
- for (i = 0; i < count; i++) {
+ for (i = 0; i < BUFFERS; i++) {
ret = io_uring_wait_cqe(ring, &cqe);
if (ret) {
fprintf(stderr, "wait_cqe=%d\n", ret);
@@ -482,7 +479,7 @@ static int test_buf_select_pipe(void)
return 1;
}
- ret = provide_buffers_iovec(&ring, 0, 4);
+ ret = provide_buffers_iovec(&ring, 0);
if (ret) {
fprintf(stderr, "provide buffers failed: %d\n", ret);
return 1;
@@ -515,13 +512,6 @@ static int test_buf_select_pipe(void)
fprintf(stderr, "bad wait %d\n", i);
return 1;
}
- if (i == 4) {
- if (cqe->res != -ENOBUFS) {
- fprintf(stderr, "expected failure %d\n", cqe->res);
- return 1;
- }
- continue;
- }
if (cqe->res != 1) {
fprintf(stderr, "expected read %d\n", cqe->res);
return 1;
@@ -580,7 +570,7 @@ static int test_buf_select(const char *filename, int nonvec)
for (i = 0; i < BUFFERS; i++)
memset(vecs[i].iov_base, 0x55, vecs[i].iov_len);
- ret = provide_buffers_iovec(&ring, 1, -1);
+ ret = provide_buffers_iovec(&ring, 1);
if (ret)
return ret;
@@ -606,7 +596,7 @@ static int test_rem_buf(int batch, int sqe_flags)
return 1;
}
- ret = provide_buffers_iovec(&ring, bgid, -1);
+ ret = provide_buffers_iovec(&ring, bgid);
if (ret)
return ret;
base-commit: f8eb5f804288e10ae7ef442ef482e4dd8b18fee7
--
2.30.2
^ permalink raw reply related [flat|nested] 2+ messages in thread
end of thread, other threads:[~2022-07-05 14:38 UTC | newest]
Thread overview: 2+ messages (download: mbox.gz follow: Atom feed
-- links below jump to the message on this page --
2022-07-04 16:06 [PATCH liburing] fix test_buf_select_pipe on older kernels Dylan Yudaken
2022-07-05 14:38 ` Jens Axboe
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox