Lines Matching +full:retry +full:- +full:time
2 # SPDX-License-Identifier: GPL-2.0
25 import time
46 format="%(asctime)s - %(levelname)s - %(message)s",
63 # Time bpftrace will be running in parallel.
67 def ethtool_get_ringsize(interface_name: str) -> tuple[int, int]:
72 ethtool_result = ethtool(f"-g {interface_name}", json=True)[0]
83 def ethtool_set_ringsize(interface_name: str, ring_size: tuple[int, int]) -> bool:
90 ethtool(f"-G {interface_name} rx {rxs} tx {txs}")
92 # This might fail on real device, retry with a higher value,
99 def ethtool_get_queues_cnt(interface_name: str) -> tuple[int, int, int]:
103 ethtool_result = ethtool(f"-l {interface_name}", json=True)[0]
104 rxq = ethtool_result.get("rx", -1)
105 txq = ethtool_result.get("tx", -1)
106 combined = ethtool_result.get("combined", -1)
116 def ethtool_set_queues_cnt(interface_name: str, queues: tuple[int, int, int]) -> None:
120 cmdline = f"-L {interface_name}"
122 if rxq != -1:
124 if txq != -1:
126 if combined != -1:
139 def netcons_generate_random_target_name() -> str:
148 ) -> None:
166 with open(path, "w", encoding="utf-8") as file:
175 encoding="utf-8",
194 ) -> None:
213 def netcons_delete_target(name: str) -> None:
225 def netcons_load_module() -> None:
230 def bpftrace_call() -> None:
238 # This will be passed to bpftrace as in bpftrace -e "expr"
255 def bpftrace_stop() -> None:
261 def bpftrace_any_hit(join: bool) -> bool:
282 def do_netpoll_flush_monitored(cfg: NetDrvEpEnv, ifname: str, target_name: str) -> None:
298 def do_netpoll_flush(cfg: NetDrvEpEnv, ifname: str, target_name: str) -> None:
301 retry = 0
309 with open("/dev/kmsg", "w", encoding="utf-8") as kmsg:
312 kmsg.write(f"{msg}-{j}\n")
314 # in some cases, kmsg can be busy, so, we will retry
315 time.sleep(1)
316 retry += 1
317 if retry < 5:
319 # Just retry a few times
329 time.sleep(0.4)
332 def configure_network(ifname: str) -> None:
353 def test_netpoll(cfg: NetDrvEpEnv) -> None:
375 def test_check_dependencies() -> None:
383 def main() -> None: