Stop sending blocks and transactions on error
This commit is contained in:
parent
bf1e2bd3b8
commit
9c3f236075
|
@ -911,6 +911,7 @@ where
|
||||||
for transaction in transactions.into_iter() {
|
for transaction in transactions.into_iter() {
|
||||||
if let Err(e) = self.peer_tx.send(Message::Tx(transaction)).await {
|
if let Err(e) = self.peer_tx.send(Message::Tx(transaction)).await {
|
||||||
self.fail_with(e);
|
self.fail_with(e);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -919,6 +920,7 @@ where
|
||||||
for block in blocks.into_iter() {
|
for block in blocks.into_iter() {
|
||||||
if let Err(e) = self.peer_tx.send(Message::Block(block)).await {
|
if let Err(e) = self.peer_tx.send(Message::Block(block)).await {
|
||||||
self.fail_with(e);
|
self.fail_with(e);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue