Show More
@@ -200,6 +200,10 b' class ShellSocketChannel(ZMQSocketChannel):' | |||||
200 | self.stream = zmqstream.ZMQStream(self.socket, self.ioloop) |
|
200 | self.stream = zmqstream.ZMQStream(self.socket, self.ioloop) | |
201 | self.stream.on_recv(self._handle_recv) |
|
201 | self.stream.on_recv(self._handle_recv) | |
202 | self._run_loop() |
|
202 | self._run_loop() | |
|
203 | try: | |||
|
204 | self.socket.close() | |||
|
205 | except: | |||
|
206 | pass | |||
203 |
|
207 | |||
204 | def stop(self): |
|
208 | def stop(self): | |
205 | self.ioloop.stop() |
|
209 | self.ioloop.stop() | |
@@ -390,6 +394,10 b' class SubSocketChannel(ZMQSocketChannel):' | |||||
390 | self.stream = zmqstream.ZMQStream(self.socket, self.ioloop) |
|
394 | self.stream = zmqstream.ZMQStream(self.socket, self.ioloop) | |
391 | self.stream.on_recv(self._handle_recv) |
|
395 | self.stream.on_recv(self._handle_recv) | |
392 | self._run_loop() |
|
396 | self._run_loop() | |
|
397 | try: | |||
|
398 | self.socket.close() | |||
|
399 | except: | |||
|
400 | pass | |||
393 |
|
401 | |||
394 | def stop(self): |
|
402 | def stop(self): | |
395 | self.ioloop.stop() |
|
403 | self.ioloop.stop() | |
@@ -452,6 +460,11 b' class StdInSocketChannel(ZMQSocketChannel):' | |||||
452 | self.stream = zmqstream.ZMQStream(self.socket, self.ioloop) |
|
460 | self.stream = zmqstream.ZMQStream(self.socket, self.ioloop) | |
453 | self.stream.on_recv(self._handle_recv) |
|
461 | self.stream.on_recv(self._handle_recv) | |
454 | self._run_loop() |
|
462 | self._run_loop() | |
|
463 | try: | |||
|
464 | self.socket.close() | |||
|
465 | except: | |||
|
466 | pass | |||
|
467 | ||||
455 |
|
468 | |||
456 | def stop(self): |
|
469 | def stop(self): | |
457 | self.ioloop.stop() |
|
470 | self.ioloop.stop() | |
@@ -575,6 +588,10 b' class HBSocketChannel(ZMQSocketChannel):' | |||||
575 | # and close/reopen the socket, because the REQ/REP cycle has been broken |
|
588 | # and close/reopen the socket, because the REQ/REP cycle has been broken | |
576 | self._create_socket() |
|
589 | self._create_socket() | |
577 | continue |
|
590 | continue | |
|
591 | try: | |||
|
592 | self.socket.close() | |||
|
593 | except: | |||
|
594 | pass | |||
578 |
|
595 | |||
579 | def pause(self): |
|
596 | def pause(self): | |
580 | """Pause the heartbeat.""" |
|
597 | """Pause the heartbeat.""" |
General Comments 0
You need to be logged in to leave comments.
Login now