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

renamed: ZMQSockets -> ZMQSocketsWorker

Browse Source
This commit is contained in:
augustin_s
2025-10-15 12:29:14 +02:00
parent f968497895
commit d8cdc17860
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
dap/worker.py
View File

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

2
dap/zmqsocks.py
View File

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