mirror of
https://github.com/logos-storage/logos-storage-nim-dht.git
synced 2026-01-02 13:33:08 +00:00
fixup: fix trace messages
This commit is contained in:
parent
db4ccc8bee
commit
7dd0ff1bb6
@ -37,9 +37,9 @@ proc recvAddProvider(p: ProvidersProtocol, nodeId: NodeId, msg: AddProviderMessa
|
||||
proc registerAddProvider(p: ProvidersProtocol) =
|
||||
proc handler(protocol: TalkProtocol, request: seq[byte], fromId: NodeId, fromUdpAddress: Address): seq[byte]
|
||||
{.gcsafe, raises: [Defect].} =
|
||||
trace "<<< add_provider ", src = nodeId, dst = p.discovery.localNode.id, cid = msg.cId, prov=msg.prov
|
||||
#TODO: add checks, add signed version
|
||||
let msg = AddProviderMessage.decode(request).get()
|
||||
trace "<<< add_provider ", src = fromId, dst = p.discovery.localNode.id, cid = msg.cId, prov=msg.prov
|
||||
|
||||
recvAddProvider(p, fromId, msg)
|
||||
|
||||
@ -138,8 +138,8 @@ proc recvGetProviders(p: ProvidersProtocol, nodeId: NodeId, msg: GetProvidersMes
|
||||
proc registerGetProviders(p: ProvidersProtocol) =
|
||||
proc handler(protocol: TalkProtocol, request: seq[byte], fromId: NodeId, fromUdpAddress: Address): seq[byte]
|
||||
{.gcsafe, raises: [Defect].} =
|
||||
trace "<<< get_providers ", src = nodeId, dst = p.discovery.localNode.id, cid = msg.cId
|
||||
let msg = GetProvidersMessage.decode(request).get()
|
||||
trace "<<< get_providers ", src = fromId, dst = p.discovery.localNode.id, cid = msg.cId
|
||||
|
||||
let returnMsg = recvGetProviders(p, fromId, msg)
|
||||
trace "returnMsg", returnMsg
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user