diff --git a/consensus/config.go b/consensus/config.go index a99e3b9be..34554f175 100644 --- a/consensus/config.go +++ b/consensus/config.go @@ -17,6 +17,8 @@ const ( consensusBlockNumBuffer uint64 = 2 // ReProposeBlockNumShard0: leader propose this block from it's database and validators accept them ReProposeBlockNumShard0 uint64 = 270108 + // ReProposeBlockNumShard1: leader propose this block from it's database and validators accept them + ReProposeBlockNumShard1 uint64 = 275559 // ReProposeBlockNumShard2: leader propose this block from it's database and validators accept them ReProposeBlockNumShard2 uint64 = 275057 ) diff --git a/consensus/consensus_service.go b/consensus/consensus_service.go index 52cbded6e..acef164da 100644 --- a/consensus/consensus_service.go +++ b/consensus/consensus_service.go @@ -657,6 +657,8 @@ func (consensus *Consensus) NeedsBlockRecovery(blockNum uint64) bool { switch { case blockNum == ReProposeBlockNumShard0 && consensus.ShardID == 0: return true + case blockNum == ReProposeBlockNumShard1 && consensus.ShardID == 1: + return true case blockNum == ReProposeBlockNumShard2 && consensus.ShardID == 2: return true } @@ -668,6 +670,8 @@ func (consensus *Consensus) RecoveryBlockNumber(shardID uint32) uint64 { switch { case consensus.ShardID == 0: return ReProposeBlockNumShard0 + case consensus.ShardID == 1: + return ReProposeBlockNumShard1 case consensus.ShardID == 2: return ReProposeBlockNumShard2 }