forked from Deuxfleurs/garage
I'm stupid though
This commit is contained in:
parent
231cb32955
commit
2556a1e383
1 changed files with 4 additions and 2 deletions
|
@ -280,9 +280,11 @@ impl BlockManager {
|
||||||
let mut need_nodes = vec![];
|
let mut need_nodes = vec![];
|
||||||
for (node, needed) in who.into_iter().zip(who_needs.iter()) {
|
for (node, needed) in who.into_iter().zip(who_needs.iter()) {
|
||||||
match needed {
|
match needed {
|
||||||
Ok(Message::NeedBlockReply(true)) => {
|
Ok(Message::NeedBlockReply(needed)) => {
|
||||||
|
if *needed {
|
||||||
need_nodes.push(node);
|
need_nodes.push(node);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
return Err(Error::Message(format!(
|
return Err(Error::Message(format!(
|
||||||
"Should delete block, but unable to confirm that all other nodes that need it have it: {}",
|
"Should delete block, but unable to confirm that all other nodes that need it have it: {}",
|
||||||
|
|
Loading…
Reference in a new issue