diff --git a/blockchain/reactor.go b/blockchain/reactor.go index 971c72a36..bc5bb38f0 100644 --- a/blockchain/reactor.go +++ b/blockchain/reactor.go @@ -203,7 +203,7 @@ FOR_LOOP: maxPending := bcR.pool.numPending == maxPendingRequests maxPeerless := bcR.pool.peerless == bcR.pool.numPending o, i, _ := bcR.sw.NumPeers() - enoughPeers := o+i > 5 + enoughPeers := o+i >= 5 if maxPending && maxPeerless && enoughPeers { log.Warn("Time to switch to consensus reactor!", "height", bcR.pool.height) bcR.pool.Stop() diff --git a/consensus/reactor.go b/consensus/reactor.go index fd8887281..3926bfd52 100644 --- a/consensus/reactor.go +++ b/consensus/reactor.go @@ -245,6 +245,7 @@ func (conR *ConsensusReactor) SetPrivValidator(priv *sm.PrivValidator) { // Reset to some state. func (conR *ConsensusReactor) ResetToState(state *sm.State) { conR.conS.updateToState(state, false) + conR.conS.newStepCh <- conR.conS.getRoundState() } // implements events.Eventable