From abac1f5e06c4370be7c674b4690fa13380b6685f Mon Sep 17 00:00:00 2001
From: earayu <earayu@163.com>
Date: Thu, 28 Dec 2023 19:50:08 +0800
Subject: [PATCH] feat: fix vtconsensus loop

---
 go/vt/vtconsensus/vtconsensus.go | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/go/vt/vtconsensus/vtconsensus.go b/go/vt/vtconsensus/vtconsensus.go
index 5b6eb69a03..37cc1edc5f 100644
--- a/go/vt/vtconsensus/vtconsensus.go
+++ b/go/vt/vtconsensus/vtconsensus.go
@@ -165,7 +165,7 @@ func (vtconsensus *VTConsensus) RefreshCluster() {
 		ticker := time.Tick(refreshInterval)
 		for range ticker {
 			if !enableVtconsensus {
-				return
+				continue
 			}
 			ctx, cancel := context.WithTimeout(vtconsensus.ctx, refreshInterval)
 			shard.RefreshTabletsInShardWithLock(ctx)
@@ -182,10 +182,10 @@ func (vtconsensus *VTConsensus) ScanAndRepair() {
 			scanInterval.Seconds(), scanAndRepairTimeout.Seconds())
 		ticker := time.Tick(scanInterval)
 		for range ticker {
+			if !enableVtconsensus {
+				continue
+			}
 			func() {
-				if !enableVtconsensus {
-					return
-				}
 				ctx, cancel := context.WithTimeout(vtconsensus.ctx, scanAndRepairTimeout)
 				defer cancel()
 				if !vtconsensus.stopped.Get() {