logos-messaging/logos-delivery
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-delivery.git synced 2026-04-14 04:03:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix from Ivan's review

Browse Source
This commit is contained in:
Fabiana Cecin 2026-04-06 09:44:06 -03:00
parent d4884185b6
commit 3a7ca52968
No known key found for this signature in database
GPG Key ID: BCAB8A55CB51B6C7
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
waku/node/delivery_service/subscription_manager.nim
View File

@ -388,15 +388,9 @@ proc selectFilterCandidates(
trackedOnOther.incl(peer.peerId)
# Prefer peers we already have a connection to first, preserving shuffle
var candidates: seq[RemotePeerInfo]
for peer in allCandidates:
if peer.peerId in trackedOnOther:
candidates.add(peer)
# Fill with new (not yet used in other shards) peers after, preserving shuffle
for peer in allCandidates:
if peer.peerId notin trackedOnOther:
candidates.add(peer)
var candidates =
allCandidates.filterIt(it.peerId in trackedOnOther) &
allCandidates.filterIt(it.peerId notin trackedOnOther)
# We need to return 'needed' peers only
if candidates.len > needed: