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

clearer comments

Browse Source
This commit is contained in:
augustin_s
2025-10-15 16:19:14 +02:00
parent 33e93c179c
commit a756678882
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
dap/zmqsocks.py
View File

@@ -45,12 +45,12 @@ class ZMQSocketsWorker:
self.visualisation_socket = visualisation_socket = zmq_context.socket(zmq.PUB)
visualisation_socket.connect(visualisation_addr)
# in case of problem with communication to visualisation, keep in 0mq buffer only few messages
# in case of communication problems with the visualisation, keep only few messages
visualisation_socket.set_hwm(10)
def has_data(self):
events = dict(self.poller.poll(2000)) # check every 2 seconds in each worker
events = dict(self.poller.poll(2000)) # each worker checks for input every 2 seconds
return (self.backend_socket in events)
def get_data(self):