Isbackup initialization with provided value.

consensus/consensus.go

@@ -53,8 +53,6 @@ type Consensus struct {
 	phase FBFTPhase
 	// current indicates what state a node is in
 	current State
-	// isBackup declarative the node is in backup mode
-	isBackup bool
 	// 2 types of timeouts: normal and viewchange
 	consensusTimeout map[TimeoutType]*utils.Timeout
 	// Commits collected from validators.
@@ -254,9 +252,7 @@ func (consensus *Consensus) getConsensusLeaderPrivateKey() (*bls.PrivateKeyWrapp
 }
 
 func (consensus *Consensus) IsBackup() bool {
-	consensus.mutex.RLock()
-	defer consensus.mutex.RUnlock()
-	return consensus.isBackup
+	return consensus.registry.IsBackup()
 }
 
 func (consensus *Consensus) BlockNum() uint64 {

consensus/consensus_service.go

@@ -199,11 +199,11 @@ func (consensus *Consensus) setMode(m Mode) {
 // SetIsBackup sets the mode of consensus
 func (consensus *Consensus) SetIsBackup(isBackup bool) {
 	consensus.mutex.Lock()
-	defer consensus.mutex.Unlock()
 	consensus.getLogger().Debug().
 		Bool("IsBackup", isBackup).
 		Msg("[SetIsBackup]")
-	consensus.isBackup = isBackup
+	consensus.mutex.Unlock()
+	consensus.registry.SetIsBackup(isBackup)
 }
 
 // Mode returns the mode of consensus

consensus/consensus_v2.go

@@ -106,7 +106,8 @@ func (consensus *Consensus) HandleMessageUpdate(ctx context.Context, peer libp2p
 		consensus.isLeader()
 
 	// if in backup normal mode, force ignore view change event and leader event.
-	if consensus.isBackup {
+	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().
@@ -133,7 +136,7 @@ func (consensus *Consensus) validateNewBlock(recvMsg *FBFTMessage) (*types.Block
 }
 
 func (consensus *Consensus) prepare() {
-	if consensus.isBackup {
+	if consensus.registry.IsBackup() {
 		return
 	}
 
@@ -152,7 +155,8 @@ func (consensus *Consensus) prepare() {
 
 // sendCommitMessages send out commit messages to leader
 func (consensus *Consensus) sendCommitMessages(blockObj *types.Block) {
-	if consensus.isBackup || blockObj == nil {
+	if consensus.IsBackup() || blockObj == nil {
+		consensus.getLogger().Warn().Msg("[sendCommitMessages] I am a backup node, will not send commit message")
 		return
 	}
 

consensus/view_change.go

@@ -231,7 +231,7 @@ func createTimeout() map[TimeoutType]*utils.Timeout {
 
 // startViewChange start the view change process
 func (consensus *Consensus) startViewChange() {
-	if consensus.disableViewChange || consensus.isBackup {
+	if consensus.disableViewChange || consensus.registry.IsBackup() {
 		return
 	}