Show More
@@ -216,8 +216,11 class KernelApp(BaseIPythonApplication): | |||||
216 | self.stdin_socket = context.socket(zmq.ROUTER) |
|
216 | self.stdin_socket = context.socket(zmq.ROUTER) | |
217 | self.stdin_port = self._bind_socket(self.stdin_socket, self.stdin_port) |
|
217 | self.stdin_port = self._bind_socket(self.stdin_socket, self.stdin_port) | |
218 | self.log.debug("stdin ROUTER Channel on port: %i"%self.stdin_port) |
|
218 | self.log.debug("stdin ROUTER Channel on port: %i"%self.stdin_port) | |
219 |
|
219 | |||
220 | self.heartbeat = Heartbeat(context, (self.ip, self.hb_port)) |
|
220 | # heartbeat doesn't share context, because it mustn't be blocked | |
|
221 | # by the GIL, which is accessed by libzmq when freeing zero-copy messages | |||
|
222 | hb_ctx = zmq.Context() | |||
|
223 | self.heartbeat = Heartbeat(hb_ctx, (self.ip, self.hb_port)) | |||
221 | self.hb_port = self.heartbeat.port |
|
224 | self.hb_port = self.heartbeat.port | |
222 | self.log.debug("Heartbeat REP Channel on port: %i"%self.hb_port) |
|
225 | self.log.debug("Heartbeat REP Channel on port: %i"%self.hb_port) | |
223 |
|
226 |
General Comments 0
You need to be logged in to leave comments.
Login now