mrtoth/baseimage-tutorial-framework
1
0
Fork 0
mirror of https://github.com/avatao-content/baseimage-tutorial-framework synced 2024-11-22 18:31:33 +00:00
Code Issues Releases Wiki Activity

Remove leftover parentheses

Browse Source
This commit is contained in:
Kristóf Tóth 2019-07-09 09:12:21 +02:00
parent 64ea7d8218
commit e5dee3a1b3
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib/tfw/networking/event_handler_connector.py
View File

@ -8,7 +8,7 @@ from .serialization import serialize_tfw_msg, with_deserialize_tfw_msg
LOG = logging.getLogger(__name__) LOG = logging.getLogger(__name__)
class EventHandlerDownlinkConnector(): class EventHandlerDownlinkConnector:
def __init__(self, bind_addr): def __init__(self, bind_addr):
self._zmq_pull_socket = zmq.Context.instance().socket(zmq.PULL) self._zmq_pull_socket = zmq.Context.instance().socket(zmq.PULL)
self._zmq_pull_socket.setsockopt(zmq.RCVHWM, 0) self._zmq_pull_socket.setsockopt(zmq.RCVHWM, 0)
@ -24,7 +24,7 @@ class EventHandlerDownlinkConnector():
self._zmq_pull_stream.close() self._zmq_pull_stream.close()
class EventHandlerUplinkConnector(): class EventHandlerUplinkConnector:
def __init__(self, bind_addr): def __init__(self, bind_addr):
self._zmq_pub_socket = zmq.Context.instance().socket(zmq.PUB) self._zmq_pub_socket = zmq.Context.instance().socket(zmq.PUB)
self._zmq_pub_socket.setsockopt(zmq.SNDHWM, 0) self._zmq_pub_socket.setsockopt(zmq.SNDHWM, 0)

4
lib/tfw/networking/server_connector.py
View File

@ -10,7 +10,7 @@ from .serialization import serialize_tfw_msg, with_deserialize_tfw_msg
LOG = logging.getLogger(__name__) LOG = logging.getLogger(__name__)
class ServerDownlinkConnector(): class ServerDownlinkConnector:
def __init__(self, connect_addr): def __init__(self, connect_addr):
self._zmq_sub_socket = zmq.Context.instance().socket(zmq.SUB) self._zmq_sub_socket = zmq.Context.instance().socket(zmq.SUB)
self._zmq_sub_socket.setsockopt(zmq.RCVHWM, 0) self._zmq_sub_socket.setsockopt(zmq.RCVHWM, 0)
@ -28,7 +28,7 @@ class ServerDownlinkConnector():
self._zmq_sub_stream.close() self._zmq_sub_stream.close()
class ServerUplinkConnector(): class ServerUplinkConnector:
def __init__(self, connect_addr): def __init__(self, connect_addr):
self._zmq_push_socket = zmq.Context.instance().socket(zmq.PUSH) self._zmq_push_socket = zmq.Context.instance().socket(zmq.PUSH)
self._zmq_push_socket.setsockopt(zmq.SNDHWM, 0) self._zmq_push_socket.setsockopt(zmq.SNDHWM, 0)