From 6431fac9b15cb5ac3619d83d0d165bbf509c2a34 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Krist=C3=B3f=20T=C3=B3th?= Date: Tue, 21 May 2019 13:57:56 +0200 Subject: [PATCH] Set ZMQ HWM in EventHandlerConnector to infinite --- lib/tfw/networking/server/event_handler_connector.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/lib/tfw/networking/server/event_handler_connector.py b/lib/tfw/networking/server/event_handler_connector.py index bc6c9be..8b13338 100644 --- a/lib/tfw/networking/server/event_handler_connector.py +++ b/lib/tfw/networking/server/event_handler_connector.py @@ -16,6 +16,7 @@ class EventHandlerDownlinkConnector(ZMQConnectorBase): def __init__(self, zmq_context=None): super(EventHandlerDownlinkConnector, self).__init__(zmq_context) self._zmq_pull_socket = self._zmq_context.socket(zmq.PULL) + self._zmq_pull_socket.setsockopt(zmq.RCVHWM, 0) self._zmq_pull_stream = ZMQStream(self._zmq_pull_socket) address = f'tcp://*:{TFWENV.RECEIVER_PORT}' self._zmq_pull_socket.bind(address) @@ -30,6 +31,7 @@ class EventHandlerUplinkConnector(ZMQConnectorBase): def __init__(self, zmq_context=None): super(EventHandlerUplinkConnector, self).__init__(zmq_context) self._zmq_pub_socket = self._zmq_context.socket(zmq.PUB) + self._zmq_pub_socket.setsockopt(zmq.SNDHWM, 0) address = f'tcp://*:{TFWENV.PUBLISHER_PORT}' self._zmq_pub_socket.bind(address) LOG.debug('Pub socket bound to %s', address)