status-im/nimbus-eth1
2
0
Fork 0
mirror of https://github.com/status-im/nimbus-eth1.git synced 2025-01-12 13:24:21 +00:00
Code Issues Projects Releases Wiki Activity

Improve portal wire logging on sending/receiving messages (#874)

Browse Source
This commit is contained in:
Kim De Mey 2021-10-22 11:03:00 +02:00 committed by GitHub
parent 4b85c73f43
commit 4b498356fc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
fluffy/network/wire/portal_protocol.nim
View File

@ -188,7 +188,7 @@ proc messageHandler*(protocol: TalkProtocol, request: seq[byte],
let decoded = decodeMessage(request)
if decoded.isOk():
let message = decoded.get()
trace "Received message response", kind = message.kind
trace "Received message request", srcId, srcUdpAddress, kind = message.kind
case message.kind
of MessageKind.ping:
p.handlePing(message.ping)
@ -199,8 +199,11 @@ proc messageHandler*(protocol: TalkProtocol, request: seq[byte],
of MessageKind.offer:
p.handleOffer(message.offer)
else:
# This shouldn't occur as the 0 case is already covered in `decodedMessage`
debug "Packet decoding error: Invalid message type"
@[]
else:
debug "Packet decoding error", error = decoded.error, srcId, srcUdpAddress
@[]
proc new*(T: type PortalProtocol,
@ -248,8 +251,12 @@ proc reqResponse[Request: SomeMessage, Response: SomeMessage](
)
if messageResponse.isOk():
trace "Received message response", srcId = toNode.id,
srcAddress = toNode.address, kind = messageKind(Response)
p.routingTable.setJustSeen(toNode)
else:
debug "Error receiving message response", error = messageResponse.error,
srcId = toNode.id, srcAddress = toNode.address
p.routingTable.replaceNode(toNode)
return messageResponse