summaryrefslogtreecommitdiff
path: root/test/cq-ready.c
diff options
context:
space:
mode:
authorJames Rouzier <rouzier@gmail.com>2019-09-25 10:46:19 -0400
committerJames Rouzier <rouzier@gmail.com>2019-09-25 20:11:50 -0400
commit46850c3a617e361c133c4da3d6e3069807ebe2b7 (patch)
tree0a09609779cdb12a526c36811dabff986621ffe1 /test/cq-ready.c
parent4e360f71131918c36774f51688e5c65dea8d43f2 (diff)
downloadliburing-46850c3a617e361c133c4da3d6e3069807ebe2b7.tar.gz
liburing-46850c3a617e361c133c4da3d6e3069807ebe2b7.tar.bz2
Add io_uring_cq_ready()
io_uring_cq_ready(), returns the number of completions that are ready. test/cq-ready.c: tests io_uring_cq_ready Signed-off-by: James Rouzier <rouzier@gmail.com>
Diffstat (limited to 'test/cq-ready.c')
-rw-r--r--test/cq-ready.c90
1 files changed, 90 insertions, 0 deletions
diff --git a/test/cq-ready.c b/test/cq-ready.c
new file mode 100644
index 0000000..1885c0c
--- /dev/null
+++ b/test/cq-ready.c
@@ -0,0 +1,90 @@
+/*
+ * Description: test CQ ready
+ *
+ */
+#include <errno.h>
+#include <stdio.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <string.h>
+#include <fcntl.h>
+
+#include "liburing.h"
+
+static int queue_n_nops(struct io_uring *ring, int n)
+{
+ struct io_uring_sqe *sqe;
+ int i, ret;
+
+ for (i = 0; i < n; i++) {
+ 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 < n) {
+ printf("Submitted only %d\n", ret);
+ goto err;
+ } else if (ret < 0) {
+ printf("sqe submit failed: %d\n", ret);
+ goto err;
+ }
+
+ return 0;
+err:
+ return 1;
+}
+
+#define CHECK_READY(ring, expected) do {\
+ ready = io_uring_cq_ready((ring));\
+ if (ready != expected) {\
+ printf("Got %d CQs ready, expected %d\n", ready, expected);\
+ goto err;\
+ }\
+} while(0)
+
+int main(int argc, char *argv[])
+{
+ struct io_uring ring;
+ int ret;
+ unsigned ready;
+
+ ret = io_uring_queue_init(4, &ring, 0);
+ if (ret) {
+ printf("ring setup failed\n");
+ return 1;
+
+ }
+
+ CHECK_READY(&ring, 0);
+ if (queue_n_nops(&ring, 4))
+ goto err;
+
+ CHECK_READY(&ring, 4);
+ io_uring_cq_advance(&ring, 4);
+ CHECK_READY(&ring, 0);
+ if (queue_n_nops(&ring, 4))
+ goto err;
+
+ CHECK_READY(&ring, 4);
+
+ io_uring_cq_advance(&ring, 1);
+ CHECK_READY(&ring, 3);
+
+ io_uring_cq_advance(&ring, 2);
+ CHECK_READY(&ring, 1);
+
+ io_uring_cq_advance(&ring, 1);
+ CHECK_READY(&ring, 0);
+
+ io_uring_queue_exit(&ring);
+ return 0;
+err:
+ io_uring_queue_exit(&ring);
+ return 1;
+}