Additional isBackup checks.

consensus/consensus_v2.go

@@ -107,6 +107,7 @@ func (consensus *Consensus) HandleMessageUpdate(ctx context.Context, peer libp2p
 
 	// if in backup normal mode, force ignore view change event and leader event.
 	if consensus.registry.IsBackup() {
+		consensus.getLogger().Info().Msgf("IsBackup: true")
 		canHandleViewChange = false
 		intendedForLeader = false
 	}
@@ -424,7 +425,7 @@ func (consensus *Consensus) BlockChannel(newBlock *types.Block) {
 		Msg("[ConsensusMainLoop] Received Proposed New Block!")
 
 	if newBlock.NumberU64() < consensus.BlockNum() {
-		consensus.getLogger().Warn().Uint64("newBlockNum", newBlock.NumberU64()).
+		consensus.GetLogger().Warn().Uint64("newBlockNum", newBlock.NumberU64()).
 			Msg("[ConsensusMainLoop] received old block, abort")
 		return
 	}

consensus/leader.go

@@ -18,6 +18,10 @@ import (
 
 // announce fires leader
 func (consensus *Consensus) announce(block *types.Block) {
+	if consensus.registry.IsBackup() {
+		consensus.getLogger().Warn().Msg("[Announce] I am a backup node")
+		return
+	}
 	blockHash := block.Hash()
 
 	// prepare message and broadcast to validators

consensus/validator.go

@@ -18,6 +18,9 @@ import (
 )
 
 func (consensus *Consensus) onAnnounce(msg *msg_pb.Message) {
+	if consensus.registry.IsBackup() {
+		return
+	}
 	recvMsg, err := consensus.parseFBFTMessage(msg)
 	if err != nil {
 		consensus.getLogger().Error().