1 // SPDX-License-Identifier: GPL-2.0
2 #include <test_progs.h>
3 #include "cgroup_helpers.h"
5 struct tcp_rtt_storage {
10 __u32 icsk_retransmits;
13 static void send_byte(int fd)
17 if (CHECK_FAIL(write(fd, &b, sizeof(b)) != 1))
18 perror("Failed to send single byte");
21 static int wait_for_ack(int fd, int retries)
27 for (i = 0; i < retries; i++) {
28 optlen = sizeof(info);
29 err = getsockopt(fd, SOL_TCP, TCP_INFO, &info, &optlen);
31 log_err("Failed to lookup TCP stats");
35 if (info.tcpi_unacked == 0)
41 log_err("Did not receive ACK");
45 static int verify_sk(int map_fd, int client_fd, const char *msg, __u32 invoked,
46 __u32 dsack_dups, __u32 delivered, __u32 delivered_ce,
47 __u32 icsk_retransmits)
50 struct tcp_rtt_storage val;
52 if (CHECK_FAIL(bpf_map_lookup_elem(map_fd, &client_fd, &val) < 0)) {
53 perror("Failed to read socket storage");
57 if (val.invoked != invoked) {
58 log_err("%s: unexpected bpf_tcp_sock.invoked %d != %d",
59 msg, val.invoked, invoked);
63 if (val.dsack_dups != dsack_dups) {
64 log_err("%s: unexpected bpf_tcp_sock.dsack_dups %d != %d",
65 msg, val.dsack_dups, dsack_dups);
69 if (val.delivered != delivered) {
70 log_err("%s: unexpected bpf_tcp_sock.delivered %d != %d",
71 msg, val.delivered, delivered);
75 if (val.delivered_ce != delivered_ce) {
76 log_err("%s: unexpected bpf_tcp_sock.delivered_ce %d != %d",
77 msg, val.delivered_ce, delivered_ce);
81 if (val.icsk_retransmits != icsk_retransmits) {
82 log_err("%s: unexpected bpf_tcp_sock.icsk_retransmits %d != %d",
83 msg, val.icsk_retransmits, icsk_retransmits);
90 static int connect_to_server(int server_fd)
92 struct sockaddr_storage addr;
93 socklen_t len = sizeof(addr);
96 fd = socket(AF_INET, SOCK_STREAM, 0);
98 log_err("Failed to create client socket");
102 if (getsockname(server_fd, (struct sockaddr *)&addr, &len)) {
103 log_err("Failed to get server addr");
107 if (connect(fd, (const struct sockaddr *)&addr, len) < 0) {
108 log_err("Fail to connect to server");
119 static int run_test(int cgroup_fd, int server_fd)
121 struct bpf_prog_load_attr attr = {
122 .prog_type = BPF_PROG_TYPE_SOCK_OPS,
123 .file = "./tcp_rtt.o",
124 .expected_attach_type = BPF_CGROUP_SOCK_OPS,
126 struct bpf_object *obj;
133 err = bpf_prog_load_xattr(&attr, &obj, &prog_fd);
135 log_err("Failed to load BPF object");
139 map = bpf_map__next(NULL, obj);
140 map_fd = bpf_map__fd(map);
142 err = bpf_prog_attach(prog_fd, cgroup_fd, BPF_CGROUP_SOCK_OPS, 0);
144 log_err("Failed to attach BPF program");
145 goto close_bpf_object;
148 client_fd = connect_to_server(server_fd);
151 goto close_bpf_object;
154 err += verify_sk(map_fd, client_fd, "syn-ack",
159 /*icsk_retransmits=*/0);
161 send_byte(client_fd);
162 if (wait_for_ack(client_fd, 100) < 0) {
164 goto close_client_fd;
168 err += verify_sk(map_fd, client_fd, "first payload byte",
173 /*icsk_retransmits=*/0);
179 bpf_object__close(obj);
183 static int start_server(void)
185 struct sockaddr_in addr = {
186 .sin_family = AF_INET,
187 .sin_addr.s_addr = htonl(INADDR_LOOPBACK),
191 fd = socket(AF_INET, SOCK_STREAM, 0);
193 log_err("Failed to create server socket");
197 if (bind(fd, (const struct sockaddr *)&addr, sizeof(addr)) < 0) {
198 log_err("Failed to bind socket");
206 static pthread_mutex_t server_started_mtx = PTHREAD_MUTEX_INITIALIZER;
207 static pthread_cond_t server_started = PTHREAD_COND_INITIALIZER;
209 static void *server_thread(void *arg)
211 struct sockaddr_storage addr;
212 socklen_t len = sizeof(addr);
213 int fd = *(int *)arg;
219 pthread_mutex_lock(&server_started_mtx);
220 pthread_cond_signal(&server_started);
221 pthread_mutex_unlock(&server_started_mtx);
223 if (CHECK_FAIL(err < 0)) {
224 perror("Failed to listed on socket");
228 client_fd = accept(fd, (struct sockaddr *)&addr, &len);
229 if (CHECK_FAIL(client_fd < 0)) {
230 perror("Failed to accept client");
234 /* Wait for the next connection (that never arrives)
235 * to keep this thread alive to prevent calling
236 * close() on client_fd.
238 if (CHECK_FAIL(accept(fd, (struct sockaddr *)&addr, &len) >= 0)) {
239 perror("Unexpected success in second accept");
248 void test_tcp_rtt(void)
250 int server_fd, cgroup_fd;
253 cgroup_fd = test__join_cgroup("/tcp_rtt");
254 if (CHECK_FAIL(cgroup_fd < 0))
257 server_fd = start_server();
258 if (CHECK_FAIL(server_fd < 0))
259 goto close_cgroup_fd;
261 if (CHECK_FAIL(pthread_create(&tid, NULL, server_thread,
262 (void *)&server_fd)))
263 goto close_server_fd;
265 pthread_mutex_lock(&server_started_mtx);
266 pthread_cond_wait(&server_started, &server_started_mtx);
267 pthread_mutex_unlock(&server_started_mtx);
269 CHECK_FAIL(run_test(cgroup_fd, server_fd));