diff --git a/dap/zmqsocks.py b/dap/zmqsocks.py index 600fd98..000aef0 100644 --- a/dap/zmqsocks.py +++ b/dap/zmqsocks.py @@ -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):