codex-storage/nim-codex
1
0
Fork 0
mirror of https://github.com/codex-storage/nim-codex.git synced 2025-02-07 18:43:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

readd eaguer dht lookup is required in some cases

Browse Source
This commit is contained in:
Dmitriy Ryajov 2023-11-23 12:35:21 -06:00 committed by gmega
parent ab8a97118d
commit 2b362dda27
No known key found for this signature in database
GPG Key ID: FFD8DAF00660270F
1 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -184,15 +184,17 @@ proc requestBlock*(
if b.pendingBlocks.isInFlight(address): if b.pendingBlocks.isInFlight(address):
return await blockFuture return await blockFuture
let let peers = b.peers.selectCheapest(address)
peers = b.peers.selectCheapest(address) if peers.len == 0:
maybePeer = b.discovery.queueFindBlocksReq(@[address.cidOrTreeCid])
if peers.len > 0:
peers[hash(address) mod peers.len].some let maybePeer =
elif b.peers.len > 0: if peers.len > 0:
toSeq(b.peers)[hash(address) mod b.peers.len].some peers[hash(address) mod peers.len].some
else: elif b.peers.len > 0:
BlockExcPeerCtx.none toSeq(b.peers)[hash(address) mod b.peers.len].some
else:
BlockExcPeerCtx.none
if peer =? maybePeer: if peer =? maybePeer:
asyncSpawn b.monitorBlockHandle(blockFuture, address, peer.id) asyncSpawn b.monitorBlockHandle(blockFuture, address, peer.id)