From b28f5ebf7a4fbedbbedafd539d9d33d2f1992a9e Mon Sep 17 00:00:00 2001
From: Mark Qvist <bc7291552be7a58f361522990465165c>
Date: Fri, 28 Aug 2026 11:11:42 +0200
Subject: [PATCH] Allow inbound queue utilization in drainer benchmarks

---
 tests/throughput.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/throughput.py b/tests/throughput.py
index 8f5f0ef6..34e623cf 100644
--- 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()