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

nph

Browse Source
This commit is contained in:
thatben 2025-01-30 13:51:16 +01:00
parent 668f0b93dc
commit 5cd506dd3b
No known key found for this signature in database
GPG Key ID: 62C543548433D43E
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -246,7 +246,7 @@ proc blockPresenceHandler*(
)
proc scheduleTasks(b: BlockExcEngine, blocksDelivery: seq[BlockDelivery]) {.async.} =
let addresses = blocksDelivery.mapIt( it.address )
let addresses = blocksDelivery.mapIt(it.address)
# schedule any new peers to provide blocks to
for p in b.peers:
for address in addresses:

2
codex/blockexchange/peers/peerctxstore.nim
View File

@ -66,7 +66,7 @@ func peersHave*(self: PeerCtxStore, address: BlockAddress): seq[BlockExcPeerCtx]
toSeq(self.peers.values).filterIt(it.peerHave.anyIt(it == address))
func countPeersWhoHave*(self: PeerCtxStore, cid: Cid): int =
self.peers.values.countIt(it.peerHave.anyIt( it.cidOrTreeCid == cid ) )
self.peers.values.countIt(it.peerHave.anyIt(it.cidOrTreeCid == cid))
func peersWant*(self: PeerCtxStore, address: BlockAddress): seq[BlockExcPeerCtx] =
toSeq(self.peers.values).filterIt(it.peerWants.anyIt(it == address))