diff --git a/consensus/byzantine_test.go b/consensus/byzantine_test.go index 9508b02eb..d06a2456e 100644 --- a/consensus/byzantine_test.go +++ b/consensus/byzantine_test.go @@ -625,4 +625,7 @@ func (br *ByzantineReactor) RemovePeer(peer p2p.Peer, reason interface{}) { func (br *ByzantineReactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) { br.reactor.Receive(chID, peer, msgBytes) } +func (br *ByzantineReactor) NewReceive(e p2p.Envelope) { + br.reactor.NewReceive(e) +} func (br *ByzantineReactor) InitPeer(peer p2p.Peer) p2p.Peer { return peer } diff --git a/consensus/reactor.go b/consensus/reactor.go index 18d6fc319..7b3b453de 100644 --- a/consensus/reactor.go +++ b/consensus/reactor.go @@ -228,6 +228,7 @@ func (conR *Reactor) RemovePeer(peer p2p.Peer, reason interface{}) { // proposals, block parts, and votes are ordered by the receiveRoutine // NOTE: blocks on consensus state for proposals, block parts, and votes func (conR *Reactor) Receive(chID byte, src p2p.Peer, msgBytes []byte) { + return //disable and rely on the NewReceive if !conR.IsRunning() { conR.Logger.Debug("Receive", "src", src, "chId", chID, "bytes", msgBytes) return