examples/zcrx: check for submission errors

Signed-off-by: Pavel Begunkov <asml.silence@gmail.com>

Author: isilence

examples/zcrx.c

@@ -350,7 +350,8 @@ static void return_buffer(struct io_uring_zcrx_rq *rq_ring,
 	io_uring_smp_store_release(rq_ring->ktail, ++rq_ring->rq_tail);
 }
 
-static void process_recvzc_error(struct zc_conn *conn, int ret)
+static void process_recvzc_error(struct io_uring *ring,
+				 struct zc_conn *conn, int ret)
 {
 	if (ret == -ENOSPC) {
 		size_t left = 0;
@@ -379,7 +380,7 @@ static void process_recvzc_error(struct zc_conn *conn, int ret)
 	stop = true;
 }
 
-static void process_recvzc(struct io_uring __attribute__((unused)) *ring,
+static void process_recvzc(struct io_uring *ring,
 			   struct io_uring_cqe *cqe)
 {
 	struct zc_conn *conn = get_connection(cqe->user_data);
@@ -390,7 +391,7 @@ static void process_recvzc(struct io_uring __attribute__((unused)) *ring,
 	conn->stat_nr_cqes++;
 
 	if (!(cqe->flags & IORING_CQE_F_MORE)) {
-		process_recvzc_error(conn, cqe->res);
+		process_recvzc_error(ring, conn, cqe->res);
 		return;
 	}
 	if (cqe->res < 0)
@@ -409,8 +410,11 @@ static void server_loop(struct io_uring *ring)
 {
 	struct io_uring_cqe *cqe;
 	unsigned int head, count = 0;
+	int ret;
 
-	io_uring_submit_and_wait(ring, 1);
+	ret = io_uring_submit_and_wait(ring, 1);
+	if (ret < 0 && ret != -ETIME)
+		t_error(1, ret, "io_uring_submit_and_wait failed\n");
 
 	io_uring_for_each_cqe(ring, head, cqe) {
 		switch (cqe->user_data & REQ_TYPE_MASK) {