github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-27 16:18:08 -05:00
Code Issues Packages Projects Releases Wiki Activity

feat(net/peer): simple support rank higher with static peer (#9471)

Browse Source 
Signed-off-by: jsvisa <delweng@gmail.com>
Co-authored-by: Matthias Seitz <matthias.seitz@outlook.de>
This commit is contained in:
Delweng
2024-07-12 19:20:34 +08:00
committed by GitHub
parent df9cb81ea6
commit d943e78294
1 changed files with 16 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
crates/net/network/src/peers.rs
View File

@@ -375,8 +375,9 @@ impl PeersManager {
fn ban_peer(&mut self, peer_id: PeerId) {
let mut ban_duration = self.ban_duration;
if let Some(peer) = self.peers.get(&peer_id) {
if peer.is_trusted() {
// For misbehaving trusted peers, we provide a bit more leeway when penalizing them.
if peer.is_trusted() || peer.is_static() {
// For misbehaving trusted or static peers, we provide a bit more leeway when
// penalizing them.
ban_duration = self.backoff_durations.medium;
}
}
@@ -446,8 +447,8 @@ impl PeersManager {
peer.reset_reputation()
} else {
let mut reputation_change = self.reputation_weights.change(rep).as_i32();
if peer.is_trusted() {
// exempt trusted peers from reputation slashing for
if peer.is_trusted() || peer.is_static() {
// exempt trusted and static peers from reputation slashing for
if matches!(
rep,
ReputationChangeKind::Dropped |
@@ -781,8 +782,8 @@ impl PeersManager {
/// Returns the idle peer with the highest reputation.
///
/// Peers that are `trusted`, see [`PeerKind`], are prioritized as long as they're not currently
/// marked as banned or backed off.
/// Peers that are `trusted` or `static`, see [`PeerKind`], are prioritized as long as they're
/// not currently marked as banned or backed off.
///
/// If `trusted_nodes_only` is enabled, see [`PeersConfig`], then this will only consider
/// `trusted` peers.
@@ -799,13 +800,13 @@ impl PeersManager {
// keep track of the best peer, if there's one
let mut best_peer = unconnected.next()?;
if best_peer.1.is_trusted() {
if best_peer.1.is_trusted() || best_peer.1.is_static() {
return Some((*best_peer.0, best_peer.1))
}
for maybe_better in unconnected {
// if the peer is trusted, return it immediately
if maybe_better.1.is_trusted() {
// if the peer is trusted or static, return it immediately
if maybe_better.1.is_trusted() || maybe_better.1.is_static() {
return Some((*maybe_better.0, maybe_better.1))
}
@@ -1152,6 +1153,12 @@ impl Peer {
const fn is_trusted(&self) -> bool {
matches!(self.kind, PeerKind::Trusted)
}
/// Returns whether this peer is static
#[inline]
const fn is_static(&self) -> bool {
matches!(self.kind, PeerKind::Static)
}
}
/// Outcomes when a reputation change is applied to a peer