From a1cdc2b68a38c0fa458cc05a07cfdc463a3e7174 Mon Sep 17 00:00:00 2001
From: Anton Kaliaev <anton.kalyaev@gmail.com>
Date: Thu, 9 Nov 2017 14:57:40 -0500
Subject: [PATCH] set logger for peer's MConnection

---
 consensus/reactor.go | 1 -
 p2p/peer.go          | 6 ++++++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/consensus/reactor.go b/consensus/reactor.go
index 050fdfa40..06af50557 100644
--- a/consensus/reactor.go
+++ b/consensus/reactor.go
@@ -390,7 +390,6 @@ func (conR *ConsensusReactor) broadcastProposalHeartbeatMessage(heartbeat types.
 }
 
 func (conR *ConsensusReactor) broadcastNewRoundStep(rs *cstypes.RoundState) {
-
 	nrsMsg, csMsg := makeRoundStepMessages(rs)
 	if nrsMsg != nil {
 		conR.Switch.Broadcast(StateChannel, struct{ ConsensusMessage }{nrsMsg})
diff --git a/p2p/peer.go b/p2p/peer.go
index 2efe55d26..9ee1c0e32 100644
--- a/p2p/peer.go
+++ b/p2p/peer.go
@@ -11,6 +11,7 @@ import (
 	crypto "github.com/tendermint/go-crypto"
 	wire "github.com/tendermint/go-wire"
 	cmn "github.com/tendermint/tmlibs/common"
+	"github.com/tendermint/tmlibs/log"
 )
 
 // Peer is an interface representing a peer connected on a reactor.
@@ -136,6 +137,11 @@ func newPeerFromConnAndConfig(rawConn net.Conn, outbound bool, reactorsByCh map[
 	return p, nil
 }
 
+func (p *peer) SetLogger(l log.Logger) {
+	p.Logger = l
+	p.mconn.SetLogger(l)
+}
+
 // CloseConn should be used when the peer was created, but never started.
 func (p *peer) CloseConn() {
 	p.conn.Close()