Deuxfleurs/garage
48
56
Fork 73
Code Issues 100 Pull requests 13 Releases 30 Wiki Activity

Small things
Some checks failed
continuous-integration/drone/pr Build is failing
Details
continuous-integration/drone/push Build is passing
Details

Browse source
This commit is contained in:
Alex 2022-06-28 17:42:54 +02:00
parent fc2bc8b0ca
commit 368414a261
Signed by: lx
GPG key ID: 0E496D15096376BE
2 changed files with 9 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/block/repair.rs
View file

@ -381,7 +381,7 @@ impl BlockStoreIterator {
} }
} }
/// Returns progress done, between 0% and 1% /// Returns progress done, between 0 and 1
fn progress(&self) -> f32 { fn progress(&self) -> f32 {
if self.path.is_empty() { if self.path.is_empty() {
1.0 1.0
@ -453,7 +453,6 @@ impl BlockStoreIterator {
if name.len() == 2 && hex::decode(&name).is_ok() && ent_type.is_dir() { if name.len() == 2 && hex::decode(&name).is_ok() && ent_type.is_dir() {
let path = data_dir_ent.path(); let path = data_dir_ent.path();
self.path.push(ReadingDir::Pending(path)); self.path.push(ReadingDir::Pending(path));
continue;
} else if name.len() == 64 { } else if name.len() == 64 {
let hash_bytes = if let Ok(h) = hex::decode(&name) { let hash_bytes = if let Ok(h) = hex::decode(&name) {
h h

8
src/garage/repair/online.rs
View file

@ -85,6 +85,10 @@ impl Worker for RepairVersionsWorker {
"Version repair worker".into() "Version repair worker".into()
} }
fn info(&self) -> Option<String> {
Some(format!("{} items done", self.counter))
}
async fn work( async fn work(
&mut self, &mut self,
_must_exit: &mut watch::Receiver<bool>, _must_exit: &mut watch::Receiver<bool>,
@ -165,6 +169,10 @@ impl Worker for RepairBlockrefsWorker {
"Block refs repair worker".into() "Block refs repair worker".into()
} }
fn info(&self) -> Option<String> {
Some(format!("{} items done", self.counter))
}
async fn work( async fn work(
&mut self, &mut self,
_must_exit: &mut watch::Receiver<bool>, _must_exit: &mut watch::Receiver<bool>,