diff options
| author | Alex Auvolat <alex@adnab.me> | 2021-03-16 16:35:10 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2021-03-16 16:35:10 +0100 |
| commit | 3fadc5cbbd5067e160dbe9cf23e301f74a19186e (patch) | |
| tree | 252357775eda37a2c40c153692574ed5d9d70fa6 /src/table/gc.rs | |
| parent | f4346cc5f45839ace93d2d11ce6beea632fd8f2c (diff) | |
| download | garage-3fadc5cbbd5067e160dbe9cf23e301f74a19186e.tar.gz garage-3fadc5cbbd5067e160dbe9cf23e301f74a19186e.zip | |
Small changes
Diffstat (limited to 'src/table/gc.rs')
| -rw-r--r-- | src/table/gc.rs | 13 |
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( |