From c69223d2c12ce78232f781e1ec43bebfce1fa371 Mon Sep 17 00:00:00 2001 From: Aleksandr Bezobchuk Date: Fri, 23 Jul 2021 09:16:09 -0400 Subject: [PATCH] p2p: logs++ --- internal/p2p/router.go | 2 +- internal/p2p/transport_mconn.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/p2p/router.go b/internal/p2p/router.go index 2f74a8859..878f1a847 100644 --- a/internal/p2p/router.go +++ b/internal/p2p/router.go @@ -905,7 +905,7 @@ func (r *Router) receivePeer(peerID types.NodeID, conn Connection) error { for { chID, bz, err := conn.ReceiveMessage() if err != nil { - r.logger.Error("received error from receive message") + r.logger.Error("received error from receive message", "err", err, "context", "P2P DEBUG") return err } diff --git a/internal/p2p/transport_mconn.go b/internal/p2p/transport_mconn.go index bdfc46656..7ff5fb6e0 100644 --- a/internal/p2p/transport_mconn.go +++ b/internal/p2p/transport_mconn.go @@ -368,7 +368,7 @@ func (c *mConnConnection) onError(e interface{}) { _ = c.Close() select { case c.errorCh <- err: - c.logger.Error("adding error to channel") + c.logger.Error("adding error to channel", "err", err, "context", "P2P DEBUG") case <-c.closeCh: } } @@ -412,7 +412,7 @@ func (c *mConnConnection) TrySendMessage(chID ChannelID, msg []byte) (bool, erro func (c *mConnConnection) ReceiveMessage() (ChannelID, []byte, error) { select { case err := <-c.errorCh: - c.logger.Error("propagating error message to router", "err", err) + c.logger.Error("propagating error message to router", "err", err, "context", "P2P DEBUG") return 0, nil, err case <-c.closeCh: return 0, nil, io.EOF