(self)
| 87 | c.pool.spawn_n(self.loop, c) |
| 88 | |
| 89 | def on_stop(self): |
| 90 | if self._node_stopped: |
| 91 | self._node_shutdown.set() |
| 92 | debug('Waiting for broadcast thread to shutdown...') |
| 93 | self._node_stopped.wait() |
| 94 | self._node_stopped = self._node_shutdown = None |
| 95 | |
| 96 | def reset(self): |
| 97 | self._resets += 1 |