sf-daq/dap
0
1
Fork 2
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

allow to set bsread buffer window from CLI

Browse Source
This commit is contained in:
augustin_s
2025-10-18 19:06:27 +02:00
parent 2adda65b88
commit e126dd691b
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
dap/accumulator.py
View File

@@ -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)