mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-02-03 10:32:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

p2p: logs++

Browse Source
This commit is contained in:
Aleksandr Bezobchuk
2021-07-23 09:16:09 -04:00
parent ca8b611ea8
commit c69223d2c1
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/p2p/router.go
View File

@@ -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
}

4
internal/p2p/transport_mconn.go
View File

@@ -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