Show More
@@ -481,6 +481,8 b' class IOPubHandler(AuthenticatedZMQStreamHandler):' | |||
|
481 | 481 | if self._kernel_alive: |
|
482 | 482 | self._kernel_alive = False |
|
483 | 483 | self.hb_stream.send(b'ping') |
|
484 | # flush stream to force immediate socket send | |
|
485 | self.hb_stream.flush() | |
|
484 | 486 | else: |
|
485 | 487 | try: |
|
486 | 488 | callback() |
@@ -64,7 +64,7 b' class HeartMonitor(LoggingConfigurable):' | |||
|
64 | 64 | pongstream: an XREP stream |
|
65 | 65 | period: the period of the heartbeat in milliseconds""" |
|
66 | 66 | |
|
67 |
period = Integer( |
|
|
67 | period = Integer(3000, config=True, | |
|
68 | 68 | help='The frequency at which the Hub pings the engines for heartbeats ' |
|
69 | 69 | '(in ms)', |
|
70 | 70 | ) |
@@ -124,6 +124,8 b' class HeartMonitor(LoggingConfigurable):' | |||
|
124 | 124 | # print self.on_probation, self.hearts |
|
125 | 125 | # self.log.debug("heartbeat::beat %.3f, %i beating hearts", self.lifetime, len(self.hearts)) |
|
126 | 126 | self.pingstream.send(asbytes(str(self.lifetime))) |
|
127 | # flush stream to force immediate socket send | |
|
128 | self.pingstream.flush() | |
|
127 | 129 | |
|
128 | 130 | def handle_new_heart(self, heart): |
|
129 | 131 | if self._new_handlers: |
General Comments 0
You need to be logged in to leave comments.
Login now