public inbox for [email protected]
 help / color / mirror / Atom feed
* [PATCH liburing] fix test_buf_select_pipe on older kernels
@ 2022-07-04 16:06 Dylan Yudaken
  0 siblings, 0 replies; only message 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] only message in thread

only message in thread, other threads:[~2022-07-04 16:06 UTC | newest]

Thread overview: (only message) (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

This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox