aboutsummaryrefslogtreecommitdiff
path: root/src/block.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/block.rs')
-rw-r--r--src/block.rs14
1 files changed, 1 insertions, 13 deletions
diff --git a/src/block.rs b/src/block.rs
index 4ad74d76..11818fd8 100644
--- a/src/block.rs
+++ b/src/block.rs
@@ -358,19 +358,7 @@ impl BlockManager {
Ok(())
}
- pub async fn launch_repair(self: &Arc<Self>) -> Result<(), Error> {
- let self2 = self.clone();
- self.system
- .background
- .spawn_worker(move |must_exit| async move { self2.repair_worker(must_exit).await })
- .await;
- Ok(())
- }
-
- pub async fn repair_worker(
- self: Arc<Self>,
- must_exit: watch::Receiver<bool>,
- ) -> Result<(), Error> {
+ pub async fn repair_data_store(&self, must_exit: &watch::Receiver<bool>) -> Result<(), Error> {
// 1. Repair blocks from RC table
let garage = self.garage.load_full().unwrap();
let mut last_hash = None;