Show More
@@ -127,7 +127,10 b' class ZMQChannelHandler(AuthenticatedZMQStreamHandler):' | |||
|
127 | 127 | # closed before the ZMQ streams are setup, they could be None. |
|
128 | 128 | if self.zmq_stream is not None and not self.zmq_stream.closed(): |
|
129 | 129 | self.zmq_stream.on_recv(None) |
|
130 | # close the socket directly, don't wait for the stream | |
|
131 | socket = self.zmq_stream.socket | |
|
130 | 132 | self.zmq_stream.close() |
|
133 | socket.close() | |
|
131 | 134 | |
|
132 | 135 | |
|
133 | 136 | class IOPubHandler(ZMQChannelHandler): |
@@ -524,6 +524,8 b' class ConnectionFileMixin(Configurable):' | |||
|
524 | 524 | socket_type = channel_socket_types[channel] |
|
525 | 525 | self.log.debug("Connecting to: %s" % url) |
|
526 | 526 | sock = self.context.socket(socket_type) |
|
527 | # set linger to 1s to prevent hangs at exit | |
|
528 | sock.linger = 1000 | |
|
527 | 529 | if identity: |
|
528 | 530 | sock.identity = identity |
|
529 | 531 | sock.connect(url) |
General Comments 0
You need to be logged in to leave comments.
Login now