Allow inbound queue utilization in drainer benchmarks

2026-08-28 11:11:42 +02:00 · 2026-08-28 11:11:42 +02:00 · b28f5ebf7a
parent 77c8256a1a
commit b28f5ebf7a
1 changed files with 1 additions and 1 deletions
--- a/tests/throughput.py
+++ b/tests/throughput.py
@ -568,7 +568,7 @@ def _bench_drainer(scenario, n, runs):
                    _feed(scenario.frames[base + i], scenario.interface)
                fed += batch
                target = baseline + fed
-                while scenario.completion_counter() < target:
+                while scenario.completion_counter() < target-800: # Assumes default inbound queue of 1024
                    time.sleep(0.0002)
            dt = time.perf_counter() - t0
            gc.enable()