From b3d31d9d8e3823edec376470c1ce94f65f960d7e Mon Sep 17 00:00:00 2001 From: LinuxDev9002 Date: Sat, 18 Jul 2026 15:18:45 -0700 Subject: [PATCH] Test queued packet cleanup on signal --- src/53-egress-pacer/tests/test_egress_pacer.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/src/53-egress-pacer/tests/test_egress_pacer.py b/src/53-egress-pacer/tests/test_egress_pacer.py index 98c0884..955be8a 100644 --- a/src/53-egress-pacer/tests/test_egress_pacer.py +++ b/src/53-egress-pacer/tests/test_egress_pacer.py @@ -230,11 +230,17 @@ def main() -> int: bufsize=1, ) signal_lines = wait_until_ready(process) + send_burst() process.terminate() signal_remainder, _ = process.communicate(timeout=4) signal_output = "".join(signal_lines) + signal_remainder assert process.returncode == 0, signal_output - parse_summary(signal_output) + signal_stats = parse_summary(signal_output) + assert signal_stats["enqueued"] + signal_stats["policy_dropped"] == ATTEMPTS, signal_stats + assert signal_stats["cleanup_dropped"] > 0, signal_stats + assert signal_stats["enqueued"] == ( + signal_stats["dequeued"] + signal_stats["cleanup_dropped"] + ), signal_stats qdisc_after_signal = run("tc", "qdisc", "show", "dev", TX_INTERFACE).stdout assert "bpf_pacer" not in qdisc_after_signal, qdisc_after_signal