X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=t%2Fio_uring.c;h=f27a12c7bb26cefe49e224468bc0197f1913795a;hb=24a24c12a04c45174c2d68ffb7fcb3f367e40dee;hp=ffdb5d3db545130f1754466f50b9ae652cde6061;hpb=265697fc16b767fee5fae25a73d74ec4df20d94a;p=fio.git

diff --git a/t/io_uring.c b/t/io_uring.c
index ffdb5d3d..f27a12c7 100644
--- a/t/io_uring.c
+++ b/t/io_uring.c
@@ -701,23 +701,21 @@ static void *submitter_aio_fn(void *data)
 		}
 		prepped = 0;
 
-		if (to_wait) {
+		while (to_wait) {
 			int r;
 
-			do {
-				s->calls++;
-				r = io_getevents(s->aio_ctx, to_wait, to_wait, events, NULL);
-				if (r < 0) {
-					perror("io_getevents");
-					break;
-				} else if (r != to_wait) {
-					printf("r=%d, wait=%d\n", r, to_wait);
-					break;
-				}
-				r = reap_events_aio(s, events, r);
-				s->reaps += r;
-				to_wait -= r;
-			} while (to_wait);
+			s->calls++;
+			r = io_getevents(s->aio_ctx, to_wait, to_wait, events, NULL);
+			if (r < 0) {
+				perror("io_getevents");
+				break;
+			} else if (r != to_wait) {
+				printf("r=%d, wait=%d\n", r, to_wait);
+				break;
+			}
+			r = reap_events_aio(s, events, r);
+			s->reaps += r;
+			to_wait -= r;
 		}
 	} while (!s->finish);