From ca8b611ea8d8602d593696bfde333da6a8e20731 Mon Sep 17 00:00:00 2001
From: Callum Waters <cmwaters19@gmail.com>
Date: Fri, 23 Jul 2021 15:09:23 +0200
Subject: [PATCH] add more p2p logs

---
 internal/p2p/router.go          | 1 +
 internal/p2p/transport_mconn.go | 3 +++
 2 files changed, 4 insertions(+)

diff --git a/internal/p2p/router.go b/internal/p2p/router.go
index 1171566d1..2f74a8859 100644
--- a/internal/p2p/router.go
+++ b/internal/p2p/router.go
@@ -905,6 +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")
 			return err
 		}
 
diff --git a/internal/p2p/transport_mconn.go b/internal/p2p/transport_mconn.go
index eca261476..bdfc46656 100644
--- a/internal/p2p/transport_mconn.go
+++ b/internal/p2p/transport_mconn.go
@@ -362,11 +362,13 @@ func (c *mConnConnection) onError(e interface{}) {
 	if !ok {
 		err = fmt.Errorf("%v", err)
 	}
+	c.logger.Error("error from connection", "err", err)
 	// We have to close the connection here, since MConnection will have stopped
 	// the service on any errors.
 	_ = c.Close()
 	select {
 	case c.errorCh <- err:
+		c.logger.Error("adding error to channel")
 	case <-c.closeCh:
 	}
 }
@@ -410,6 +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)
 		return 0, nil, err
 	case <-c.closeCh:
 		return 0, nil, io.EOF