Added additional locks.

2 years ago · 9328a0aea9
parent 0ec4c81121
commit 9328a0aea9
1 changed files with 2 additions and 1 deletions
--- a/consensus/consensus_v2.go
+++ b/consensus/consensus_v2.go
@ -436,7 +436,8 @@ func (consensus *Consensus) BlockChannel(newBlock *types.Block) {
 	consensus.getLogger().Info().Msg("[ConsensusMainLoop] Waiting for Block Time")
 	time.AfterFunc(time.Until(consensus.NextBlockDue), func() {
 		consensus.StartFinalityCount()
-
+		consensus.mutex.Lock()
+		defer consensus.mutex.Unlock()
 		// Update time due for next block
 		consensus.NextBlockDue = time.Now().Add(consensus.BlockPeriod)