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

Update semaphore

Browse Source
This commit is contained in:
Arnaud 2026-06-03 09:36:50 +04:00
parent 0c08053f30
commit 9617b8fbcd
No known key found for this signature in database
GPG Key ID: A6C7C781817146FA
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
storage/blockexchange/network/network.nim
View File

@ -13,7 +13,7 @@ import std/sequtils
import pkg/chronos
import pkg/libp2p
import pkg/libp2p/utils/semaphore
import pkg/chronos/asyncsync
import pkg/questionable
import pkg/questionable/results
@ -107,13 +107,17 @@ proc send*(
let peer = b.peers[id]
await b.inflightSema.acquire()
await peer.send(msg)
try:
await peer.send(msg)
finally:
try:
b.inflightSema.release()
except AsyncSemaphoreError as err:
error "Failed to release semaphore", msg = err.msg
except CancelledError as error:
raise error
except CatchableError as err:
error "Error sending message", peer = id, msg = err.msg
finally:
b.inflightSema.release()
proc handleWantList(
b: BlockExcNetwork, peer: NetworkPeer, list: WantList
@ -316,7 +320,7 @@ proc new*(
maxInflight: maxInflight,
)
self.maxIncomingStreams = self.maxInflight
#self.maxIncomingStreams = self.maxInflight
proc sendWantList(
id: PeerId,