From e126dd691b69de9e447718a4d72b566d36254cb6 Mon Sep 17 00:00:00 2001 From: Sven Augustin Date: Sat, 18 Oct 2025 19:06:27 +0200 Subject: [PATCH] allow to set bsread buffer window from CLI --- dap/accumulator.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/dap/accumulator.py b/dap/accumulator.py index c3723e9..b3ec3b8 100644 --- a/dap/accumulator.py +++ b/dap/accumulator.py @@ -14,21 +14,22 @@ def main(): parser.add_argument("--accumulator_port", type=int, default=13000) parser.add_argument("--bsread_host", default="*") parser.add_argument("--bsread_port", type=int, default=None) + parser.add_argument("--bsread_window", type=int, default=1000) clargs = parser.parse_args() accumulator_addr = make_address(clargs.accumulator_host, clargs.accumulator_port) - accumulate(accumulator_addr, clargs.bsread_host, clargs.bsread_port) + accumulate(accumulator_addr, clargs.bsread_host, clargs.bsread_port, clargs.bsread_window) -def accumulate(accumulator_addr, bsread_host, bsread_port): +def accumulate(accumulator_addr, bsread_host, bsread_port, bsread_window): zmq_socks = ZMQSocketsAccumulator(accumulator_addr) output = FileHandler() - sorter = Sorter() + sorter = Sorter(window=bsread_window) sender = make_bsread_sender(bsread_host, bsread_port)