14 def _test_v4(cfg) -> None:  argument
15     if not cfg.addr_v["4"]:
18     cmd("ping -c 1 -W0.5 " + cfg.remote_addr_v["4"])
19     cmd("ping -c 1 -W0.5 " + cfg.addr_v["4"], host=cfg.remote)
20     cmd("ping -s 65000 -c 1 -W0.5 " + cfg.remote_addr_v["4"])
21     cmd("ping -s 65000 -c 1 -W0.5 " + cfg.addr_v["4"], host=cfg.remote)
23 def _test_v6(cfg) -> None:  argument
24     if not cfg.addr_v["6"]:
27     cmd("ping -c 1 -W5 " + cfg.remote_addr_v["6"])
28     cmd("ping -c 1 -W5 " + cfg.addr_v["6"], host=cfg.remote)
29     cmd("ping -s 65000 -c 1 -W0.5 " + cfg.remote_addr_v["6"])
30     cmd("ping -s 65000 -c 1 -W0.5 " + cfg.addr_v["6"], host=cfg.remote)
32 def _test_tcp(cfg) -> None:  argument
33     cfg.require_cmd("socat", remote=True)
36     listen_cmd = f"socat -{cfg.addr_ipver} -t 2 -u TCP-LISTEN:{port},reuseport STDOUT"
42         cmd(f"echo {test_string} | socat -t 2 -u STDIN TCP:{cfg.baddr}:{port}",
43             shell=True, host=cfg.remote)
47     with bkg(listen_cmd, host=cfg.remote, exit_wait=True) as nc:
48         wait_port_listen(port, host=cfg.remote)
50         cmd(f"echo {test_string} | socat -t 2 -u STDIN TCP:{cfg.remote_baddr}:{port}", shell=True)
53 def _set_offload_checksum(cfg, netnl, on) -> None:  argument
55         ethtool(f" -K {cfg.ifname} rx {on} tx {on} ")
59 def _set_xdp_generic_sb_on(cfg) -> None:  argument
60     prog = cfg.net_lib_dir / "xdp_dummy.bpf.o"
61     cmd(f"ip link set dev {cfg.remote_ifname} mtu 1500", shell=True, host=cfg.remote)
62     cmd(f"ip link set dev {cfg.ifname} mtu 1500 xdpgeneric obj {prog} sec xdp", shell=True)
63     defer(cmd, f"ip link set dev {cfg.ifname} xdpgeneric off")
68 def _set_xdp_generic_mb_on(cfg) -> None:  argument
69     prog = cfg.net_lib_dir / "xdp_dummy.bpf.o"
70     cmd(f"ip link set dev {cfg.remote_ifname} mtu 9000", shell=True, host=cfg.remote)
71     defer(ip, f"link set dev {cfg.remote_ifname} mtu 1500", host=cfg.remote)
72     ip("link set dev %s mtu 9000 xdpgeneric obj %s sec xdp.frags" % (cfg.ifname, prog))
73     defer(ip, f"link set dev {cfg.ifname} mtu 1500 xdpgeneric off")
78 def _set_xdp_native_sb_on(cfg) -> None:  argument
79     prog = cfg.net_lib_dir / "xdp_dummy.bpf.o"
80     cmd(f"ip link set dev {cfg.remote_ifname} mtu 1500", shell=True, host=cfg.remote)
81     cmd(f"ip -j link set dev {cfg.ifname} mtu 1500 xdp obj {prog} sec xdp", shell=True)
82     defer(ip, f"link set dev {cfg.ifname} mtu 1500 xdp off")
83     xdp_info = ip("-d link show %s" % (cfg.ifname), json=True)[0]
95 def _set_xdp_native_mb_on(cfg) -> None:  argument
96     prog = cfg.net_lib_dir / "xdp_dummy.bpf.o"
97     cmd(f"ip link set dev {cfg.remote_ifname} mtu 9000", shell=True, host=cfg.remote)
98     defer(ip, f"link set dev {cfg.remote_ifname} mtu 1500", host=cfg.remote)
100         cmd(f"ip link set dev {cfg.ifname} mtu 9000 xdp obj {prog} sec xdp.frags", shell=True)
101         defer(ip, f"link set dev {cfg.ifname} mtu 1500 xdp off")
108 def _set_xdp_offload_on(cfg) -> None:  argument
109     prog = cfg.net_lib_dir / "xdp_dummy.bpf.o"
110     cmd(f"ip link set dev {cfg.ifname} mtu 1500", shell=True)
112         cmd(f"ip link set dev {cfg.ifname} xdpoffload obj {prog} sec xdp", shell=True)
115     defer(ip, f"link set dev {cfg.ifname} xdpoffload off")
116     cmd(f"ip link set dev {cfg.remote_ifname} mtu 1500", shell=True, host=cfg.remote)
121 def get_interface_info(cfg) -> None:  argument
124     if cfg.remote_ifname == "":
126     local_info = ip("-d link show %s" % (cfg.ifname), json=True)[0]
132 def set_interface_init(cfg) -> None:  argument
133     cmd(f"ip link set dev {cfg.ifname} mtu 1500", shell=True)
134     cmd(f"ip link set dev {cfg.ifname} xdp off ", shell=True)
135     cmd(f"ip link set dev {cfg.ifname} xdpgeneric off ", shell=True)
136     cmd(f"ip link set dev {cfg.ifname} xdpoffload off", shell=True)
137     cmd(f"ip link set dev {cfg.remote_ifname} mtu 1500", shell=True, host=cfg.remote)
139 def test_default_v4(cfg, netnl) -> None:  argument
140     cfg.require_ipver("4")
142     _set_offload_checksum(cfg, netnl, "off")
143     _test_v4(cfg)
144     _test_tcp(cfg)
145     _set_offload_checksum(cfg, netnl, "on")
146     _test_v4(cfg)
147     _test_tcp(cfg)
149 def test_default_v6(cfg, netnl) -> None:  argument
150     cfg.require_ipver("6")
152     _set_offload_checksum(cfg, netnl, "off")
153     _test_v6(cfg)
154     _test_tcp(cfg)
155     _set_offload_checksum(cfg, netnl, "on")
156     _test_v6(cfg)
157     _test_tcp(cfg)
159 def test_xdp_generic_sb(cfg, netnl) -> None:  argument
160     _set_xdp_generic_sb_on(cfg)
161     _set_offload_checksum(cfg, netnl, "off")
162     _test_v4(cfg)
163     _test_v6(cfg)
164     _test_tcp(cfg)
165     _set_offload_checksum(cfg, netnl, "on")
166     _test_v4(cfg)
167     _test_v6(cfg)
168     _test_tcp(cfg)
170 def test_xdp_generic_mb(cfg, netnl) -> None:  argument
171     _set_xdp_generic_mb_on(cfg)
172     _set_offload_checksum(cfg, netnl, "off")
173     _test_v4(cfg)
174     _test_v6(cfg)
175     _test_tcp(cfg)
176     _set_offload_checksum(cfg, netnl, "on")
177     _test_v4(cfg)
178     _test_v6(cfg)
179     _test_tcp(cfg)
181 def test_xdp_native_sb(cfg, netnl) -> None:  argument
182     _set_xdp_native_sb_on(cfg)
183     _set_offload_checksum(cfg, netnl, "off")
184     _test_v4(cfg)
185     _test_v6(cfg)
186     _test_tcp(cfg)
187     _set_offload_checksum(cfg, netnl, "on")
188     _test_v4(cfg)
189     _test_v6(cfg)
190     _test_tcp(cfg)
192 def test_xdp_native_mb(cfg, netnl) -> None:  argument
193     _set_xdp_native_mb_on(cfg)
194     _set_offload_checksum(cfg, netnl, "off")
195     _test_v4(cfg)
196     _test_v6(cfg)
197     _test_tcp(cfg)
198     _set_offload_checksum(cfg, netnl, "on")
199     _test_v4(cfg)
200     _test_v6(cfg)
201     _test_tcp(cfg)
203 def test_xdp_offload(cfg, netnl) -> None:  argument
204     _set_xdp_offload_on(cfg)
205     _test_v4(cfg)
206     _test_v6(cfg)
207     _test_tcp(cfg)
210     with NetDrvEpEnv(__file__) as cfg:
211         get_interface_info(cfg)
212         set_interface_init(cfg)
220                  args=(cfg, EthtoolFamily()))