From d80840d926cd6250cdeab129cad8165c2fa3d006 Mon Sep 17 00:00:00 2001 From: Ivan FB Date: Mon, 4 May 2026 17:21:00 +0200 Subject: [PATCH] move evictPeer proc to allow compilation issue --- waku/node/peer_manager/peer_manager.nim | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/waku/node/peer_manager/peer_manager.nim b/waku/node/peer_manager/peer_manager.nim index c38303209..bed7f8c3c 100644 --- a/waku/node/peer_manager/peer_manager.nim +++ b/waku/node/peer_manager/peer_manager.nim @@ -404,16 +404,6 @@ proc disconnectNode*(pm: PeerManager, peer: RemotePeerInfo) {.async.} = let peerId = peer.peerId await pm.disconnectNode(peerId) -proc evictPeer(pm: PeerManager, peerId: PeerId) {.async.} = - ## Policy-based eviction (relay-peer limit, IP colocation, pruning). - ## Skips the disconnect when the peer has an in-flight store stream to - ## avoid aborting active store requests. - let (storeInPeers, storeOutPeers) = pm.connectedPeers(WakuStoreCodec) - if storeInPeers.contains(peerId) or storeOutPeers.contains(peerId): - trace "skipping peer eviction: active store stream", peerId = peerId - return - await pm.switch.disconnect(peerId) - # Dialing should be used for just protocols that require a stream to write and read # This shall not be used to dial Relay protocols, since that would create # unneccesary unused streams. @@ -529,6 +519,16 @@ proc connectedPeers*( return (inPeers, outPeers) +proc evictPeer(pm: PeerManager, peerId: PeerId) {.async.} = + ## Policy-based eviction (relay-peer limit, IP colocation, pruning). + ## Skips the disconnect when the peer has an in-flight store stream to + ## avoid aborting active store requests. + let (storeInPeers, storeOutPeers) = pm.connectedPeers(WakuStoreCodec) + if storeInPeers.contains(peerId) or storeOutPeers.contains(peerId): + trace "skipping peer eviction: active store stream", peerId = peerId + return + await pm.switch.disconnect(peerId) + proc capablePeers*(pm: PeerManager, protocol: string): (seq[PeerId], seq[PeerId]) = ## Returns the PeerIds of peers with an active socket connection. ## If a protocol is specified, it returns peers that have identified