bpf/prog_tests/sockmap_listen.c

734 	int sock_map = bpf_map__fd(inner_map);
737 	err = xbpf_prog_attach(parser, sock_map, BPF_SK_SKB_STREAM_PARSER, 0);
740 	err = xbpf_prog_attach(verdict, sock_map, BPF_SK_SKB_STREAM_VERDICT, 0);
744 	redir_to_connected(family, sotype, sock_map, verdict_map,
747 	xbpf_prog_detach2(verdict, sock_map, BPF_SK_SKB_STREAM_VERDICT);
749 	xbpf_prog_detach2(parser, sock_map, BPF_SK_SKB_STREAM_PARSER);
758 	int sock_map = bpf_map__fd(inner_map);
761 	err = xbpf_prog_attach(verdict, sock_map, BPF_SK_MSG_VERDICT, 0);
765 	redir_to_connected(family, sotype, sock_map, verdict_map, REDIR_EGRESS);
767 	xbpf_prog_detach2(verdict, sock_map, BPF_SK_MSG_VERDICT);
836 	int sock_map = bpf_map__fd(inner_map);
839 	err = xbpf_prog_attach(parser, sock_map, BPF_SK_SKB_STREAM_PARSER, 0);
842 	err = xbpf_prog_attach(verdict, sock_map, BPF_SK_SKB_STREAM_VERDICT, 0);
846 	redir_to_listening(family, sotype, sock_map, verdict_map,
849 	xbpf_prog_detach2(verdict, sock_map, BPF_SK_SKB_STREAM_VERDICT);
851 	xbpf_prog_detach2(parser, sock_map, BPF_SK_SKB_STREAM_PARSER);
860 	int sock_map = bpf_map__fd(inner_map);
863 	err = xbpf_prog_attach(verdict, sock_map, BPF_SK_MSG_VERDICT, 0);
867 	redir_to_listening(family, sotype, sock_map, verdict_map, REDIR_EGRESS);
869 	xbpf_prog_detach2(verdict, sock_map, BPF_SK_MSG_VERDICT);
872 static void redir_partial(int family, int sotype, int sock_map, int parser_map)
892 	err = add_to_sockmap(sock_map, p0, p1);
925 	int sock_map = bpf_map__fd(inner_map);
928 	err = xbpf_prog_attach(parser, sock_map, BPF_SK_SKB_STREAM_PARSER, 0);
932 	err = xbpf_prog_attach(verdict, sock_map, BPF_SK_SKB_STREAM_VERDICT, 0);
936 	redir_partial(family, sotype, sock_map, parser_map);
938 	xbpf_prog_detach2(verdict, sock_map, BPF_SK_SKB_STREAM_VERDICT);
940 	xbpf_prog_detach2(parser, sock_map, BPF_SK_SKB_STREAM_PARSER);
944 					    int sock_map, int verd_map,
968 	err = xbpf_map_update_elem(sock_map, &key, &value, BPF_NOEXIST);
1013 					    int sock_map, int verd_map,
1029 	/* Populate sock_map[0] to avoid ENOENT on first connection */
1032 	err = xbpf_map_update_elem(sock_map, &key, &value, BPF_NOEXIST);
1068 	/* Update sock_map[0] to redirect to a connected socket */
1071 	err = xbpf_map_update_elem(sock_map, &key, &value, BPF_EXIST);
1118 static void test_reuseport_mixed_groups(int family, int sotype, int sock_map,
1138 	err = add_to_sockmap(sock_map, s1, s2);
1142 	/* Connect to s2, reuseport BPF selects s1 via sock_map[0] */
1411 	int sock_map = bpf_map__fd(inner_map);
1414 	err = xbpf_prog_attach(verdict, sock_map, BPF_SK_SKB_VERDICT, 0);
1419 	unix_redir_to_connected(sotype, sock_map, verdict_map, REDIR_EGRESS);
1421 	unix_redir_to_connected(sotype, sock_map, verdict_map, REDIR_INGRESS);
1423 	xbpf_prog_detach2(verdict, sock_map, BPF_SK_SKB_VERDICT);
1562 	int sock_map = bpf_map__fd(inner_map);
1565 	err = xbpf_prog_attach(verdict, sock_map, BPF_SK_SKB_VERDICT, 0);
1570 	vsock_unix_redir_connectible(sock_map, verdict_map, REDIR_EGRESS, sotype);
1572 	vsock_unix_redir_connectible(sock_map, verdict_map, REDIR_INGRESS, sotype);
1574 	xbpf_prog_detach2(verdict, sock_map, BPF_SK_SKB_VERDICT);
1701 	int sock_map = bpf_map__fd(inner_map);
1704 	err = xbpf_prog_attach(verdict, sock_map, BPF_SK_SKB_VERDICT, 0);
1709 	udp_redir_to_connected(family, sock_map, verdict_map, REDIR_EGRESS);
1711 	udp_redir_to_connected(family, sock_map, verdict_map, REDIR_INGRESS);
1713 	xbpf_prog_detach2(verdict, sock_map, BPF_SK_SKB_VERDICT);
1759 	int sock_map = bpf_map__fd(inner_map);
1762 	err = xbpf_prog_attach(verdict, sock_map, BPF_SK_SKB_VERDICT, 0);
1767 	inet_unix_redir_to_connected(family, SOCK_DGRAM, sock_map, verdict_map,
1769 	inet_unix_redir_to_connected(family, SOCK_STREAM, sock_map, verdict_map,
1772 	inet_unix_redir_to_connected(family, SOCK_DGRAM, sock_map, verdict_map,
1774 	inet_unix_redir_to_connected(family, SOCK_STREAM, sock_map, verdict_map,
1777 	xbpf_prog_detach2(verdict, sock_map, BPF_SK_SKB_VERDICT);
1814 	int sock_map = bpf_map__fd(inner_map);
1817 	err = xbpf_prog_attach(verdict, sock_map, BPF_SK_SKB_VERDICT, 0);
1823 				     sock_map, -1, verdict_map,
1826 				     sock_map, -1, verdict_map,
1830 				     sock_map, nop_map, verdict_map,
1833 				     sock_map, nop_map, verdict_map,
1837 				     sock_map, -1, verdict_map,
1840 				     sock_map, -1, verdict_map,
1844 				     sock_map, nop_map, verdict_map,
1847 				     sock_map, nop_map, verdict_map,
1850 	xbpf_prog_detach2(verdict, sock_map, BPF_SK_SKB_VERDICT);
1891 	run_tests(skel, skel->maps.sock_map, AF_INET);
1892 	run_tests(skel, skel->maps.sock_map, AF_INET6);
1893 	test_unix_redir(skel, skel->maps.sock_map, SOCK_DGRAM);
1894 	test_unix_redir(skel, skel->maps.sock_map, SOCK_STREAM);
1895 	test_vsock_redir(skel, skel->maps.sock_map);