Lines Matching full:cfg
13 def _get_hds_mode(cfg, netnl) -> str:
15 rings = netnl.rings_get({'header': {'dev-index': cfg.ifindex}})
23 def _xdp_onoff(cfg):
24 prog = cfg.net_lib_dir / "xdp_dummy.bpf.o"
26 (cfg.ifname, prog))
27 ip("link set dev %s xdp off" % cfg.ifname)
30 def _ioctl_ringparam_modify(cfg, netnl) -> None:
36 rings = netnl.rings_get({'header': {'dev-index': cfg.ifindex}})
44 ethtool(f"--disable-netlink -G {cfg.ifname} tx {rings['tx'] // 2}")
46 ethtool(f"--disable-netlink -G {cfg.ifname} tx {rings['tx'] * 2}")
47 defer(ethtool, f"-G {cfg.ifname} tx {rings['tx']}")
50 def get_hds(cfg, netnl) -> None:
51 _get_hds_mode(cfg, netnl)
54 def get_hds_thresh(cfg, netnl) -> None:
56 rings = netnl.rings_get({'header': {'dev-index': cfg.ifindex}})
63 def _hds_reset(cfg, netnl, rings) -> None:
64 cur = netnl.rings_get({'header': {'dev-index': cfg.ifindex}})
66 arg = {'header': {'dev-index': cfg.ifindex}}
72 cur = netnl.rings_get({'header': {'dev-index': cfg.ifindex}})
84 def _defer_reset_hds(cfg, netnl) -> Union[dict, None]:
86 rings = netnl.rings_get({'header': {'dev-index': cfg.ifindex}})
88 defer(_hds_reset, cfg, netnl, rings)
93 def set_hds_enable(cfg, netnl) -> None:
94 _defer_reset_hds(cfg, netnl)
96 netnl.rings_set({'header': {'dev-index': cfg.ifindex}, 'tcp-data-split': 'enabled'})
103 rings = netnl.rings_get({'header': {'dev-index': cfg.ifindex}})
111 def set_hds_disable(cfg, netnl) -> None:
112 _defer_reset_hds(cfg, netnl)
114 netnl.rings_set({'header': {'dev-index': cfg.ifindex}, 'tcp-data-split': 'disabled'})
121 rings = netnl.rings_get({'header': {'dev-index': cfg.ifindex}})
129 def set_hds_thresh_zero(cfg, netnl) -> None:
130 _defer_reset_hds(cfg, netnl)
132 netnl.rings_set({'header': {'dev-index': cfg.ifindex}, 'hds-thresh': 0})
139 rings = netnl.rings_get({'header': {'dev-index': cfg.ifindex}})
147 def set_hds_thresh_random(cfg, netnl) -> None:
148 _defer_reset_hds(cfg, netnl)
150 rings = netnl.rings_get({'header': {'dev-index': cfg.ifindex}})
169 netnl.rings_set({'header': {'dev-index': cfg.ifindex}, 'hds-thresh': hds_thresh})
175 rings = netnl.rings_get({'header': {'dev-index': cfg.ifindex}})
178 def set_hds_thresh_max(cfg, netnl) -> None:
179 _defer_reset_hds(cfg, netnl)
181 rings = netnl.rings_get({'header': {'dev-index': cfg.ifindex}})
187 netnl.rings_set({'header': {'dev-index': cfg.ifindex}, 'hds-thresh': rings['hds-thresh-max']})
193 rings = netnl.rings_get({'header': {'dev-index': cfg.ifindex}})
196 def set_hds_thresh_gt(cfg, netnl) -> None:
197 _defer_reset_hds(cfg, netnl)
199 rings = netnl.rings_get({'header': {'dev-index': cfg.ifindex}})
208 netnl.rings_set({'header': {'dev-index': cfg.ifindex}, 'hds-thresh': hds_gt})
212 def set_xdp(cfg, netnl) -> None:
217 mode = _get_hds_mode(cfg, netnl)
219 _defer_reset_hds(cfg, netnl)
220 netnl.rings_set({'header': {'dev-index': cfg.ifindex},
223 _xdp_onoff(cfg)
226 def enabled_set_xdp(cfg, netnl) -> None:
231 _get_hds_mode(cfg, netnl)
232 netnl.rings_set({'header': {'dev-index': cfg.ifindex},
235 defer(netnl.rings_set, {'header': {'dev-index': cfg.ifindex},
239 _xdp_onoff(cfg)
242 def set_xdp(cfg, netnl) -> None:
247 mode = _get_hds_mode(cfg, netnl)
249 netnl.rings_set({'header': {'dev-index': cfg.ifindex},
252 _xdp_onoff(cfg)
255 def enabled_set_xdp(cfg, netnl) -> None:
260 _get_hds_mode(cfg, netnl) # Trigger skip if not supported
262 netnl.rings_set({'header': {'dev-index': cfg.ifindex},
264 defer(netnl.rings_set, {'header': {'dev-index': cfg.ifindex},
268 _xdp_onoff(cfg)
271 def ioctl(cfg, netnl) -> None:
272 mode1 = _get_hds_mode(cfg, netnl)
273 _ioctl_ringparam_modify(cfg, netnl)
274 mode2 = _get_hds_mode(cfg, netnl)
279 def ioctl_set_xdp(cfg, netnl) -> None:
283 mode = _get_hds_mode(cfg, netnl)
285 netnl.rings_set({'header': {'dev-index': cfg.ifindex},
288 _ioctl_ringparam_modify(cfg, netnl)
290 _xdp_onoff(cfg)
293 def ioctl_enabled_set_xdp(cfg, netnl) -> None:
298 _get_hds_mode(cfg, netnl) # Trigger skip if not supported
300 netnl.rings_set({'header': {'dev-index': cfg.ifindex},
302 defer(netnl.rings_set, {'header': {'dev-index': cfg.ifindex},
306 _xdp_onoff(cfg)
310 with NetDrvEnv(__file__, queue_count=3) as cfg:
324 args=(cfg, EthtoolFamily()))