Add chain failure handling test case

Signed-off-by: Jens Axboe <axboe@kernel.dk>

2 files changed, 78 insertions, 4 deletions

diff --git a/examples/link-cp.c b/examples/link-cp.c
index c747966..993d3a6 100644
--- a/examples/link-cp.c
+++ b/examples/link-cp.c
@@ -82,6 +82,9 @@ static void handle_cqe(struct io_uring_cqe *cqe)
 {
 	struct io_data *data;
 
+	if (cqe->res < 0)
+		printf("cqe error: %s\n", strerror(cqe->res));
+
 	data = io_uring_cqe_get_data(cqe);
 	if (!data)
 		return;
diff --git a/test/link.c b/test/link.c
index b656bb2..e7ca3e3 100644
--- a/test/link.c
+++ b/test/link.c
@@ -12,6 +12,64 @@
 #include "../src/liburing.h"
 
 /*
+ * Test failing head of chain, and dependent getting -ECANCELED
+ */
+static int test_single_link_fail(struct io_uring *ring)
+{
+	struct io_uring_cqe *cqe;
+	struct io_uring_sqe *sqe;
+	int ret, i;
+
+	sqe = io_uring_get_sqe(ring);
+	if (!sqe) {
+		printf("get sqe failed\n");
+		goto err;
+	}
+
+	io_uring_prep_nop(sqe);
+	sqe->flags |= IOSQE_IO_LINK;
+
+	sqe = io_uring_get_sqe(ring);
+	if (!sqe) {
+		printf("get sqe failed\n");
+		goto err;
+	}
+
+	io_uring_prep_nop(sqe);
+
+	ret = io_uring_submit(ring);
+	if (ret <= 0) {
+		printf("sqe submit failed: %d\n", ret);
+		goto err;
+	}
+
+	for (i = 0; i < 2; i++) {
+		ret = io_uring_peek_cqe(ring, &cqe);
+		if (ret < 0) {
+			printf("wait completion %d\n", ret);
+			goto err;
+		}
+		if (!cqe) {
+			printf("failed to get cqe\n");
+			goto err;
+		}
+		if (i == 0 && cqe->res != -EINVAL) {
+			printf("sqe0 failed with %d, wanted -EINVAL\n", cqe->res);
+			goto err;
+		}
+		if (i == 1 && cqe->res != -ECANCELED) {
+			printf("sqe0 failed with %d, wanted -ECANCELED\n", cqe->res);
+			goto err;
+		}
+		io_uring_cqe_seen(ring, cqe);
+	}
+
+	return 0;
+err:
+	return 1;
+}
+
+/*
  * Test two independent chains
  */
 static int test_double_chain(struct io_uring *ring)
@@ -53,7 +111,7 @@ static int test_double_chain(struct io_uring *ring)
 	}
 
 	io_uring_prep_nop(sqe);
-	
+
 	ret = io_uring_submit(ring);
 	if (ret <= 0) {
 		printf("sqe submit failed: %d\n", ret);
@@ -108,7 +166,7 @@ static int test_double_link(struct io_uring *ring)
 	}
 
 	io_uring_prep_nop(sqe);
-	
+
 	ret = io_uring_submit(ring);
 	if (ret <= 0) {
 		printf("sqe submit failed: %d\n", ret);
@@ -154,7 +212,7 @@ static int test_single_link(struct io_uring *ring)
 	}
 
 	io_uring_prep_nop(sqe);
-	
+
 	ret = io_uring_submit(ring);
 	if (ret <= 0) {
 		printf("sqe submit failed: %d\n", ret);
@@ -177,7 +235,7 @@ err:
 
 int main(int argc, char *argv[])
 {
-	struct io_uring ring;
+	struct io_uring ring, poll_ring;
 	int ret;
 
 	ret = io_uring_queue_init(8, &ring, 0);
@@ -187,6 +245,13 @@ int main(int argc, char *argv[])
 
 	}
 
+	ret = io_uring_queue_init(8, &poll_ring, IORING_SETUP_IOPOLL);
+	if (ret) {
+		printf("poll_ring setup failed\n");
+		return 1;
+
+	}
+
 	ret = test_single_link(&ring);
 	if (ret) {
 		printf("test_single_link failed\n");
@@ -205,5 +270,11 @@ int main(int argc, char *argv[])
 		return ret;
 	}
 
+	ret = test_single_link_fail(&poll_ring);
+	if (ret) {
+		printf("test_single_link_fail failed\n");
+		return ret;
+	}
+
 	return 0;
 }