From 709b0a32717188b02cdb8e5beca939e64e25b57c Mon Sep 17 00:00:00 2001 From: evgeny Date: Mon, 12 Oct 2026 01:15:31 +0200 Subject: [PATCH] Wait for the real observer link and distribute STUN bench scripts --- tests/Makefile.am | 2 +- tests/stream_netns/stun_scenario.py | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/tests/Makefile.am b/tests/Makefile.am index cc4516e3..91c03c54 100644 --- a/tests/Makefile.am +++ b/tests/Makefile.am @@ -3,7 +3,7 @@ EXTRA_DIST = fixtures/reality_openssl_hello.hex data/silero_speech.pcm data/silero_speech.txt test_net.h nat_fixture.h \ run_tests.py test_run_tests.py test_build_script.py stream_netns/topology.py stream_netns/network.py \ stream_netns/probe.py stream_netns/run.py stream_netns/scenario.py stream_netns/README.md stream_netns/TESTED.md \ - stream_netns/test_isolation.py stream_netns/nat_scenario.py + stream_netns/test_isolation.py stream_netns/nat_scenario.py stream_netns/stun_server.py stream_netns/stun_scenario.py # Порядок по замерам Linux: быстрые проверки раньше длительных; состав зависит от прежних configure-условий. diff --git a/tests/stream_netns/stun_scenario.py b/tests/stream_netns/stun_scenario.py index 43fd75e5..bee0ab39 100644 --- a/tests/stream_netns/stun_scenario.py +++ b/tests/stream_netns/stun_scenario.py @@ -54,6 +54,8 @@ def check_stun(scenario): agents[name] = Agent(network, nodes[name], Path(scenario.args.binary).resolve(), scenario.args.seed, False, False, True) agents[owner_name].rpc("nat_link", snapshot=agents[observer_name].rpc("snapshot")["snapshot"], socket="udp") + scenario.wait(f"stun-observer-link-{owner_name}", lambda statistics: + agents[observer_name].identity in statistics[owner_name]["direct_up"], 20) agents[owner_name].rpc("nat_check", socket="udp", observer=agents[observer_name].identity) data = scenario.wait(f"stun-no-helper-{owner_name}", lambda statistics: profile(statistics[owner_name], "udp")["reason"] == "no_helper", 40)