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