Div target per shard count

waku-org · Oct 30, 2023 · b79983c · b79983c
1 parent 2947dab
commit b79983c
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/waku/node/peer_manager/peer_manager.nim b/waku/node/peer_manager/peer_manager.nim
@@ -635,8 +635,13 @@ proc manageRelayPeers*(pm: PeerManager) {.async.} =
     let connectedOutPeers = peers.filterIt(
       pm.peerStore.isConnected(it.peerId) and it.direction == Outbound)
 
-    let outPeerDiff = pm.outRelayPeersTarget - connectedOutPeers.len
-    let inPeerDiff = pm.inRelayPeersTarget - connectedInPeers.len
+    # 1/3 of relay connection divided by number of shards minus current ones
+    let outPeerDiff =
+      pm.outRelayPeersTarget div pm.wakuMetadata.shards.len - connectedOutPeers.len
+
+    # 2/3 of relay connections divided by number of shards minus current ones
+    let inPeerDiff =
+      pm.inRelayPeersTarget div pm.wakuMetadata.shards.len - connectedInPeers.len
 
     if inPeerDiff <= 0:
       peersToDisconnect += abs(inPeerDiff)