Fix: null-ref in networkPeer (#937)
* Fixes nullref in networkPeer
* Removes inflight semaphore
* Revert "Removes inflight semaphore"
This reverts commit 26ec15c6f7
.
This commit is contained in:
parent
0ea8cfb085
commit
17f0988fc7
|
@ -93,18 +93,20 @@ proc send*(b: BlockExcNetwork, id: PeerId, msg: pb.Message) {.async.} =
|
||||||
## Send message to peer
|
## Send message to peer
|
||||||
##
|
##
|
||||||
|
|
||||||
b.peers.withValue(id, peer):
|
if not (id in b.peers):
|
||||||
try:
|
|
||||||
await b.inflightSema.acquire()
|
|
||||||
await peer[].send(msg)
|
|
||||||
except CancelledError as error:
|
|
||||||
raise error
|
|
||||||
except CatchableError as err:
|
|
||||||
error "Error sending message", peer = id, msg = err.msg
|
|
||||||
finally:
|
|
||||||
b.inflightSema.release()
|
|
||||||
do:
|
|
||||||
trace "Unable to send, peer not found", peerId = id
|
trace "Unable to send, peer not found", peerId = id
|
||||||
|
return
|
||||||
|
|
||||||
|
let peer = b.peers[id]
|
||||||
|
try:
|
||||||
|
await b.inflightSema.acquire()
|
||||||
|
await peer.send(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(
|
proc handleWantList(
|
||||||
b: BlockExcNetwork,
|
b: BlockExcNetwork,
|
||||||
|
|
Loading…
Reference in New Issue