1 /* SPDX-License-Identifier: MIT */
2 /*
3 * Description: test use of eventfds with multiple rings
4 *
5 */
6 #include <errno.h>
7 #include <stdio.h>
8 #include <unistd.h>
9 #include <stdlib.h>
10 #include <string.h>
11 #include <fcntl.h>
12 #include <poll.h>
13 #include <sys/eventfd.h>
14
15 #include "liburing.h"
16 #include "helpers.h"
17
main(int argc,char * argv[])18 int main(int argc, char *argv[])
19 {
20 struct io_uring_params p = {};
21 struct io_uring ring1, ring2;
22 struct io_uring_sqe *sqe;
23 int ret, evfd1, evfd2;
24
25 if (argc > 1)
26 return T_EXIT_SKIP;
27
28 ret = io_uring_queue_init_params(8, &ring1, &p);
29 if (ret) {
30 fprintf(stderr, "ring setup failed: %d\n", ret);
31 return T_EXIT_FAIL;
32 }
33 if (!(p.features & IORING_FEAT_CUR_PERSONALITY)) {
34 fprintf(stdout, "Skipping\n");
35 return T_EXIT_SKIP;
36 }
37 ret = io_uring_queue_init(8, &ring2, 0);
38 if (ret) {
39 fprintf(stderr, "ring setup failed: %d\n", ret);
40 return T_EXIT_FAIL;
41 }
42
43 evfd1 = eventfd(0, EFD_CLOEXEC);
44 if (evfd1 < 0) {
45 perror("eventfd");
46 return T_EXIT_FAIL;
47 }
48
49 evfd2 = eventfd(0, EFD_CLOEXEC);
50 if (evfd2 < 0) {
51 perror("eventfd");
52 return T_EXIT_FAIL;
53 }
54
55 ret = io_uring_register_eventfd(&ring1, evfd1);
56 if (ret) {
57 fprintf(stderr, "failed to register evfd: %d\n", ret);
58 return T_EXIT_FAIL;
59 }
60
61 ret = io_uring_register_eventfd(&ring2, evfd2);
62 if (ret) {
63 fprintf(stderr, "failed to register evfd: %d\n", ret);
64 return T_EXIT_FAIL;
65 }
66
67 sqe = io_uring_get_sqe(&ring1);
68 io_uring_prep_poll_add(sqe, evfd2, POLLIN);
69 sqe->user_data = 1;
70
71 sqe = io_uring_get_sqe(&ring2);
72 io_uring_prep_poll_add(sqe, evfd1, POLLIN);
73 sqe->user_data = 1;
74
75 ret = io_uring_submit(&ring1);
76 if (ret != 1) {
77 fprintf(stderr, "submit: %d\n", ret);
78 return T_EXIT_FAIL;
79 }
80
81 ret = io_uring_submit(&ring2);
82 if (ret != 1) {
83 fprintf(stderr, "submit: %d\n", ret);
84 return T_EXIT_FAIL;
85 }
86
87 sqe = io_uring_get_sqe(&ring1);
88 io_uring_prep_nop(sqe);
89 sqe->user_data = 3;
90
91 ret = io_uring_submit(&ring1);
92 if (ret != 1) {
93 fprintf(stderr, "submit: %d\n", ret);
94 return T_EXIT_FAIL;
95 }
96
97 return T_EXIT_PASS;
98 }
99