logos-storage/logos-storage-nim
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim.git synced 2026-01-05 23:13:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Implement load-balanced peer selection for block requests

Browse Source
This commit is contained in:
Chrysostomos Nanakos 2025-09-12 22:05:38 +03:00
parent 6891824226
commit 7cb4b31557
No known key found for this signature in database
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
codex/blockexchange/engine/engine.nim
View File

@ -836,8 +836,19 @@ proc blockexcTaskRunner(self: BlockExcEngine) {.async: (raises: []).} =
info "Exiting blockexc task runner" info "Exiting blockexc task runner"
proc selectRandom*(peers: seq[BlockExcPeerCtx]): BlockExcPeerCtx = proc selectRandom*(peers: seq[BlockExcPeerCtx]): BlockExcPeerCtx {.gcsafe, raises: [].} =
Rng.instance.sample(peers) if peers.len == 1:
return peers[0]
try:
let sortedPeers = peers.sortedByIt(it.blocksRequested.len)
# Take top 40% of least loaded peers (minimum 3, maximum 8)
let selectionPoolSize = max(3, min(8, int(float(peers.len) * 0.4)))
let candidates = sortedPeers[0 ..< min(selectionPoolSize, sortedPeers.len)]
return Rng.instance.sample(candidates)
except CatchableError:
return Rng.instance.sample(peers)
proc new*( proc new*(
T: type BlockExcEngine, T: type BlockExcEngine,