

@gen.coroutine
@util.debuglog
def _reload(self, graceful=True, sequential=False):
    ' reload\n        '
    if ((not graceful) and sequential):
        logger.warn('with graceful=False, sequential=True is ignored')
    if (self.prereload_fn is not None):
        self.prereload_fn(self)
    if (not graceful):
        (yield self._restart())
        return
    if self.is_stopped():
        (yield self._start())
    elif self.send_hup:
        for process in self.processes.values():
            logger.info(('SENDING HUP to %s' % process.pid))
            process.send_signal(signal.SIGHUP)
    elif sequential:
        active_processes = self.get_active_processes()
        for process in active_processes:
            (yield self.kill_process(process))
            self.reap_process(process.pid)
            self.spawn_process()
            (yield tornado_sleep(self.warmup_delay))
    else:
        for i in range(self.numprocesses):
            self.spawn_process()
        (yield self.manage_processes())
    self.notify_event('reload', {
        'time': time.time(),
    })
    logger.info('%s reloaded', self.name)

dataset/ETHPy150Open circus-tent/circus/circus/watcher.py Watcher._reload/original