|
|
@ -197,13 +197,6 @@ class BackfillerManager(object):
|
|
|
|
"""Stop the worker for given node."""
|
|
|
|
"""Stop the worker for given node."""
|
|
|
|
self.workers.pop(node).stop()
|
|
|
|
self.workers.pop(node).stop()
|
|
|
|
|
|
|
|
|
|
|
|
def restart_worker(self, node):
|
|
|
|
|
|
|
|
"""Restart the worker for given node."""
|
|
|
|
|
|
|
|
self.stop_worker(node)
|
|
|
|
|
|
|
|
self.stopping.wait(common.jitter(self.RESTART_INTERVAL))
|
|
|
|
|
|
|
|
self.start_worker(node)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def run(self):
|
|
|
|
def run(self):
|
|
|
|
while not self.stopping.is_set():
|
|
|
|
while not self.stopping.is_set():
|
|
|
|
new_nodes = set(get_nodes() + self.static_nodes)
|
|
|
|
new_nodes = set(get_nodes() + self.static_nodes)
|
|
|
@ -269,8 +262,6 @@ class BackfillerWorker(object):
|
|
|
|
recent_cutoff -- Skip backfilling segments younger than this number of
|
|
|
|
recent_cutoff -- Skip backfilling segments younger than this number of
|
|
|
|
seconds to prioritise letting the downloader grab these segments."""
|
|
|
|
seconds to prioritise letting the downloader grab these segments."""
|
|
|
|
|
|
|
|
|
|
|
|
#logging.info('Starting backfilling from {}'.format(node))
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
for variant in self.variants:
|
|
|
|
for variant in self.variants:
|
|
|
|
|
|
|
|
|
|
|
|
for hour in hours:
|
|
|
|
for hour in hours:
|
|
|
|