1 /* SPDX-License-Identifier: MIT */
2 #include <liburing.h>
3 #include <netdb.h>
4 #include <string.h>
5 #include <sys/socket.h>
6 #include <sys/types.h>
7 #include <unistd.h>
8 #include <stdio.h>
9 #include <errno.h>
10 #include "liburing.h"
11 #include "../src/syscall.h"
12
13 struct io_uring io_uring;
14
sys_io_uring_enter(const int fd,const unsigned to_submit,const unsigned min_complete,const unsigned flags,sigset_t * const sig)15 int sys_io_uring_enter(const int fd,
16 const unsigned to_submit,
17 const unsigned min_complete,
18 const unsigned flags, sigset_t * const sig)
19 {
20 return __sys_io_uring_enter(fd, to_submit, min_complete, flags, sig);
21 }
22
submit_sqe(void)23 int submit_sqe(void)
24 {
25 struct io_uring_sq *sq = &io_uring.sq;
26 const unsigned tail = *sq->ktail;
27
28 sq->array[tail & *sq->kring_mask] = 0;
29 io_uring_smp_store_release(sq->ktail, tail + 1);
30
31 return sys_io_uring_enter(io_uring.ring_fd, 1, 0, 0, NULL);
32 }
33
main(int argc,char ** argv)34 int main(int argc, char **argv)
35 {
36 struct addrinfo *addr_info_list = NULL;
37 struct addrinfo *ai, *addr_info = NULL;
38 struct io_uring_params params;
39 struct io_uring_sqe *sqe;
40 struct addrinfo hints;
41 struct sockaddr sa;
42 socklen_t sa_size = sizeof(sa);
43 int ret, listen_fd, connect_fd, val, i;
44
45 if (argc > 1)
46 return 0;
47
48 memset(¶ms, 0, sizeof(params));
49 ret = io_uring_queue_init_params(4, &io_uring, ¶ms);
50 if (ret) {
51 fprintf(stderr, "io_uring_init_failed: %d\n", ret);
52 return 1;
53 }
54 if (!(params.features & IORING_FEAT_SUBMIT_STABLE)) {
55 fprintf(stdout, "FEAT_SUBMIT_STABLE not there, skipping\n");
56 return 0;
57 }
58
59 memset(&hints, 0, sizeof(hints));
60 hints.ai_family = AF_UNSPEC;
61 hints.ai_socktype = SOCK_STREAM;
62 hints.ai_flags = AI_PASSIVE | AI_NUMERICSERV;
63
64 ret = getaddrinfo(NULL, "12345", &hints, &addr_info_list);
65 if (ret < 0) {
66 perror("getaddrinfo");
67 return 1;
68 }
69
70 for (ai = addr_info_list; ai; ai = ai->ai_next) {
71 if (ai->ai_family == AF_INET || ai->ai_family == AF_INET6) {
72 addr_info = ai;
73 break;
74 }
75 }
76 if (!addr_info) {
77 fprintf(stderr, "addrinfo not found\n");
78 return 1;
79 }
80
81 sqe = &io_uring.sq.sqes[0];
82 listen_fd = -1;
83
84 ret = socket(addr_info->ai_family, SOCK_STREAM,
85 addr_info->ai_protocol);
86 if (ret < 0) {
87 perror("socket");
88 return 1;
89 }
90 listen_fd = ret;
91
92 val = 1;
93 setsockopt(listen_fd, SOL_SOCKET, SO_REUSEADDR, &val, sizeof(int));
94 setsockopt(listen_fd, SOL_SOCKET, SO_REUSEPORT, &val, sizeof(int));
95
96 ret = bind(listen_fd, addr_info->ai_addr, addr_info->ai_addrlen);
97 if (ret < 0) {
98 perror("bind");
99 return 1;
100 }
101
102 ret = listen(listen_fd, SOMAXCONN);
103 if (ret < 0) {
104 perror("listen");
105 return 1;
106 }
107
108 memset(&sa, 0, sizeof(sa));
109
110 io_uring_prep_accept(sqe, listen_fd, &sa, &sa_size, 0);
111 sqe->user_data = 1;
112 ret = submit_sqe();
113 if (ret != 1) {
114 fprintf(stderr, "submit failed: %d\n", ret);
115 return 1;
116 }
117
118 connect_fd = -1;
119 ret = socket(addr_info->ai_family, SOCK_STREAM, addr_info->ai_protocol);
120 if (ret < 0) {
121 perror("socket");
122 return 1;
123 }
124 connect_fd = ret;
125
126 io_uring_prep_connect(sqe, connect_fd, addr_info->ai_addr,
127 addr_info->ai_addrlen);
128 sqe->user_data = 2;
129 ret = submit_sqe();
130 if (ret != 1) {
131 fprintf(stderr, "submit failed: %d\n", ret);
132 return 1;
133 }
134
135 for (i = 0; i < 2; i++) {
136 struct io_uring_cqe *cqe = NULL;
137
138 ret = io_uring_wait_cqe(&io_uring, &cqe);
139 if (ret) {
140 fprintf(stderr, "io_uring_wait_cqe: %d\n", ret);
141 return 1;
142 }
143
144 switch (cqe->user_data) {
145 case 1:
146 if (cqe->res < 0) {
147 fprintf(stderr, "accept failed: %d\n", cqe->res);
148 return 1;
149 }
150 break;
151 case 2:
152 if (cqe->res) {
153 fprintf(stderr, "connect failed: %d\n", cqe->res);
154 return 1;
155 }
156 break;
157 }
158 io_uring_cq_advance(&io_uring, 1);
159 }
160
161 freeaddrinfo(addr_info_list);
162 io_uring_queue_exit(&io_uring);
163 return 0;
164 }
165