From 0200eae679cbb04f846f173a9b7b256ed697f500 Mon Sep 17 00:00:00 2001 From: Alex Auvolat Date: Fri, 8 Jul 2022 09:55:27 +0200 Subject: [PATCH] cleanup --- src/block/manager.rs | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/src/block/manager.rs b/src/block/manager.rs index 36166ae3..17d4a72d 100644 --- a/src/block/manager.rs +++ b/src/block/manager.rs @@ -494,11 +494,7 @@ impl BlockManager { fn spawn_background_workers(self: Arc) { // Launch a background workers for background resync loop processing let background = self.system.background.clone(); - let worker = ResyncWorker { - manager: self.clone(), - tranquilizer: Tranquilizer::new(30), - next_delay: Duration::from_secs(10), - }; + let worker = ResyncWorker::new(self.clone()); tokio::spawn(async move { tokio::time::sleep(Duration::from_secs(10)).await; background.spawn_worker(worker); @@ -744,6 +740,16 @@ struct ResyncWorker { next_delay: Duration, } +impl ResyncWorker { + fn new(manager: Arc) -> Self { + Self { + manager, + tranquilizer: Tranquilizer::new(30), + next_delay: Duration::from_secs(10), + } + } +} + #[async_trait] impl Worker for ResyncWorker { fn name(&self) -> String {