github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-02-19 03:04:27 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix(net): correct backed_off_peers metric calculation (#21885)

Browse Source
This commit is contained in:
andrewshab
2026-02-06 14:08:22 +01:00
committed by GitHub
parent a16ee22a56
commit 8629c55152
1 changed files with 12 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
crates/net/network/src/manager.rs
View File

@@ -872,14 +872,9 @@ impl<N: NetworkPrimitives> NetworkManager<N> {
if let Some(reason) = reason {
self.disconnect_metrics.increment(reason);
}
self.metrics.backed_off_peers.set(
self.swarm
.state()
.peers()
.num_backed_off_peers()
.saturating_sub(1)
as f64,
);
self.metrics
.backed_off_peers
.set(self.swarm.state().peers().num_backed_off_peers() as f64);
self.event_sender
.notify(NetworkEvent::Peer(PeerEvent::SessionClosed { peer_id, reason }));
}
@@ -910,14 +905,9 @@ impl<N: NetworkPrimitives> NetworkManager<N> {
self.metrics
.incoming_connections
.set(self.swarm.state().peers().num_inbound_connections() as f64);
self.metrics.backed_off_peers.set(
self.swarm
.state()
.peers()
.num_backed_off_peers()
.saturating_sub(1)
as f64,
);
self.metrics
.backed_off_peers
.set(self.swarm.state().peers().num_backed_off_peers() as f64);
}
SwarmEvent::OutgoingPendingSessionClosed { remote_addr, peer_id, error } => {
trace!(
@@ -947,14 +937,9 @@ impl<N: NetworkPrimitives> NetworkManager<N> {
self.metrics.closed_sessions.increment(1);
self.update_pending_connection_metrics();
self.metrics.backed_off_peers.set(
self.swarm
.state()
.peers()
.num_backed_off_peers()
.saturating_sub(1)
as f64,
);
self.metrics
.backed_off_peers
.set(self.swarm.state().peers().num_backed_off_peers() as f64);
}
SwarmEvent::OutgoingConnectionError { remote_addr, peer_id, error } => {
trace!(
@@ -971,14 +956,9 @@ impl<N: NetworkPrimitives> NetworkManager<N> {
&error,
);
self.metrics.backed_off_peers.set(
self.swarm
.state()
.peers()
.num_backed_off_peers()
.saturating_sub(1)
as f64,
);
self.metrics
.backed_off_peers
.set(self.swarm.state().peers().num_backed_off_peers() as f64);
self.update_pending_connection_metrics();
}
SwarmEvent::BadMessage { peer_id } => {