Show More
@@ -49,14 +49,11 b' class IOLoopKernelRestarter(KernelRestarter):' | |||||
49 | self._pcallback = ioloop.PeriodicCallback( |
|
49 | self._pcallback = ioloop.PeriodicCallback( | |
50 | self.poll, 1000*self.time_to_dead, self.loop |
|
50 | self.poll, 1000*self.time_to_dead, self.loop | |
51 | ) |
|
51 | ) | |
52 | self._pcallback.start() |
|
52 | self._pcallback.start() | |
53 |
|
53 | |||
54 | def stop(self): |
|
54 | def stop(self): | |
55 | """Stop the kernel polling.""" |
|
55 | """Stop the kernel polling.""" | |
56 | if self._pcallback is not None: |
|
56 | if self._pcallback is not None: | |
57 | self._pcallback.stop() |
|
57 | self._pcallback.stop() | |
|
58 | self._pcallback = None | |||
58 |
|
59 | |||
59 | def clear(self): |
|
|||
60 | """Clear the underlying PeriodicCallback.""" |
|
|||
61 | self.stop() |
|
|||
62 | self._pcallback = None |
|
@@ -89,8 +89,13 b' class KernelRestarter(LoggingConfigurable):' | |||||
89 | self.log.warn("KernelRestarter: restart failed") |
|
89 | self.log.warn("KernelRestarter: restart failed") | |
90 | self._fire_callbacks('dead') |
|
90 | self._fire_callbacks('dead') | |
91 | self._restarting = False |
|
91 | self._restarting = False | |
|
92 | self.stop() | |||
92 | else: |
|
93 | else: | |
93 | self.log.info('KernelRestarter: restarting kernel') |
|
94 | self.log.info('KernelRestarter: restarting kernel') | |
94 | self._fire_callbacks('restart') |
|
95 | self._fire_callbacks('restart') | |
95 | self.kernel_manager.restart_kernel(now=True) |
|
96 | self.kernel_manager.restart_kernel(now=True) | |
96 | self._restarting = True |
|
97 | self._restarting = True | |
|
98 | else: | |||
|
99 | if self._restarting: | |||
|
100 | self.log.debug("KernelRestarter: restart apparently succeeded") | |||
|
101 | self._restarting = False |
General Comments 0
You need to be logged in to leave comments.
Login now