peter/infix
1
0
Fork 0
mirror of https://github.com/kernelkit/infix.git synced 2026-07-30 04:33:00 +02:00
Code Issues Packages Projects Releases Wiki Activity

test: change query-interval and add retry in igmp_basic

Browse Source 
There's a case where the first query is lost due to the network just
starting up. To handle this we introduce a retry loop in the test case
that waits for a second query message to be sent.

In this commit we also lower the query interval to speed up the case
when the first message is lost. Ideally mcd (the underlying multicast
daemon) should implement a Startup Query Interval to send it even
faster.

Signed-off-by: Richard Alpe <richard@bit42.se>
This commit is contained in:
Richard Alpe
2024-09-10 17:58:26 +02:00
committed by Joachim Wiberg
parent cfd95dc300
commit 1f74ebf828
1 changed files with 19 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
test/case/infix_interfaces/igmp_basic/test.py
+19 -1
View File
@@ -27,6 +27,8 @@ import infamy
import time
import infamy.multicast as mcast
query_interval = 4
with infamy.Test() as test:
with test.step("Initialize"):
env = infamy.Env()
@@ -76,6 +78,7 @@ with infamy.Test() as test:
"bridge": {
"multicast": {
"query-interval": query_interval,
"snooping": True
}
@@ -113,6 +116,21 @@ with infamy.Test() as test:
receive_ns.must_receive("ip dst 224.1.1.1")
with test.step("Verify that the group is no longer forwarded to the non-member"):
nojoin_ns.must_not_receive("ip dst 224.1.1.1")
attempt = 0
# This retry loop exists to handle the case where the first query is lost due
# to the network just starting up. In particular there's a case where a newly
# created bridge uses the "NOOP" scheduler (noop_enqueue()) for a split second
# while it's starting up, which might drop the first query msg.
while attempt <= query_interval:
try:
nojoin_ns.must_not_receive("ip dst 224.1.1.1")
break
except Exception as e:
attempt += 1
if attempt > query_interval:
test.fail()
else:
print(f"Got mcast flood, retrying ({attempt}/{query_interval})")
test.succeed()