Home
last modified time | relevance | path

Searched refs:sock_fd (Results 1 – 25 of 25) sorted by relevance

/tools/testing/selftests/net/
A Dbind_bhash.c33 int sock_fd, reuse = 1, err; in bind_socket() local
37 if (sock_fd < 0) { in bind_socket()
39 return sock_fd; in bind_socket()
65 return sock_fd; in bind_socket()
68 close(sock_fd); in bind_socket()
74 int sock_fd, i; in setup() local
79 if (sock_fd < 0) { in setup()
80 ret = sock_fd; in setup()
83 array[i] = sock_fd; in setup()
126 if (sock_fd < 0) in main()
[all …]
/tools/testing/selftests/bpf/prog_tests/
A Dsockopt_qos_to_cc.c7 static void run_setsockopt_test(int cg_fd, int sock_fd) in run_setsockopt_test() argument
15 err = setsockopt(sock_fd, SOL_IPV6, IPV6_TCLASS, &buf, sizeof(buf)); in run_setsockopt_test()
21 err = getsockopt(sock_fd, SOL_TCP, TCP_CONGESTION, cc, &optlen); in run_setsockopt_test()
34 int sock_fd = -1; in test_sockopt_qos_to_cc() local
47 sock_fd = socket(AF_INET6, SOCK_STREAM, 0); in test_sockopt_qos_to_cc()
48 if (!ASSERT_GE(sock_fd, 0, "v6 socket open")) in test_sockopt_qos_to_cc()
51 err = setsockopt(sock_fd, SOL_TCP, TCP_CONGESTION, &cc_cubic, in test_sockopt_qos_to_cc()
63 run_setsockopt_test(cg_fd, sock_fd); in test_sockopt_qos_to_cc()
66 if (sock_fd != -1) in test_sockopt_qos_to_cc()
67 close(sock_fd); in test_sockopt_qos_to_cc()
A Dsockopt_multi.c8 int cg_child, int sock_fd) in run_getsockopt_test() argument
19 err = setsockopt(sock_fd, SOL_IP, IP_TOS, &buf, 1); in run_getsockopt_test()
95 err = setsockopt(sock_fd, SOL_IP, IP_TOS, &buf, 1); in run_getsockopt_test()
131 err = setsockopt(sock_fd, SOL_IP, IP_TOS, &buf, 1); in run_getsockopt_test()
159 int cg_child, int sock_fd) in run_setsockopt_test() argument
170 err = setsockopt(sock_fd, SOL_IP, IP_TOS, &buf, 1); in run_setsockopt_test()
198 err = setsockopt(sock_fd, SOL_IP, IP_TOS, &buf, 1); in run_setsockopt_test()
257 int sock_fd = -1; in test_sockopt_multi() local
273 sock_fd = socket(AF_INET, SOCK_STREAM, 0); in test_sockopt_multi()
274 if (!ASSERT_GE(sock_fd, 0, "socket")) in test_sockopt_multi()
[all …]
A Dcgroup_getset_retval.c19 static void test_setsockopt_set(int cgroup_fd, int sock_fd) in test_setsockopt_set() argument
436 if (!ASSERT_OK(getsockopt(sock_fd, SOL_CUSTOM, 0, in test_getsockopt_retval_sync()
504 int sock_fd = -1; in test_cgroup_getset_retval() local
511 if (!ASSERT_GE(sock_fd, 0, "start-server")) in test_cgroup_getset_retval()
515 test_setsockopt_set(cgroup_fd, sock_fd); in test_cgroup_getset_retval()
518 test_setsockopt_set_and_get(cgroup_fd, sock_fd); in test_cgroup_getset_retval()
527 test_setsockopt_override(cgroup_fd, sock_fd); in test_cgroup_getset_retval()
536 test_getsockopt_get(cgroup_fd, sock_fd); in test_cgroup_getset_retval()
539 test_getsockopt_override(cgroup_fd, sock_fd); in test_cgroup_getset_retval()
542 test_getsockopt_retval_sync(cgroup_fd, sock_fd); in test_cgroup_getset_retval()
[all …]
A Dcgroup_mprog_ordering.c7 static int run_getsockopt_test(int cg_parent, int sock_fd, bool has_relative_fd) in run_getsockopt_test() argument
41 err = getsockopt(sock_fd, SOL_IP, IP_TOS, &buf, &optlen); in run_getsockopt_test()
61 int cg_parent = -1, sock_fd = -1; in test_cgroup_mprog_ordering() local
67 sock_fd = socket(AF_INET, SOCK_STREAM, 0); in test_cgroup_mprog_ordering()
68 if (!ASSERT_GE(sock_fd, 0, "socket")) in test_cgroup_mprog_ordering()
71 ASSERT_OK(run_getsockopt_test(cg_parent, sock_fd, false), "getsockopt_test_1"); in test_cgroup_mprog_ordering()
72 ASSERT_OK(run_getsockopt_test(cg_parent, sock_fd, true), "getsockopt_test_2"); in test_cgroup_mprog_ordering()
75 close(sock_fd); in test_cgroup_mprog_ordering()
A Dcgroup_preorder.c7 static int run_getsockopt_test(int cg_parent, int cg_child, int sock_fd, bool all_preorder) in run_getsockopt_test() argument
23 err = setsockopt(sock_fd, SOL_IP, IP_TOS, &buf, 1); in run_getsockopt_test()
46 err = getsockopt(sock_fd, SOL_IP, IP_TOS, &buf, &optlen); in run_getsockopt_test()
77 err = getsockopt(sock_fd, SOL_IP, IP_TOS, &buf, &optlen); in run_getsockopt_test()
107 int cg_parent = -1, cg_child = -1, sock_fd = -1; in test_cgroup_preorder() local
117 sock_fd = socket(AF_INET, SOCK_STREAM, 0); in test_cgroup_preorder()
118 if (!ASSERT_GE(sock_fd, 0, "socket")) in test_cgroup_preorder()
121 ASSERT_OK(run_getsockopt_test(cg_parent, cg_child, sock_fd, false), "getsockopt_test_1"); in test_cgroup_preorder()
122 ASSERT_OK(run_getsockopt_test(cg_parent, cg_child, sock_fd, true), "getsockopt_test_2"); in test_cgroup_preorder()
125 close(sock_fd); in test_cgroup_preorder()
A Dprobe_user.c16 int err, results_map_fd, sock_fd, duration = 0; in serial_test_probe_user() local
58 sock_fd = socket(AF_INET, SOCK_STREAM, 0); in serial_test_probe_user()
59 if (CHECK(sock_fd < 0, "create_sock_fd", "err %d\n", sock_fd)) in serial_test_probe_user()
62 connect(sock_fd, &curr, sizeof(curr)); in serial_test_probe_user()
63 close(sock_fd); in serial_test_probe_user()
A Dconnect_ping.c34 int sock_fd; in subtest() local
52 sock_fd = socket(family, SOCK_DGRAM, protocol); in subtest()
53 if (!ASSERT_GE(sock_fd, 0, "sock-create")) in subtest()
56 if (!ASSERT_OK(connect(sock_fd, sa, sa_len), "connect")) in subtest()
68 if (!ASSERT_OK(getsockname(sock_fd, sa, &sa_len), in subtest()
93 close(sock_fd); in subtest()
A Dsock_create.c282 int sock_fd, err, prog_fd, optval, ret = -1; in run_test() local
297 sock_fd = socket(test->domain, test->type, test->protocol); in run_test()
298 if (sock_fd < 0) { in run_test()
308 err = getsockopt(sock_fd, SOL_SOCKET, test->optname, &optval, &optlen); in run_test()
324 close(sock_fd); in run_test()
A Dxdp_metadata.c207 int sock_fd, err = 0; in generate_packet_inet() local
215 sock_fd = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP); in generate_packet_inet()
216 if (!ASSERT_GE(sock_fd, 0, "socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)")) in generate_packet_inet()
217 return sock_fd; in generate_packet_inet()
219 err = sendto(sock_fd, udp_payload, UDP_PAYLOAD_BYTES, MSG_DONTWAIT, in generate_packet_inet()
223 close(sock_fd); in generate_packet_inet()
364 int sock_fd; in test_xdp_metadata() local
454 sock_fd = xsk_socket__fd(rx_xsk.socket); in test_xdp_metadata()
455 ret = bpf_map_update_elem(bpf_map__fd(bpf_obj->maps.xsk), &queue_id, &sock_fd, 0); in test_xdp_metadata()
A Dbpf_iter.c1199 int sock_fd = -1; in test_bpf_sk_storage_delete() local
1210 if (!ASSERT_GE(sock_fd, 0, "socket")) in test_bpf_sk_storage_delete()
1252 if (sock_fd >= 0) in test_bpf_sk_storage_delete()
1253 close(sock_fd); in test_bpf_sk_storage_delete()
1267 int sock_fd = -1; in test_bpf_sk_storage_get() local
1277 err = listen(sock_fd, 1); in test_bpf_sk_storage_get()
1301 close(sock_fd); in test_bpf_sk_storage_get()
1326 int sock_fd[3] = {-1, -1, -1}; in test_bpf_sk_storage_map() local
1336 num_sockets = ARRAY_SIZE(sock_fd); in test_bpf_sk_storage_map()
1398 if (sock_fd[i] >= 0) in test_bpf_sk_storage_map()
[all …]
A Dsockmap_basic.c290 __s64 *sock_fd = NULL; in test_sockmap_copy() local
309 sock_fd = calloc(num_sockets, sizeof(*sock_fd)); in test_sockmap_copy()
310 if (!ASSERT_OK_PTR(sock_fd, "calloc(sock_fd)")) in test_sockmap_copy()
314 sock_fd[i] = -1; in test_sockmap_copy()
319 sock_fd[i] = connected_socket_v4(); in test_sockmap_copy()
320 if (!ASSERT_NEQ(sock_fd[i], -1, "connected_socket_v4")) in test_sockmap_copy()
359 for (i = 0; sock_fd && i < num_sockets; i++) in test_sockmap_copy()
360 if (sock_fd[i] >= 0) in test_sockmap_copy()
361 close(sock_fd[i]); in test_sockmap_copy()
362 if (sock_fd) in test_sockmap_copy()
[all …]
A Dtoken.c281 static void child(int sock_fd, struct bpffs_opts *opts, child_callback_fn callback) in child() argument
329 err = sendfd(sock_fd, fs_fd); in child()
336 err = read(sock_fd, &one, sizeof(one)); in child()
389 err = sendfd(sock_fd, token_fd); in child()
401 zclose(sock_fd); in child()
432 static void parent(int child_pid, struct bpffs_opts *bpffs_opts, int sock_fd) in parent() argument
437 err = recvfd(sock_fd, &fs_fd); in parent()
448 err = write(sock_fd, &one, sizeof(one)); in parent()
454 err = recvfd(sock_fd, &token_fd); in parent()
462 zclose(sock_fd); in parent()
A Dassign_reuse.c16 static int attach_reuseport(int sock_fd, int prog_fd) in attach_reuseport() argument
18 return setsockopt(sock_fd, SOL_SOCKET, SO_ATTACH_REUSEPORT_EBPF, in attach_reuseport()
A Dsocket_helpers.h413 static inline const char *socket_kind_to_str(int sock_fd) in socket_kind_to_str() argument
419 if (getsockopt(sock_fd, SOL_SOCKET, SO_DOMAIN, &domain, &opt_len)) in socket_kind_to_str()
423 if (getsockopt(sock_fd, SOL_SOCKET, SO_TYPE, &type, &opt_len)) in socket_kind_to_str()
A Dsockopt.c1075 int sock_fd, err, prog_fd, link_fd = -1; in run_test() local
1106 sock_fd = socket(AF_INET, SOCK_STREAM, 0); in run_test()
1107 if (sock_fd < 0) { in run_test()
1121 err = call_setsockopt(use_io_uring, sock_fd, test->set_level, in run_test()
1150 err = call_getsockopt(use_io_uring, sock_fd, test->get_level, in run_test()
1185 close(sock_fd); in run_test()
A Dsk_lookup.c90 static int attach_reuseport(int sock_fd, struct bpf_program *reuseport_prog) in attach_reuseport() argument
100 err = setsockopt(sock_fd, SOL_SOCKET, SO_ATTACH_REUSEPORT_EBPF, in attach_reuseport()
433 static int update_lookup_map(struct bpf_map *map, int index, int sock_fd) in update_lookup_map() argument
445 value = (uint64_t)sock_fd; in update_lookup_map()
/tools/testing/selftests/net/lib/
A Dxdp_helper.c43 int sock_fd; in main() local
51 sock_fd = socket(AF_XDP, SOCK_RAW, 0); in main()
52 if (sock_fd < 0) { in main()
65 close(sock_fd); in main()
84 setsockopt(sock_fd, SOL_XDP, XDP_UMEM_REG, &umem_reg, in main()
86 setsockopt(sock_fd, SOL_XDP, XDP_UMEM_FILL_RING, &num_desc, in main()
88 setsockopt(sock_fd, SOL_XDP, XDP_UMEM_COMPLETION_RING, &num_desc, in main()
90 setsockopt(sock_fd, SOL_XDP, XDP_RX_RING, &num_desc, sizeof(num_desc)); in main()
107 if (bind(sock_fd, (struct sockaddr *)&sxdp, sizeof(sxdp)) == 0) in main()
117 close(sock_fd); in main()
[all …]
/tools/testing/selftests/landlock/
A Dnet_test.c194 ret = bind(sock_fd, &srv->ipv4_addr, addrlen); in bind_variant_addrlen()
215 static int bind_variant(const int sock_fd, in bind_variant() argument
251 static int connect_variant(const int sock_fd, in connect_variant() argument
1954 int ruleset_fd, sock_fd; in TEST_F() local
1962 sock_fd = socket_variant(&self->srv0); in TEST_F()
1963 ASSERT_LE(0, sock_fd); in TEST_F()
1972 EXPECT_EQ(0, close(sock_fd)); in TEST_F()
1982 int ruleset_fd, sock_fd; in TEST_F() local
1990 sock_fd = socket_variant(&self->srv0); in TEST_F()
1991 ASSERT_LE(0, sock_fd); in TEST_F()
[all …]
/tools/testing/selftests/bpf/
A Dtest_progs.c1419 int sock_fd; member
1424 if (recv_message(sock_fd, msg) < 0) in read_prog_test_msg()
1447 if (read_prog_test_msg(sock_fd, &msg, MSG_TEST_LOG)) { in dispatch_thread_read_log()
1486 if (dispatch_thread_read_log(sock_fd, in dispatch_thread_send_subtests()
1498 int sock_fd; in dispatch_thread() local
1500 sock_fd = data->sock_fd; in dispatch_thread()
1533 if (send_message(sock_fd, &msg_do_test) < 0) { in dispatch_thread()
1558 if (dispatch_thread_read_log(sock_fd, in dispatch_thread()
1568 if (dispatch_thread_send_subtests(sock_fd, state)) in dispatch_thread()
1585 if (send_message(sock_fd, &msg_exit) < 0) { in dispatch_thread()
[all …]
A Dnetwork_helpers.h86 int get_socket_local_port(int sock_fd);
A Dxdp_hw_metadata.c865 int sock_fd = xsk_socket__fd(rx_xsk[i].socket); in main() local
868 printf("map[%d] = %d\n", queue_id, sock_fd); in main()
869 ret = bpf_map_update_elem(bpf_map__fd(bpf_obj->maps.xsk), &queue_id, &sock_fd, 0); in main()
A Dxsk.c450 int map_fd, sock_fd; in xsk_update_xskmap() local
453 sock_fd = xsk_socket__fd(xsk); in xsk_update_xskmap()
455 return bpf_map_update_elem(map_fd, &index, &sock_fd, 0); in xsk_update_xskmap()
A Dnetwork_helpers.c596 int get_socket_local_port(int sock_fd) in get_socket_local_port() argument
602 err = getsockname(sock_fd, (struct sockaddr *)&addr, &addrlen); in get_socket_local_port()
/tools/perf/
A Dbuiltin-daemon.c810 static int handle_server_socket(struct daemon *daemon, int sock_fd) in handle_server_socket() argument
816 fd = accept(sock_fd, NULL, NULL); in handle_server_socket()
1256 int sock_fd = -1, conf_fd = -1, signal_fd = -1; in __cmd_start() local
1296 sock_fd = setup_server_socket(daemon); in __cmd_start()
1297 if (sock_fd < 0) in __cmd_start()
1308 sock_pos = fdarray__add(&fda, sock_fd, POLLIN|POLLERR|POLLHUP, 0); in __cmd_start()
1331 err = handle_server_socket(daemon, sock_fd); in __cmd_start()
1348 if (sock_fd != -1) in __cmd_start()
1349 close(sock_fd); in __cmd_start()

Completed in 46 milliseconds