def _stop_handler(self): gevent.joinall([self._watcher_starter_coroutine,]) log.info('OctpClient(%s) stopped.', self.service_names)