status-im
/
nim-eth
mirror of https://github.com/status-im/nim-eth.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Do not send empty messages packets at interval

This commit is contained in:
kdeme 2019-12-03 16:49:20 +01:00
parent 146eeddd65
commit 2dcccf19b2
2 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
eth/p2p/rlpx_protocols/waku_protocol.nim
View File

@ -270,10 +270,11 @@ proc processQueue(peer: Peer) =
envelopes.add(message.env)
wakuPeer.received.incl(message)
trace "Sending envelopes", amount=envelopes.len
# Ignore failure of sending messages, this could occur when the connection
# gets dropped
traceAsyncErrors peer.messages(envelopes)
if envelopes.len() > 0:
trace "Sending envelopes", amount=envelopes.len
# Ignore failure of sending messages, this could occur when the connection
# gets dropped
traceAsyncErrors peer.messages(envelopes)
proc run(peer: Peer) {.async.} =
while peer.connectionState notin {Disconnecting, Disconnected}:

9
eth/p2p/rlpx_protocols/whisper_protocol.nim
View File

@ -265,10 +265,11 @@ proc processQueue(peer: Peer) =
envelopes.add(message.env)
whisperPeer.received.incl(message)
trace "Sending envelopes", amount=envelopes.len
# Ignore failure of sending messages, this could occur when the connection
# gets dropped
traceAsyncErrors peer.messages(envelopes)
if envelopes.len() > 0:
trace "Sending envelopes", amount=envelopes.len
# Ignore failure of sending messages, this could occur when the connection
# gets dropped
traceAsyncErrors peer.messages(envelopes)
proc run(peer: Peer) {.async.} =
while peer.connectionState notin {Disconnecting, Disconnected}: