octo
/
Zebra
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Log initial peer connection failures 

And standardise another log message
This commit is contained in:
teor 2021-02-17 11:01:36 +10:00 committed by Deirdre Connolly
parent 1ef836abb9
commit 8d1c498234
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
zebra-network/src/peer_set/initialize.rs
View File

@ -193,7 +193,7 @@ where
S: Service<SocketAddr, Response = Change<SocketAddr, peer::Client>, Error = BoxError> + Clone, S: Service<SocketAddr, Response = Change<SocketAddr, peer::Client>, Error = BoxError> + Clone,
S::Future: Send + 'static, S::Future: Send + 'static,
{ {
info!(?initial_peers, "Connecting to initial peer set"); info!(?initial_peers, "connecting to initial peer set");
// ## Correctness: // ## Correctness:
// //
// Each `CallAll` can hold one `Buffer` or `Batch` reservation for // Each `CallAll` can hold one `Buffer` or `Batch` reservation for
@ -205,6 +205,10 @@ where
let mut handshakes = CallAllUnordered::new(connector, addr_stream); let mut handshakes = CallAllUnordered::new(connector, addr_stream);
while let Some(handshake_result) = handshakes.next().await { while let Some(handshake_result) = handshakes.next().await {
// this is verbose, but it's better than just hanging with no output
if let Err(ref e) = handshake_result {
info!(?e, "an initial peer connection failed");
}
tx.send(handshake_result).await?; tx.send(handshake_result).await?;
} }