fix leak in startConsensus

0xPolygon · Sep 7, 2022 · 68df30d · 68df30d
1 parent 8e9099a
commit 68df30d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/consensus/ibft/ibft.go b/consensus/ibft/ibft.go
@@ -361,8 +361,10 @@ func (i *backendIBFT) startConsensus() {
 	// to insert a valid block. Used for cancelling active consensus
 	// rounds for a specific height
 	go func() {
+		eventCh := newBlockSub.GetEventCh()
+
 		for {
-			if ev := <-newBlockSub.GetEventCh(); ev.Source == "syncer" {
+			if ev := <-eventCh; ev.Source == "syncer" {
 				if ev.NewChain[0].Number < i.blockchain.Header().Number {
 					// The blockchain notification system can eventually deliver
 					// stale block notifications. These should be ignored