zmq: use global client context

cylc · Mar 21, 2019 · 80d7d8a · 80d7d8a
1 parent 3c0ffb5
commit 80d7d8a
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/lib/cylc/network/client.py b/lib/cylc/network/client.py
@@ -34,6 +34,10 @@
     SuiteSrvFilesManager, SuiteServiceFileError)
 
 
+# we should only have one ZMQ context per-process
+CONTEXT = zmq.asyncio.Context()
+
+
 class ClientError(Exception):
     # TODO: this is a bit messy, lets tidy
     # TODO: ServerError class
@@ -112,8 +116,7 @@ def __init__(self, host, port, encode_method, decode_method, secret_method,
         self.timeout_handler = timeout_handler
 
         # open the ZMQ socket
-        self.context = zmq.asyncio.Context()
-        self.socket = self.context.socket(zmq.REQ)
+        self.socket = CONTEXT.socket(zmq.REQ)
         self.socket.connect('tcp://%s:%d' % (host, port))
         # if there is no server don't keep the client hanging around
         self.socket.setsockopt(zmq.LINGER, int(self.DEFAULT_TIMEOUT))