mirror of
https://github.com/torvalds/linux.git
synced 2026-07-28 10:09:10 +02:00
3bdd6852c2
This test needs more work, and it fails in non-obvious way when IPv4 connectivity is not available: # Exception| CMD[remote]: /tmp/vjquwblf/gukinuzqso_txtime -4 -c mono -t 1780939014114542914 -S None -D None a,0 -r # Exception| EXIT: -15 Explicitly check for IPv4 support to make the future triage less painful. Reviewed-by: Willem de Bruijn <willemb@google.com> Signed-off-by: Jakub Kicinski <kuba@kernel.org> Link: https://patch.msgid.link/20260609180803.1093428-3-kuba@kernel.org Signed-off-by: Paolo Abeni <pabeni@redhat.com>
119 lines
3.8 KiB
Python
Executable File
119 lines
3.8 KiB
Python
Executable File
#!/usr/bin/env python3
|
|
# SPDX-License-Identifier: GPL-2.0
|
|
|
|
"""Regression tests for the SO_TXTIME interface.
|
|
|
|
Test delivery time in FQ and ETF qdiscs.
|
|
"""
|
|
|
|
import os
|
|
import time
|
|
|
|
from lib.py import ksft_exit, ksft_run, ksft_variants
|
|
from lib.py import KsftNamedVariant, KsftSkipEx
|
|
from lib.py import NetDrvEpEnv, bkg, cmd, defer, tc
|
|
|
|
|
|
def test_so_txtime(cfg, clockid, ipver, args_tx, args_rx, expect_success):
|
|
"""Main function. Run so_txtime as sender and receiver."""
|
|
slow_machine = os.environ.get('KSFT_MACHINE_SLOW')
|
|
|
|
if not hasattr(cfg, "bin_remote"):
|
|
cfg.bin_local = cfg.test_dir / "so_txtime"
|
|
cfg.bin_remote = cfg.remote.deploy(cfg.bin_local)
|
|
|
|
tstart = time.time_ns() + (2000_000_000 if slow_machine else 200_000_000)
|
|
|
|
cmd_addr = f"-S {cfg.addr_v[ipver]} -D {cfg.remote_addr_v[ipver]}"
|
|
cmd_args = f"-{ipver} -c {clockid} -t {tstart} {cmd_addr}"
|
|
cmd_rx = f"{cfg.bin_remote} {cmd_args} {args_rx} -r"
|
|
cmd_tx = f"{cfg.bin_local} {cmd_args} {args_tx}"
|
|
|
|
expect_fail = not expect_success
|
|
if slow_machine:
|
|
expect_success = False
|
|
|
|
with bkg(cmd_rx, host=cfg.remote, fail=expect_success,
|
|
expect_fail=expect_fail, exit_wait=True):
|
|
cmd(cmd_tx)
|
|
|
|
|
|
def _qdisc_setup(ifname, qdisc, optargs=""):
|
|
"""Replace root qdisc. Restore the original after the test.
|
|
|
|
If the original is mq, children will be of type default_qdisc.
|
|
"""
|
|
orig = tc(f"qdisc show dev {ifname} root", json=True)[0].get("kind", None)
|
|
defer(tc, f"qdisc replace dev {ifname} root {orig}")
|
|
tc(f"qdisc replace dev {ifname} root {qdisc} {optargs}")
|
|
|
|
|
|
def _test_variants_fq():
|
|
for ipver in ["4", "6"]:
|
|
for testcase in [
|
|
["no_delay", "a,-1", "a,-1"],
|
|
["zero_delay", "a,0", "a,0"],
|
|
["one_pkt", "a,10", "a,10"],
|
|
["in_order", "a,10,b,20", "a,10,b,20"],
|
|
["reverse_order", "a,20,b,10", "b,10,a,20"],
|
|
]:
|
|
name = f"v{ipver}_{testcase[0]}"
|
|
yield KsftNamedVariant(name, ipver, testcase[1], testcase[2])
|
|
|
|
|
|
@ksft_variants(_test_variants_fq())
|
|
def test_so_txtime_fq_mono(cfg, ipver, args_tx, args_rx):
|
|
"""Run all variants of monotonic (fq) tests."""
|
|
cfg.require_ipver(ipver)
|
|
_qdisc_setup(cfg.ifname, "fq")
|
|
test_so_txtime(cfg, "mono", ipver, args_tx, args_rx, True)
|
|
|
|
|
|
@ksft_variants(_test_variants_fq())
|
|
def test_so_txtime_fq_tai(cfg, ipver, args_tx, args_rx):
|
|
"""Run all variants of fq tests, but pass CLOCK_TAI to test conversion."""
|
|
cfg.require_ipver(ipver)
|
|
_qdisc_setup(cfg.ifname, "fq")
|
|
test_so_txtime(cfg, "tai", ipver, args_tx, args_rx, True)
|
|
|
|
|
|
def _test_variants_etf():
|
|
for ipver in ["4", "6"]:
|
|
for testcase in [
|
|
["no_delay", "a,-1", "a,-1", False],
|
|
["zero_delay", "a,0", "a,0", False],
|
|
["one_pkt", "a,10", "a,10", True],
|
|
["in_order", "a,10,b,20", "a,10,b,20", True],
|
|
["reverse_order", "a,20,b,10", "b,10,a,20", True],
|
|
]:
|
|
name = f"v{ipver}_{testcase[0]}"
|
|
yield KsftNamedVariant(
|
|
name, ipver, testcase[1], testcase[2], testcase[3]
|
|
)
|
|
|
|
|
|
@ksft_variants(_test_variants_etf())
|
|
def test_so_txtime_etf(cfg, ipver, args_tx, args_rx, expect_fail):
|
|
"""Run all variants of etf tests."""
|
|
cfg.require_ipver(ipver)
|
|
try:
|
|
_qdisc_setup(cfg.ifname, "etf", "clockid CLOCK_TAI delta 400000")
|
|
except Exception as e:
|
|
raise KsftSkipEx("tc does not support qdisc etf. skipping") from e
|
|
|
|
test_so_txtime(cfg, "tai", ipver, args_tx, args_rx, expect_fail)
|
|
|
|
|
|
def main() -> None:
|
|
"""Boilerplate ksft main."""
|
|
with NetDrvEpEnv(__file__) as cfg:
|
|
ksft_run(
|
|
[test_so_txtime_fq_mono, test_so_txtime_fq_tai, test_so_txtime_etf],
|
|
args=(cfg,),
|
|
)
|
|
ksft_exit()
|
|
|
|
|
|
if __name__ == "__main__":
|
|
main()
|