testcase for aio write deadlock

1 files changed, 66 insertions, 0 deletions

diff --git a/harness/cases/13.t b/harness/cases/13.t
new file mode 100644
index 0000000..1cebae9
--- /dev/null
+++ b/harness/cases/13.t
@@ -0,0 +1,66 @@
+/* 13.t - uses testdir/rwfile
+- Submit multiple writes larger than aio-max-size (deadlocks on older
+  aio code)
+*/
+#include "aio_setup.h"
+
+#include <sys/time.h>
+#include <sys/resource.h>
+#include <unistd.h>
+
+int test_main(void)
+{
+#define SIZE	(1024 * 1024)
+#define IOS	8
+	struct iocb	iocbs[IOS];
+	struct iocb	*iocb_list[IOS];
+	char *bufs[IOS];
+	int rwfd;
+	int status = 0, res;
+	int i;
+
+	rwfd = open("testdir/rwfile", O_RDWR|O_CREAT|O_TRUNC, 0600);
+							assert(rwfd != -1);
+	res = ftruncate(rwfd, 0);			assert(res == 0);
+
+	for (i=0; i<IOS; i++) {
+		bufs[i] = malloc(SIZE);
+		assert(bufs[i] != NULL);
+		memset(bufs[i], 0, SIZE);
+
+		io_prep_pwrite(&iocbs[i], rwfd, bufs[i], SIZE, i * SIZE);
+		iocb_list[i] = &iocbs[i];
+	}
+
+	status |= attempt_io_submit(io_ctx, IOS, iocb_list, IOS);
+
+	for (i=0; i<IOS; i++) {
+		struct timespec ts = { tv_sec: 30, tv_nsec: 0 };
+		struct io_event event;
+		struct iocb *iocb;
+
+		res = io_getevents(io_ctx, 1, &event, &ts);
+		if (res != 1) {
+			status |= 1;
+			printf("io_getevents failed [%d] with res=%d [%s]\n",
+				i, res, strerror(-res));
+			break;
+		}
+
+		if (event.res != SIZE)
+			status |= 1;
+
+		iocb = (void *)event.obj;
+		printf("event[%d]: write[%d] %s, returned: %ld [%s]\n",
+			i, (int)(iocb - &iocbs[0]),
+			(event.res != SIZE) ? "failed" : "okay",
+			(long)event.res, strerror(-event.res)
+			);
+	}
+
+	res = ftruncate(rwfd, 0);			assert(res == 0);
+	res = close(rwfd);				assert(res == 0);
+	res = unlink("testdir/rwfile");			assert(res == 0);
+	return status;
+}
+