Skip to content

Commit

Permalink
Silence verbose failed connection logs
Browse files Browse the repository at this point in the history
  • Loading branch information
teor2345 authored Dec 6, 2023
1 parent e692b94 commit d99968a
Showing 1 changed file with 15 additions and 2 deletions.
17 changes: 15 additions & 2 deletions zebra-network/src/peer_set/initialize.rs
Original file line number Diff line number Diff line change
Expand Up @@ -863,8 +863,9 @@ where

// Increment the connection count before we spawn the connection.

Check failure on line 864 in zebra-network/src/peer_set/initialize.rs

View workflow job for this annotation

GitHub Actions / Rustfmt

Diff in /home/runner/work/zebra/zebra/zebra-network/src/peer_set/initialize.rs
let outbound_connection_tracker = active_outbound_connections.track_connection();
let outbound_connections = active_outbound_connections.update_count();
debug!(
outbound_connections = ?active_outbound_connections.update_count(),
?outbound_connections,
"opening an outbound peer connection"
);

Expand Down Expand Up @@ -892,6 +893,7 @@ where
candidate,
outbound_connector,
outbound_connection_tracker,
outbound_connections,
peerset_tx,
address_book_updater,
demand_tx,
Expand Down Expand Up @@ -1026,6 +1028,7 @@ where
#[instrument(skip(
outbound_connector,
outbound_connection_tracker,
outbound_connections,
peerset_tx,
address_book_updater,
demand_tx
Expand All @@ -1034,6 +1037,7 @@ async fn dial<C>(
candidate: MetaAddr,
mut outbound_connector: C,
outbound_connection_tracker: ConnectionTracker,
outbound_connections: usize,
mut peerset_tx: futures::channel::mpsc::Sender<DiscoveredPeer>,
address_book_updater: tokio::sync::mpsc::Sender<MetaAddrChange>,
mut demand_tx: futures::channel::mpsc::Sender<MorePeers>,
Expand All @@ -1048,6 +1052,9 @@ where
+ 'static,
C::Future: Send + 'static,
{
// The maximum number of open or pending connections before we log an info-level message.
const MAX_CONNECTIONS_FOR_INFO_LOG: usize = 5;

// # Correctness
//
// To avoid hangs, the dialer must only await:
Expand Down Expand Up @@ -1076,7 +1083,13 @@ where
}
// The connection was never opened, or it failed the handshake and was dropped.
Err(error) => {
info!(?error, ?candidate.addr, "failed to make outbound connection to peer");
// Silence verbose info logs in production, but keep logs if the number of connections is low.
// Also silence them completely in tests.
if outbound_connections <= MAX_CONNECTIONS_FOR_INFO_LOG && !cfg!(test) {
info!(?error, ?candidate.addr, "failed to make outbound connection to peer");
} else {
debug!(?error, ?candidate.addr, "failed to make outbound connection to peer");
}
report_failed(address_book_updater.clone(), candidate).await;

// The demand signal that was taken out of the queue to attempt to connect to the
Expand Down

0 comments on commit d99968a

Please sign in to comment.