From d8cdc17860dbdd0ec6dc7f77cc611d7f66285dce Mon Sep 17 00:00:00 2001 From: Sven Augustin Date: Wed, 15 Oct 2025 12:29:14 +0200 Subject: [PATCH] renamed: ZMQSockets -> ZMQSocketsWorker --- dap/worker.py | 4 ++-- dap/zmqsocks.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/dap/worker.py b/dap/worker.py index 23a4de5..84fa595 100644 --- a/dap/worker.py +++ b/dap/worker.py @@ -7,7 +7,7 @@ from algos import ( calc_radial_integration, calc_roi, calc_spi_analysis, calc_streakfinder_analysis, JFData ) from utils import Aggregator, BufferedJSON, randskip, read_bit -from zmqsocks import ZMQSockets +from zmqsocks import ZMQSocketsWorker def main(): @@ -43,7 +43,7 @@ def work(backend_address, accumulator_host, accumulator_port, visualisation_host jfdata = JFData() - zmq_socks = ZMQSockets(backend_address, accumulator_host, accumulator_port, visualisation_host, visualisation_port) + zmq_socks = ZMQSocketsWorker(backend_address, accumulator_host, accumulator_port, visualisation_host, visualisation_port) aggregator = Aggregator() diff --git a/dap/zmqsocks.py b/dap/zmqsocks.py index be25cc8..0d134d2 100644 --- a/dap/zmqsocks.py +++ b/dap/zmqsocks.py @@ -5,7 +5,7 @@ import zmq FLAGS = 0 -class ZMQSockets: +class ZMQSocketsWorker: def __init__(self, backend_address, accumulator_host, accumulator_port, visualisation_host, visualisation_port): zmq_context = zmq.Context(io_threads=4)