commit 200cb82311bb79b18994b2bfbad6b090eee7f0d0
author Jean-Philippe Brucker <jean-philippe.brucker@arm.com> Thu Apr 04 14:20:47 2019 +0100
committer Will Deacon <will.deacon@arm.com> Fri Apr 26 14:57:59 2019 +0100
tree 40a45a87b513be79e0e5f0e28ba73ce73578c603
parent d62e8ee002eb1ef50d0ca9dfa4f0c04782e53879

disk/aio: Fix AIO thread

Currently when the kernel completes a batch of AIO requests and signals it
via eventfd, we retrieve at most AIO_MAX events (256), and ignore the
rest. Call io_getevents() again in case more events are pending.

Reviewed-by: Andre Przywara <andre.przywara@arm.com>
Signed-off-by: Jean-Philippe Brucker <jean-philippe.brucker@arm.com>
Signed-off-by: Will Deacon <will.deacon@arm.com>

disk/aio.c

diff --git a/disk/aio.c b/disk/aio.c
index 007415c..1fcf368 100644
--- a/disk/aio.c
+++ b/disk/aio.c
@@ -66,20 +66,31 @@
 			   offset, disk->evt, param);
 }
 
-static void *disk_aio_thread(void *param)
+static int disk_aio_get_events(struct disk_image *disk)
 {
-	struct disk_image *disk = param;
 	struct io_event event[AIO_MAX];
 	struct timespec notime = {0};
 	int nr, i;
+
+	do {
+		nr = io_getevents(disk->ctx, 1, ARRAY_SIZE(event), event, &notime);
+		for (i = 0; i < nr; i++)
+			disk->disk_req_cb(event[i].data, event[i].res);
+	} while (nr > 0);
+
+	return 0;
+}
+
+static void *disk_aio_thread(void *param)
+{
+	struct disk_image *disk = param;
 	u64 dummy;
 
 	kvm__set_thread_name("disk-image-io");
 
 	while (read(disk->evt, &dummy, sizeof(dummy)) > 0) {
-		nr = io_getevents(disk->ctx, 1, ARRAY_SIZE(event), event, &notime);
-		for (i = 0; i < nr; i++)
-			disk->disk_req_cb(event[i].data, event[i].res);
+		if (disk_aio_get_events(disk))
+			break;
 	}
 
 	return NULL;