| /linux/tools/testing/selftests/bpf/prog_tests/ |
| H A D | bpf_nf.c | 40 static int connect_to_server(int srv_fd) in connect_to_server() argument
48 if (!ASSERT_EQ(connect_fd_to_fd(fd, srv_fd, TIMEOUT_MS), 0, "connect_fd_to_fd")) { in connect_to_server()
59 int srv_fd = -1, client_fd = -1, srv_client_fd = -1; in test_bpf_nf_ct() local
87 srv_fd = start_server(AF_INET, SOCK_STREAM, "127.0.0.1", 0, TIMEOUT_MS); in test_bpf_nf_ct()
88 if (!ASSERT_GE(srv_fd, 0, "start_server")) in test_bpf_nf_ct()
91 srv_port = get_socket_local_port(srv_fd); in test_bpf_nf_ct()
95 client_fd = connect_to_server(srv_fd); in test_bpf_nf_ct()
100 srv_client_fd = accept(srv_fd, (struct sockaddr *)&peer_addr, &len); in test_bpf_nf_ct()
155 if (srv_fd != -1) in test_bpf_nf_ct()
156 close(srv_fd); in test_bpf_nf_ct()
|
| H A D | tc_change_tail_pmtu.c | 23 int srv_fd = -1, srv_conn_fd = -1, cli_fd = -1; in test_tc_change_tail_pmtu() local
53 srv_fd = start_server(AF_INET, SOCK_STREAM, SERVER_IP, 0, TIMEOUT_MS); in test_tc_change_tail_pmtu()
54 if (!ASSERT_OK_FD(srv_fd, "start server")) in test_tc_change_tail_pmtu()
63 port = get_socket_local_port(srv_fd); in test_tc_change_tail_pmtu()
80 cli_fd = connect_to_fd(srv_fd, TIMEOUT_MS); in test_tc_change_tail_pmtu()
83 srv_conn_fd = accept(srv_fd, NULL, NULL); in test_tc_change_tail_pmtu()
119 close(srv_fd); in test_tc_change_tail_pmtu()
|
| H A D | bpf_qdisc.c | 28 int srv_fd = -1, cli_fd = -1; in do_test() local
35 srv_fd = start_server(AF_INET6, SOCK_STREAM, NULL, 0, 0); in do_test()
36 if (!ASSERT_OK_FD(srv_fd, "start server")) in do_test()
39 cli_fd = connect_to_fd(srv_fd, 0); in do_test()
43 err = send_recv_data(srv_fd, cli_fd, total_bytes); in do_test()
47 if (srv_fd != -1) in do_test()
48 close(srv_fd); in do_test()
|
| H A D | bpf_tcp_ca.c | 42 int *srv_fd, int *cli_fd) in start_test() argument
44 *srv_fd = start_server_str(AF_INET6, SOCK_STREAM, addr_str, 0, srv_opts); in start_test()
45 if (!ASSERT_NEQ(*srv_fd, -1, "start_server_str")) in start_test()
49 *cli_fd = connect_to_fd_opts(*srv_fd, cli_opts); in start_test()
56 if (*srv_fd != -1) { in start_test()
57 close(*srv_fd); in start_test()
58 *srv_fd = -1; in start_test()
266 int err, lfd = -1, cli_fd = -1, srv_fd = -1; in test_dctcp_fallback() local
300 srv_fd = accept(lfd, NULL, 0); in test_dctcp_fallback()
301 if (!ASSERT_GE(srv_fd, 0, "srv_fd")) in test_dctcp_fallback()
[all …]
|
| H A D | icmp_send_kfunc.c | 116 int srv_fd = -1, client_fd = -1; in trigger_prog_read_icmp_errqueue() local
119 srv_fd = start_server(af, SOCK_STREAM, ip, 0, TIMEOUT_MS); in trigger_prog_read_icmp_errqueue()
120 if (!ASSERT_OK_FD(srv_fd, "start_server")) in trigger_prog_read_icmp_errqueue()
123 port = get_socket_local_port(srv_fd); in trigger_prog_read_icmp_errqueue()
125 close(srv_fd); in trigger_prog_read_icmp_errqueue()
135 client_fd = connect_to_fd_nonblock(srv_fd); in trigger_prog_read_icmp_errqueue()
137 close(srv_fd); in trigger_prog_read_icmp_errqueue()
145 close(srv_fd); in trigger_prog_read_icmp_errqueue()
|
| H A D | ip_check_defrag.c | 175 int srv_fd = -1; in test_bpf_ip_check_defrag_ok() local
193 srv_fd = start_server(family, SOCK_DGRAM, NULL, SERVER_PORT, 0); in test_bpf_ip_check_defrag_ok()
195 if (!ASSERT_GE(srv_fd, 0, "start_server")) in test_bpf_ip_check_defrag_ok()
254 len = recvfrom(srv_fd, buf, sizeof(buf), 0, (struct sockaddr *)&caddr, &caddr_len); in test_bpf_ip_check_defrag_ok()
257 len = sendto(srv_fd, buf, len, 0, (struct sockaddr *)&caddr, caddr_len); in test_bpf_ip_check_defrag_ok()
271 if (srv_fd != -1) in test_bpf_ip_check_defrag_ok()
272 close(srv_fd); in test_bpf_ip_check_defrag_ok()
|
| H A D | tcp_hdr_options.c | 36 int srv_fd; member
69 close(sk_fds->srv_fd); in sk_fds_close()
97 sk_fds->srv_fd = start_server(AF_INET6, SOCK_STREAM, LO_ADDR6, 0, 0); in sk_fds_connect()
98 if (!ASSERT_NEQ(sk_fds->srv_fd, -1, "start_server")) in sk_fds_connect()
102 sk_fds->active_fd = fastopen_connect(sk_fds->srv_fd, fast, in sk_fds_connect()
105 sk_fds->active_fd = connect_to_fd(sk_fds->srv_fd, 0); in sk_fds_connect()
108 close(sk_fds->srv_fd); in sk_fds_connect()
113 if (!ASSERT_OK(getsockname(sk_fds->srv_fd, (struct sockaddr *)&addr6, in sk_fds_connect()
124 sk_fds->passive_fd = accept(sk_fds->srv_fd, NULL, 0); in sk_fds_connect()
143 close(sk_fds->srv_fd); in sk_fds_connect()
|
| H A D | tc_redirect.c | 563 int opt = 1, srv_fd = -1, cli_fd = -1, nretries = 0, err, n; in wait_netstamp_needed_key() local
572 srv_fd = start_server(AF_INET6, SOCK_DGRAM, "::1", 0, 0); in wait_netstamp_needed_key()
573 if (!ASSERT_GE(srv_fd, 0, "start_server")) in wait_netstamp_needed_key()
576 err = setsockopt(srv_fd, SOL_SOCKET, SO_TIMESTAMPNS, in wait_netstamp_needed_key()
581 cli_fd = connect_to_fd(srv_fd, TIMEOUT_MILLIS); in wait_netstamp_needed_key()
589 err = __rcv_tstamp(srv_fd, buf, sizeof(buf), &tstamp); in wait_netstamp_needed_key()
599 if (!tstamp && srv_fd != -1) { in wait_netstamp_needed_key()
600 close(srv_fd); in wait_netstamp_needed_key()
601 srv_fd = -1; in wait_netstamp_needed_key()
606 return srv_fd; in wait_netstamp_needed_key()
|
| H A D | select_reuseport.c | 390 int nev, srv_fd, cli_fd; in do_test()
419 srv_fd = sk_fds[ev.data.u32]; in do_test()
421 int new_fd = accept(srv_fd, NULL, 0); in do_test()
423 RET_IF(new_fd == -1, "accept(srv_fd)", in do_test()
435 nread = recv(srv_fd, &rcv_cmd, sizeof(rcv_cmd), MSG_DONTWAIT); in do_test()
389 int nev, srv_fd, cli_fd; do_test() local
|
| /linux/tools/testing/selftests/landlock/ |
| H A D | fs_test.c | 4346 int srv_fd, cli_fd; in TEST_F_FORK() local
4350 srv_fd = set_up_named_unix_server(_metadata, SOCK_STREAM, path); in TEST_F_FORK()
4365 EXPECT_EQ(0, close(srv_fd)); in TEST_F_FORK()
4586 int cli_fd, srv_fd, res, status; in test_connect_to_parent() local
4638 srv_fd = set_up_named_unix_server(_metadata, sock_type, path); in test_connect_to_parent()
4651 EXPECT_EQ(0, close(srv_fd)); in test_connect_to_parent()
4670 int cli_fd, srv_fd, res, status; in test_connect_to_child() local
4694 srv_fd = set_up_named_unix_server(_metadata, sock_type, path); in test_connect_to_child()
4708 EXPECT_EQ(0, close(srv_fd)); in test_connect_to_child()
4913 int srv_fd, conn_fd, status; in TEST_F_FORK() local
[all …]
|