diff options
| author | Alex Auvolat <alex@adnab.me> | 2020-04-19 21:27:08 +0000 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2020-04-19 21:27:08 +0000 |
| commit | ec7f9f07e21ca2771d348b84c6cb14eda64e501c (patch) | |
| tree | eacaa8d5b22c193b576cb20a2e0b83d9c3cc91db /src/block.rs | |
| parent | 04acaea231a9af77e5ca05068336f4492fe32ac0 (diff) | |
| download | garage-ec7f9f07e21ca2771d348b84c6cb14eda64e501c.tar.gz garage-ec7f9f07e21ca2771d348b84c6cb14eda64e501c.zip | |
Implement repair object->version and version->block ref
Diffstat (limited to 'src/block.rs')
| -rw-r--r-- | src/block.rs | 14 |
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; |