Tweak logging; allow consensus to bypass filter

consensus/log.go

@@ -4,4 +4,13 @@ import (
 	"github.com/tendermint/go-logger"
 )
 
-var log = logger.New("module", "consensus")
+var log = logger.NewBypass("module", "consensus")
+
+func init() {
+	log.SetHandler(
+		logger.LvlFilterHandler(
+			logger.LvlDebug,
+			logger.BypassHandler(),
+		),
+	)
+}

consensus/state.go

@@ -154,7 +154,7 @@ func (rs *RoundState) StringShort() string {
 type ConsensusState struct {
 	BaseService
 
-	proxyAppCtx      proxy.AppContext
+	proxyAppCtx   proxy.AppContext
 	blockStore    *bc.BlockStore
 	mempool       *mempl.Mempool
 	privValidator *types.PrivValidator
@@ -172,10 +172,10 @@ type ConsensusState struct {
 
 func NewConsensusState(state *sm.State, proxyAppCtx proxy.AppContext, blockStore *bc.BlockStore, mempool *mempl.Mempool) *ConsensusState {
 	cs := &ConsensusState{
-		proxyAppCtx:   proxyAppCtx,
+		proxyAppCtx: proxyAppCtx,
-		blockStore: blockStore,
+		blockStore:  blockStore,
-		mempool:    mempool,
+		mempool:     mempool,
-		newStepCh:  make(chan *RoundState, 10),
+		newStepCh:   make(chan *RoundState, 10),
 	}
 	cs.updateToState(state)
 	// Don't call scheduleRound0 yet.
@@ -532,8 +532,10 @@ func (cs *ConsensusState) EnterPrevote(height int, round int, timedOut bool) {
 
 	// fire event for how we got here
 	if timedOut {
+		log.Debug("Propose timed out")
 		cs.evsw.FireEvent(types.EventStringTimeoutPropose(), cs.RoundStateEvent())
 	} else if cs.isProposalComplete() {
+		log.Debug("Propose is complete")
 		cs.evsw.FireEvent(types.EventStringCompleteProposal(), cs.RoundStateEvent())
 	} else {
 		// we received +2/3 prevotes for a future round

mempool/reactor.go

@@ -63,7 +63,7 @@ func (memR *MempoolReactor) Receive(chID byte, src *p2p.Peer, msgBytes []byte) {
 		log.Warn("Error decoding message", "error", err)
 		return
 	}
-	log.Notice("MempoolReactor received message", "msg", msg)
+	log.Info("MempoolReactor received message", "msg", msg)
 
 	switch msg := msg.(type) {
 	case *TxMessage: