// SPDX-License-Identifier: GPL-2.0 /* Copyright (c) 2023 Isovalent */ #include <uapi/linux/if_link.h>#include <net/if .h>#include <test_progs.h>#define netkit_peer "nk0" #define netkit_name "nk1" #define ping_addr_neigh 0x0a000002 /* 10.0.0.2 */ #define ping_addr_noneigh 0x0a000003 /* 10.0.0.3 */ #include "test_tc_link.skel.h" #include "netlink_helpers.h" #include "tc_helpers.h" #define NETKIT_HEADROOM 32#define NETKIT_TAILROOM 8#define MARK 42#define PRIO 0xeb9f#define ICMP_ECHO 8#define FLAG_ADJUST_ROOM (1 << 0)#define FLAG_SAME_NETNS (1 << 1)struct icmphdr {struct {struct iplink_req {struct nlmsghdr n;struct ifinfomsg i;char buf[1024];static int create_netkit(int mode, int policy, int peer_policy, int *ifindex,int scrub, int peer_scrub, __u32 flags)struct rtnl_handle rth = { .fd = -1 };struct iplink_req req = {};struct rtattr *linkinfo, *data;const char *type = "netkit" ;int err;if (!ASSERT_OK(err, "open_rtnetlink" ))return err;sizeof (req));sizeof (struct ifinfomsg));sizeof (req), IFLA_IFNAME, netkit_name,sizeof (req), IFLA_LINKINFO);sizeof (req), IFLA_INFO_KIND, type, strlen(type));sizeof (req), IFLA_INFO_DATA);sizeof (req), IFLA_NETKIT_POLICY, policy);sizeof (req), IFLA_NETKIT_PEER_POLICY, peer_policy);sizeof (req), IFLA_NETKIT_SCRUB, scrub);sizeof (req), IFLA_NETKIT_PEER_SCRUB, peer_scrub);sizeof (req), IFLA_NETKIT_MODE, mode);if (flags & FLAG_ADJUST_ROOM) {sizeof (req), IFLA_NETKIT_HEADROOM, NETKIT_HEADROOM);sizeof (req), IFLA_NETKIT_TAILROOM, NETKIT_TAILROOM);"talk_rtnetlink" );"retrieve_ifindex" );"ip netns add foo" ), "create netns" );"ip link set dev " netkit_name " up" ),"up primary" );"ip addr add dev " netkit_name " 10.0.0.1/24" ),"addr primary" );if (mode == NETKIT_L3) {"ip link set dev " netkit_name" addr ee:ff:bb:cc:aa:dd 2> /dev/null" ), 512,"set hwaddress" );else {"ip link set dev " netkit_name" addr ee:ff:bb:cc:aa:dd" ),"set hwaddress" );if (flags & FLAG_SAME_NETNS) {"ip link set dev " netkit_peer " up" ),"up peer" );"ip addr add dev " netkit_peer " 10.0.0.2/24" ),"addr peer" );else {"ip link set " netkit_peer " netns foo" ),"move peer" );"ip netns exec foo ip link set dev " " up" ), "up peer" );"ip netns exec foo ip addr add dev " " 10.0.0.2/24" ), "addr peer" );return err;static void move_netkit(void )"ip link set " netkit_peer " netns foo" ),"move peer" );"ip netns exec foo ip link set dev " " up" ), "up peer" );"ip netns exec foo ip addr add dev " " 10.0.0.2/24" ), "addr peer" );static void destroy_netkit(void )"ip link del dev " netkit_name), "del primary" );"ip netns del foo" ), "delete netns" );"_ifindex" );static int __send_icmp(__u32 dest)int sock, ret, mark = MARK, prio = PRIO;struct sockaddr_in addr;struct icmphdr icmp;"/proc/sys/net/ipv4/ping_group_range" , "0 0" );if (!ASSERT_OK(ret, "write_sysctl(net.ipv4.ping_group_range)" ))return ret;if (!ASSERT_GE(sock, 0, "icmp_socket" ))return -errno;if (!ASSERT_OK(ret, "setsockopt(SO_BINDTODEVICE)" ))goto out;sizeof (mark));if (!ASSERT_OK(ret, "setsockopt(SO_MARK)" ))goto out;sizeof (prio));if (!ASSERT_OK(ret, "setsockopt(SO_PRIORITY)" ))goto out;sizeof (addr));sizeof (icmp));sizeof (icmp), 0,struct sockaddr *)&addr, sizeof (addr));if (!ASSERT_GE(ret, 0, "icmp_sendto" ))else return ret;static int send_icmp(void )return __send_icmp(ping_addr_neigh);void serial_test_tc_netkit_basic(void )struct test_tc_link *skel;struct bpf_link *link;int err, ifindex;if (err)return ;if (!ASSERT_OK_PTR(skel, "skel_open" ))goto cleanup;"tc1_attach_type" );"tc2_attach_type" );if (!ASSERT_OK(err, "skel_load" ))goto cleanup;"prog_ids_1_2" );false , "seen_tc1" );false , "seen_tc2" );if (!ASSERT_OK_PTR(link, "link_attach" ))goto cleanup;sizeof (prog_ids));sizeof (link_ids));if (!ASSERT_OK(err, "prog_query" ))goto cleanup;"count" );"revision" );"prog_ids[0]" );"link_ids[0]" );"prog_ids[1]" );"link_ids[1]" );"icmp_pkt" );true , "seen_tc1" );false , "seen_tc2" );if (!ASSERT_OK_PTR(link, "link_attach" ))goto cleanup;"link_ids_1_2" );sizeof (prog_ids));sizeof (link_ids));if (!ASSERT_OK(err, "prog_query" ))goto cleanup;"count" );"revision" );"prog_ids[0]" );"link_ids[0]" );"prog_ids[1]" );"link_ids[1]" );"icmp_pkt" );true , "seen_tc1" );true , "seen_tc2" );static void serial_test_tc_netkit_multi_links_target(int mode, int target)struct test_tc_link *skel;struct bpf_link *link;int err, ifindex;if (err)return ;if (!ASSERT_OK_PTR(skel, "skel_open" ))goto cleanup;"tc1_attach_type" );"tc2_attach_type" );if (!ASSERT_OK(err, "skel_load" ))goto cleanup;"prog_ids_1_2" );false , "seen_tc1" );false , "seen_eth" );false , "seen_tc2" );if (!ASSERT_OK_PTR(link, "link_attach" ))goto cleanup;sizeof (prog_ids));sizeof (link_ids));if (!ASSERT_OK(err, "prog_query" ))goto cleanup;"count" );"revision" );"prog_ids[0]" );"link_ids[0]" );"prog_ids[1]" );"link_ids[1]" );"icmp_pkt" );true , "seen_tc1" );true , "seen_eth" );false , "seen_tc2" );if (!ASSERT_OK_PTR(link, "link_attach" ))goto cleanup;"link_ids_1_2" );sizeof (prog_ids));sizeof (link_ids));if (!ASSERT_OK(err, "prog_query" ))goto cleanup;"count" );"revision" );"prog_ids[0]" );"link_ids[0]" );"prog_ids[1]" );"link_ids[1]" );"prog_ids[2]" );"link_ids[2]" );"icmp_pkt" );true , "seen_tc1" );true , "seen_eth" );true , "seen_tc2" );void serial_test_tc_netkit_multi_links(void )static void serial_test_tc_netkit_multi_opts_target(int mode, int target)struct test_tc_link *skel;int err, ifindex;if (err)return ;if (!ASSERT_OK_PTR(skel, "skel_load" ))goto cleanup;"prog_ids_1_2" );false , "seen_tc1" );false , "seen_eth" );false , "seen_tc2" );if (!ASSERT_EQ(err, 0, "prog_attach" ))goto cleanup;sizeof (prog_ids));if (!ASSERT_OK(err, "prog_query" ))goto cleanup_fd1;"count" );"revision" );"prog_ids[0]" );"prog_ids[1]" );"icmp_pkt" );true , "seen_tc1" );true , "seen_eth" );false , "seen_tc2" );if (!ASSERT_EQ(err, 0, "prog_attach" ))goto cleanup_fd1;sizeof (prog_ids));if (!ASSERT_OK(err, "prog_query" ))goto cleanup_fd2;"count" );"revision" );"prog_ids[0]" );"prog_ids[1]" );"prog_ids[2]" );"icmp_pkt" );true , "seen_tc1" );true , "seen_eth" );true , "seen_tc2" );"prog_detach" );"prog_detach" );void serial_test_tc_netkit_multi_opts(void )void serial_test_tc_netkit_device(void )struct test_tc_link *skel;struct bpf_link *link;int err, ifindex, ifindex2;if (err)return ;"ifindex_1_2" );if (!ASSERT_OK_PTR(skel, "skel_open" ))goto cleanup;"tc1_attach_type" );"tc2_attach_type" );"tc3_attach_type" );if (!ASSERT_OK(err, "skel_load" ))goto cleanup;"prog_ids_1_2" );false , "seen_tc1" );false , "seen_tc2" );if (!ASSERT_OK_PTR(link, "link_attach" ))goto cleanup;sizeof (prog_ids));sizeof (link_ids));if (!ASSERT_OK(err, "prog_query" ))goto cleanup;"count" );"revision" );"prog_ids[0]" );"link_ids[0]" );"prog_ids[1]" );"link_ids[1]" );"icmp_pkt" );true , "seen_tc1" );false , "seen_tc2" );sizeof (prog_ids));sizeof (link_ids));"prog_query_should_fail" );"prog_query_should_fail" );if (!ASSERT_ERR_PTR(link, "link_attach_should_fail" )) {goto cleanup;if (!ASSERT_ERR_PTR(link, "link_attach_should_fail" )) {goto cleanup;static void serial_test_tc_netkit_neigh_links_target(int mode, int target)struct test_tc_link *skel;struct bpf_link *link;int err, ifindex;if (err)return ;if (!ASSERT_OK_PTR(skel, "skel_open" ))goto cleanup;"tc1_attach_type" );if (!ASSERT_OK(err, "skel_load" ))goto cleanup;false , "seen_tc1" );false , "seen_eth" );if (!ASSERT_OK_PTR(link, "link_attach" ))goto cleanup;sizeof (prog_ids));sizeof (link_ids));if (!ASSERT_OK(err, "prog_query" ))goto cleanup;"count" );"revision" );"prog_ids[0]" );"link_ids[0]" );"prog_ids[1]" );"link_ids[1]" );"icmp_pkt" );true /* L2: ARP */, "seen_tc1"); "seen_eth" );void serial_test_tc_netkit_neigh_links(void )static void serial_test_tc_netkit_pkt_type_mode(int mode)int err, ifindex, ifindex2;struct test_tc_link *skel;struct bpf_link *link;if (err)return ;"ifindex_1_2" );if (!ASSERT_OK_PTR(skel, "skel_open" ))goto cleanup;"tc1_attach_type" );"tc7_attach_type" );if (!ASSERT_OK(err, "skel_load" ))goto cleanup;if (!ASSERT_OK_PTR(link, "link_attach" ))goto cleanup;if (!ASSERT_OK_PTR(link, "link_attach" ))goto cleanup;true ;"icmp_pkt" );true , "seen_tc1" );true , "seen_tc7" );true , "seen_host" );true , "seen_mcast" );void serial_test_tc_netkit_pkt_type(void )static void serial_test_tc_netkit_scrub_type(int scrub, bool room)struct test_tc_link *skel;struct bpf_link *link;int err, ifindex;if (err)return ;if (!ASSERT_OK_PTR(skel, "skel_open" ))goto cleanup;"tc8_attach_type" );if (!ASSERT_OK(err, "skel_load" ))goto cleanup;false , "seen_tc8" );if (!ASSERT_OK_PTR(link, "link_attach" ))goto cleanup;"icmp_pkt" );true , "seen_tc8" );"mark" );"prio" );"headroom" );"tailroom" );void serial_test_tc_netkit_scrub(void )false );true );
Messung V0.5 C=98 H=75 G=87
¤ Dauer der Verarbeitung: 0.9 Sekunden
¤ *© Formatika GbR, Deutschland
