##// END OF EJS Templates
close KernelManager channel sockets when they stop...
MinRK -
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