chore(p2p): further debugging

dashpay · Jan 15, 2024 · 23cb8c6 · 23cb8c6
1 parent 66186bd
commit 23cb8c6
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/internal/p2p/router.go b/internal/p2p/router.go
@@ -703,14 +703,18 @@ func (r *Router) routePeer(ctx context.Context, peerID types.NodeID, conn Connec
 
  sendQueue := r.getOrMakeQueue(peerID, channels)
  defer func() {
+ r.logger.Debug("routePeer cleanup: terminated peer", "peer", peerID)
  r.peerMtx.Lock()
  delete(r.peerQueues, peerID)
  delete(r.peerChannels, peerID)
  r.peerMtx.Unlock()
+ r.logger.Debug("routePeer cleanup: deleted peer queues", "peer", peerID)
 
  sendQueue.close()
+ r.logger.Debug("routePeer cleanup: closed send queue", "peer", peerID)
 
  r.peerManager.Disconnected(ctx, peerID)
+ r.logger.Debug("routePeer cleanup: peer marked as disconnected", "peer", peerID)
  r.metrics.PeersConnected.Add(-1)
  }()