aboutsummaryrefslogtreecommitdiff
path: root/src/table
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2021-03-16 16:35:10 +0100
committerAlex Auvolat <alex@adnab.me>2021-03-16 16:35:10 +0100
commit3fadc5cbbd5067e160dbe9cf23e301f74a19186e (patch)
tree252357775eda37a2c40c153692574ed5d9d70fa6 /src/table
parentf4346cc5f45839ace93d2d11ce6beea632fd8f2c (diff)
downloadgarage-3fadc5cbbd5067e160dbe9cf23e301f74a19186e.tar.gz
garage-3fadc5cbbd5067e160dbe9cf23e301f74a19186e.zip
Small changes
Diffstat (limited to 'src/table')
-rw-r--r--src/table/gc.rs13
1 files changed, 8 insertions, 5 deletions
diff --git a/src/table/gc.rs b/src/table/gc.rs
index 20ebe3c7..a37c052f 100644
--- a/src/table/gc.rs
+++ b/src/table/gc.rs
@@ -146,16 +146,19 @@ where
.map(|(nodes, items)| self.try_send_and_delete(nodes, items)),
)
.await;
+
+ let mut errs = vec![];
for resp in resps {
if let Err(e) = resp {
- warn!(
- "({}) Unable to send and delete for GC: {}",
- self.data.name, e
- );
+ errs.push(e);
}
}
- Ok(true)
+ if errs.is_empty() {
+ Ok(true)
+ } else {
+ Err(Error::Message(errs.into_iter().map(|x| format!("{}", x)).collect::<Vec<_>>().join(", ")))
+ }
}
async fn try_send_and_delete(