/linux-master/tools/testing/selftests/bpf/prog_tests/ |
H A D | btf_skc_cls_ingress.c | 76 int listen_fd = -1, cli_fd = -1, srv_fd = -1, err; local 98 srv_fd = accept(listen_fd, NULL, NULL); 99 if (CHECK_FAIL(srv_fd == -1)) 124 if (srv_fd != -1) 125 close(srv_fd); 130 int listen_fd = -1, cli_fd = -1, srv_fd = -1, err; local 153 srv_fd = accept(listen_fd, NULL, NULL); 154 if (CHECK_FAIL(srv_fd == -1)) 184 if (srv_fd != -1) 185 close(srv_fd); [all...] |
H A D | bpf_nf.c | 34 static int connect_to_server(int srv_fd) argument 42 if (!ASSERT_EQ(connect_fd_to_fd(fd, srv_fd, TIMEOUT_MS), 0, "connect_fd_to_fd")) { 53 int srv_fd = -1, client_fd = -1, srv_client_fd = -1; local 76 srv_fd = start_server(AF_INET, SOCK_STREAM, "127.0.0.1", srv_port, TIMEOUT_MS); 77 if (!ASSERT_GE(srv_fd, 0, "start_server")) 80 client_fd = connect_to_server(srv_fd); 85 srv_client_fd = accept(srv_fd, (struct sockaddr *)&peer_addr, &len); 130 if (srv_fd != -1) 131 close(srv_fd);
|
H A D | ip_check_defrag.c | 175 int srv_fd = -1; local 193 srv_fd = start_server(ipv6 ? AF_INET6 : AF_INET, SOCK_DGRAM, NULL, SERVER_PORT, 0); 195 if (!ASSERT_GE(srv_fd, 0, "start_server")) 202 client_tx_fd = connect_to_fd_opts(srv_fd, &tx_ops); 211 client_rx_fd = connect_to_fd_opts(srv_fd, &rx_opts); 254 len = recvfrom(srv_fd, buf, sizeof(buf), 0, (struct sockaddr *)&caddr, &caddr_len); 257 len = sendto(srv_fd, buf, len, 0, (struct sockaddr *)&caddr, caddr_len); 271 if (srv_fd != -1) 272 close(srv_fd);
|
H A D | tcp_hdr_options.c | 36 int srv_fd; member in struct:sk_fds 69 close(sk_fds->srv_fd); 97 sk_fds->srv_fd = start_server(AF_INET6, SOCK_STREAM, LO_ADDR6, 0, 0); 98 if (!ASSERT_NEQ(sk_fds->srv_fd, -1, "start_server")) 102 sk_fds->active_fd = fastopen_connect(sk_fds->srv_fd, fast, 105 sk_fds->active_fd = connect_to_fd(sk_fds->srv_fd, 0); 108 close(sk_fds->srv_fd); 113 if (!ASSERT_OK(getsockname(sk_fds->srv_fd, (struct sockaddr *)&addr6, 114 &len), "getsockname(srv_fd)")) 124 sk_fds->passive_fd = accept(sk_fds->srv_fd, NUL [all...] |
H A D | bpf_tcp_ca.c | 258 int err, lfd = -1, cli_fd = -1, srv_fd = -1; local 287 srv_fd = accept(lfd, NULL, 0); 288 if (!ASSERT_GE(srv_fd, 0, "srv_fd")) 297 err = getsockopt(srv_fd, SOL_TCP, TCP_CONGESTION, srv_cc, &cc_len); 298 if (!ASSERT_OK(err, "getsockopt(srv_fd, TCP_CONGESTION)")) 300 ASSERT_STREQ(srv_cc, "cubic", "srv_fd cc"); 307 if (srv_fd != -1) 308 close(srv_fd);
|
H A D | tc_redirect.c | 527 int opt = 1, srv_fd = -1, cli_fd = -1, nretries = 0, err, n; local 536 srv_fd = start_server(AF_INET6, SOCK_DGRAM, "::1", 0, 0); 537 if (!ASSERT_GE(srv_fd, 0, "start_server")) 540 err = setsockopt(srv_fd, SOL_SOCKET, SO_TIMESTAMPNS_NEW, 545 cli_fd = connect_to_fd(srv_fd, TIMEOUT_MILLIS); 553 err = __rcv_tstamp(srv_fd, buf, sizeof(buf), &tstamp); 563 if (!tstamp && srv_fd != -1) { 564 close(srv_fd); 565 srv_fd = -1; 570 return srv_fd; [all...] |
H A D | select_reuseport.c | 399 int nev, srv_fd, cli_fd; local 428 srv_fd = sk_fds[ev.data.u32]; 430 int new_fd = accept(srv_fd, NULL, 0); 432 RET_IF(new_fd == -1, "accept(srv_fd)", 444 nread = recv(srv_fd, &rcv_cmd, sizeof(rcv_cmd), MSG_DONTWAIT);
|