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