From 4d4117f2b4eb69b63e2329f6e0b8929e6a8b5b31 Mon Sep 17 00:00:00 2001
From: Alex Auvolat <alex@adnab.me>
Date: Mon, 15 Mar 2021 20:09:44 +0100
Subject: Refactor block resync loop; make workers infaillible

---
 src/garage/repair.rs | 10 ++++++++++
 1 file changed, 10 insertions(+)

(limited to 'src/garage')

diff --git a/src/garage/repair.rs b/src/garage/repair.rs
index 599c1965..4ee66452 100644
--- a/src/garage/repair.rs
+++ b/src/garage/repair.rs
@@ -20,6 +20,16 @@ impl Repair {
 		&self,
 		opt: RepairOpt,
 		must_exit: watch::Receiver<bool>,
+	) {
+		if let Err(e) = self.repair_worker_aux(opt, must_exit).await {
+			warn!("Repair worker failed with error: {}", e);
+		}
+	}
+
+	async fn repair_worker_aux(
+		&self,
+		opt: RepairOpt,
+		must_exit: watch::Receiver<bool>,
 	) -> Result<(), Error> {
 		let todo = |x| opt.what.as_ref().map(|y| *y == x).unwrap_or(true);
 
-- 
cgit v1.2.3