15 def _test_v4(cfg) -> None:  argument
16     cfg.require_v4()
18     cmd(f"ping -c 1 -W0.5 {cfg.remote_v4}")
19     cmd(f"ping -c 1 -W0.5 {cfg.v4}", host=cfg.remote)
20     cmd(f"ping -s 65000 -c 1 -W0.5 {cfg.remote_v4}")
21     cmd(f"ping -s 65000 -c 1 -W0.5 {cfg.v4}", host=cfg.remote)
23 def _test_v6(cfg) -> None:  argument
24     cfg.require_v6()
26     cmd(f"ping -c 1 -W5 {cfg.remote_v6}")
27     cmd(f"ping -c 1 -W5 {cfg.v6}", host=cfg.remote)
28     cmd(f"ping -s 65000 -c 1 -W0.5 {cfg.remote_v6}")
29     cmd(f"ping -s 65000 -c 1 -W0.5 {cfg.v6}", host=cfg.remote)
31 def _test_tcp(cfg) -> None:  argument
32     cfg.require_cmd("socat", remote=True)
35     listen_cmd = f"socat -{cfg.addr_ipver} -t 2 -u TCP-LISTEN:{port},reuseport STDOUT"
41         cmd(f"echo {test_string} | socat -t 2 -u STDIN TCP:{cfg.baddr}:{port}",
42             shell=True, host=cfg.remote)
46     with bkg(listen_cmd, host=cfg.remote, exit_wait=True) as nc:
47         wait_port_listen(port, host=cfg.remote)
49         cmd(f"echo {test_string} | socat -t 2 -u STDIN TCP:{cfg.remote_baddr}:{port}", shell=True)
52 def _set_offload_checksum(cfg, netnl, on) -> None:  argument
54         ethtool(f" -K {cfg.ifname} rx {on} tx {on} ")
58 def _set_xdp_generic_sb_on(cfg) -> None:  argument
61     cmd(f"ip link set dev {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
71     cmd(f"ip link set dev {remote_ifname} mtu 9000", shell=True, host=cfg.remote)
72     defer(ip, f"link set dev {remote_ifname} mtu 1500", host=cfg.remote)
73     ip("link set dev %s mtu 9000 xdpgeneric obj %s sec xdp.frags" % (cfg.ifname, prog))
74     defer(ip, f"link set dev {cfg.ifname} mtu 1500 xdpgeneric off")
79 def _set_xdp_native_sb_on(cfg) -> None:  argument
82     cmd(f"ip link set dev {remote_ifname} mtu 1500", shell=True, host=cfg.remote)
83     cmd(f"ip -j link set dev {cfg.ifname} mtu 1500 xdp obj {prog} sec xdp", shell=True)
84     defer(ip, f"link set dev {cfg.ifname} mtu 1500 xdp off")
85     xdp_info = ip("-d link show %s" % (cfg.ifname), json=True)[0]
97 def _set_xdp_native_mb_on(cfg) -> None:  argument
100     cmd(f"ip link set dev {remote_ifname} mtu 9000", shell=True, host=cfg.remote)
101     defer(ip, f"link set dev {remote_ifname} mtu 1500", host=cfg.remote)
103         cmd(f"ip link set dev {cfg.ifname} mtu 9000 xdp obj {prog} sec xdp.frags", shell=True)
104         defer(ip, f"link set dev {cfg.ifname} mtu 1500 xdp off")
111 def _set_xdp_offload_on(cfg) -> None:  argument
114     cmd(f"ip link set dev {cfg.ifname} mtu 1500", shell=True)
116         cmd(f"ip link set dev {cfg.ifname} xdpoffload obj {prog} sec xdp", shell=True)
119     defer(ip, f"link set dev {cfg.ifname} xdpoffload off")
120     cmd(f"ip link set dev {remote_ifname} mtu 1500", shell=True, host=cfg.remote)
125 def get_interface_info(cfg) -> None:  argument
129 …remote_info = cmd(f"ip -4 -o addr show to {cfg.remote_v4} | awk '{{print $2}}'", shell=True, host=…
133     local_info = ip("-d link show %s" % (cfg.ifname), json=True)[0]
139 def set_interface_init(cfg) -> None:  argument
140     cmd(f"ip link set dev {cfg.ifname} mtu 1500", shell=True)
141     cmd(f"ip link set dev {cfg.ifname} xdp off ", shell=True)
142     cmd(f"ip link set dev {cfg.ifname} xdpgeneric off ", shell=True)
143     cmd(f"ip link set dev {cfg.ifname} xdpoffload off", shell=True)
144     cmd(f"ip link set dev {remote_ifname} mtu 1500", shell=True, host=cfg.remote)
146 def test_default(cfg, netnl) -> None:  argument
147     _set_offload_checksum(cfg, netnl, "off")
148     _test_v4(cfg)
149     _test_v6(cfg)
150     _test_tcp(cfg)
151     _set_offload_checksum(cfg, netnl, "on")
152     _test_v4(cfg)
153     _test_v6(cfg)
154     _test_tcp(cfg)
156 def test_xdp_generic_sb(cfg, netnl) -> None:  argument
157     _set_xdp_generic_sb_on(cfg)
158     _set_offload_checksum(cfg, netnl, "off")
159     _test_v4(cfg)
160     _test_v6(cfg)
161     _test_tcp(cfg)
162     _set_offload_checksum(cfg, netnl, "on")
163     _test_v4(cfg)
164     _test_v6(cfg)
165     _test_tcp(cfg)
167 def test_xdp_generic_mb(cfg, netnl) -> None:  argument
168     _set_xdp_generic_mb_on(cfg)
169     _set_offload_checksum(cfg, netnl, "off")
170     _test_v4(cfg)
171     _test_v6(cfg)
172     _test_tcp(cfg)
173     _set_offload_checksum(cfg, netnl, "on")
174     _test_v4(cfg)
175     _test_v6(cfg)
176     _test_tcp(cfg)
178 def test_xdp_native_sb(cfg, netnl) -> None:  argument
179     _set_xdp_native_sb_on(cfg)
180     _set_offload_checksum(cfg, netnl, "off")
181     _test_v4(cfg)
182     _test_v6(cfg)
183     _test_tcp(cfg)
184     _set_offload_checksum(cfg, netnl, "on")
185     _test_v4(cfg)
186     _test_v6(cfg)
187     _test_tcp(cfg)
189 def test_xdp_native_mb(cfg, netnl) -> None:  argument
190     _set_xdp_native_mb_on(cfg)
191     _set_offload_checksum(cfg, netnl, "off")
192     _test_v4(cfg)
193     _test_v6(cfg)
194     _test_tcp(cfg)
195     _set_offload_checksum(cfg, netnl, "on")
196     _test_v4(cfg)
197     _test_v6(cfg)
198     _test_tcp(cfg)
200 def test_xdp_offload(cfg, netnl) -> None:  argument
201     _set_xdp_offload_on(cfg)
202     _test_v4(cfg)
203     _test_v6(cfg)
204     _test_tcp(cfg)
207     with NetDrvEpEnv(__file__) as cfg:
208         get_interface_info(cfg)
209         set_interface_init(cfg)
216                  args=(cfg, EthtoolFamily()))