mirror of https://github.com/waku-org/nwaku.git
adding debug logs
This commit is contained in:
parent
5e7e8436fe
commit
b3f630b615
|
@ -116,33 +116,42 @@ proc insertOrReplace(ps: PeerStorage, remotePeerInfo: RemotePeerInfo) =
|
||||||
proc addPeer*(pm: PeerManager, remotePeerInfo: RemotePeerInfo, origin = UnknownOrigin) =
|
proc addPeer*(pm: PeerManager, remotePeerInfo: RemotePeerInfo, origin = UnknownOrigin) =
|
||||||
## Adds peer to manager for the specified protocol
|
## Adds peer to manager for the specified protocol
|
||||||
|
|
||||||
|
echo "-------------- addPeer 1 ----------------"
|
||||||
|
|
||||||
if remotePeerInfo.peerId == pm.switch.peerInfo.peerId:
|
if remotePeerInfo.peerId == pm.switch.peerInfo.peerId:
|
||||||
# Do not attempt to manage our unmanageable self
|
# Do not attempt to manage our unmanageable self
|
||||||
|
echo "-------------- addPeer 2 ----------------"
|
||||||
return
|
return
|
||||||
|
|
||||||
if pm.peerStore[AddressBook][remotePeerInfo.peerId] == remotePeerInfo.addrs and
|
if pm.peerStore[AddressBook][remotePeerInfo.peerId] == remotePeerInfo.addrs and
|
||||||
pm.peerStore[KeyBook][remotePeerInfo.peerId] == remotePeerInfo.publicKey and
|
pm.peerStore[KeyBook][remotePeerInfo.peerId] == remotePeerInfo.publicKey and
|
||||||
pm.peerStore[ENRBook][remotePeerInfo.peerId].raw.len > 0:
|
pm.peerStore[ENRBook][remotePeerInfo.peerId].raw.len > 0:
|
||||||
# Peer already managed and ENR info is already saved
|
# Peer already managed and ENR info is already saved
|
||||||
|
echo "-------------- addPeer 3 ----------------"
|
||||||
return
|
return
|
||||||
|
|
||||||
trace "Adding peer to manager", peerId = remotePeerInfo.peerId, addresses = remotePeerInfo.addrs
|
trace "Adding peer to manager", peerId = remotePeerInfo.peerId, addresses = remotePeerInfo.addrs
|
||||||
|
|
||||||
|
echo "-------------- addPeer 4 ----------------"
|
||||||
pm.peerStore[AddressBook][remotePeerInfo.peerId] = remotePeerInfo.addrs
|
pm.peerStore[AddressBook][remotePeerInfo.peerId] = remotePeerInfo.addrs
|
||||||
pm.peerStore[KeyBook][remotePeerInfo.peerId] = remotePeerInfo.publicKey
|
pm.peerStore[KeyBook][remotePeerInfo.peerId] = remotePeerInfo.publicKey
|
||||||
pm.peerStore[SourceBook][remotePeerInfo.peerId] = origin
|
pm.peerStore[SourceBook][remotePeerInfo.peerId] = origin
|
||||||
|
|
||||||
if remotePeerInfo.protocols.len > 0:
|
if remotePeerInfo.protocols.len > 0:
|
||||||
|
echo "-------------- addPeer 5 ----------------"
|
||||||
pm.peerStore[ProtoBook][remotePeerInfo.peerId] = remotePeerInfo.protocols
|
pm.peerStore[ProtoBook][remotePeerInfo.peerId] = remotePeerInfo.protocols
|
||||||
|
|
||||||
if remotePeerInfo.enr.isSome():
|
if remotePeerInfo.enr.isSome():
|
||||||
|
echo "-------------- addPeer 6 ----------------"
|
||||||
pm.peerStore[ENRBook][remotePeerInfo.peerId] = remotePeerInfo.enr.get()
|
pm.peerStore[ENRBook][remotePeerInfo.peerId] = remotePeerInfo.enr.get()
|
||||||
|
|
||||||
# Add peer to storage. Entry will subsequently be updated with connectedness information
|
# Add peer to storage. Entry will subsequently be updated with connectedness information
|
||||||
if not pm.storage.isNil:
|
if not pm.storage.isNil:
|
||||||
remotePeerInfo.connectedness = NotConnected
|
remotePeerInfo.connectedness = NotConnected
|
||||||
|
echo "-------------- addPeer 7 ----------------"
|
||||||
|
|
||||||
pm.storage.insertOrReplace(remotePeerInfo)
|
pm.storage.insertOrReplace(remotePeerInfo)
|
||||||
|
echo "-------------- addPeer 8 ----------------"
|
||||||
|
|
||||||
# Connects to a given node. Note that this function uses `connect` and
|
# Connects to a given node. Note that this function uses `connect` and
|
||||||
# does not provide a protocol. Streams for relay (gossipsub) are created
|
# does not provide a protocol. Streams for relay (gossipsub) are created
|
||||||
|
|
|
@ -191,9 +191,12 @@ proc searchLoop(wd: WakuDiscoveryV5) {.async.} =
|
||||||
let discoveredRecords = await wd.findRandomPeers()
|
let discoveredRecords = await wd.findRandomPeers()
|
||||||
let discoveredPeers = discoveredRecords.mapIt(it.toRemotePeerInfo()).filterIt(it.isOk()).mapIt(it.value)
|
let discoveredPeers = discoveredRecords.mapIt(it.toRemotePeerInfo()).filterIt(it.isOk()).mapIt(it.value)
|
||||||
|
|
||||||
|
echo "-------------- discoveredPeers.len: ", discoveredPeers.len
|
||||||
for peer in discoveredPeers:
|
for peer in discoveredPeers:
|
||||||
|
echo "peer: ", peer
|
||||||
# Peers added are filtered by the peer manager
|
# Peers added are filtered by the peer manager
|
||||||
peerManager.addPeer(peer, PeerOrigin.Discv5)
|
peerManager.addPeer(peer, PeerOrigin.Discv5)
|
||||||
|
echo "---------------------------------------------"
|
||||||
|
|
||||||
# Discovery `queryRandom` can have a synchronous fast path for example
|
# Discovery `queryRandom` can have a synchronous fast path for example
|
||||||
# when no peers are in the routing table. Don't run it in continuous loop.
|
# when no peers are in the routing table. Don't run it in continuous loop.
|
||||||
|
|
Loading…
Reference in New Issue