p2p: logs++

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", "err", err, "context", "P2P DEBUG")
 			return err
 		}
 

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, "context", "P2P DEBUG")
 	// 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", "err", err, "context", "P2P DEBUG")
 	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, "context", "P2P DEBUG")
 		return 0, nil, err
 	case <-c.closeCh:
 		return 0, nil, io.EOF