Locks for start.

2 years ago · 696f1a081c
parent 8be3607bf0
commit 696f1a081c
1 changed files with 4 additions and 0 deletions
--- a/consensus/consensus_v2.go
+++ b/consensus/consensus_v2.go
@ -331,12 +331,16 @@ func (consensus *Consensus) Start(
 }

 func (consensus *Consensus) StartChannel() {
+	consensus.mutex.Lock()
 	consensus.isInitialLeader = consensus.IsLeader()
 	if consensus.isInitialLeader {
 		consensus.start = true
 		consensus.getLogger().Info().Time("time", time.Now()).Msg("[ConsensusMainLoop] Send ReadySignal")
+		consensus.mutex.Unlock()
 		consensus.ReadySignal <- SyncProposal
+		return
 	}
+	consensus.mutex.Unlock()
 }

 func (consensus *Consensus) syncReadyChan() {