etcdutil, leadership: avoid redundant created watch channel (#7352) (#…

…7353) close #7351 Signed-off-by: lhy1024 <admin@liudos.us> Co-authored-by: lhy1024 <admin@liudos.us>
tikv · Nov 10, 2023 · d0a17ca · d0a17ca
1 parent d09a4f5
commit d0a17ca
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/pkg/election/leadership.go b/pkg/election/leadership.go
@@ -260,6 +260,7 @@ func (ls *Leadership) Watch(serverCtx context.Context, revision int64) {
 				continue
 			}
 		}
+		lastReceivedResponseTime = time.Now()
 		log.Info("watch channel is created", zap.Int64("revision", revision), zap.String("leader-key", ls.leaderKey), zap.String("purpose", ls.purpose))
 
 	watchChanLoop:

diff --git a/pkg/utils/etcdutil/etcdutil.go b/pkg/utils/etcdutil/etcdutil.go
@@ -707,7 +707,6 @@ func (lw *LoopWatcher) watch(ctx context.Context, revision int64) (nextRevision
 	}()
 	ticker := time.NewTicker(RequestProgressInterval)
 	defer ticker.Stop()
-	lastReceivedResponseTime := time.Now()
 
 	for {
 		if watcherCancel != nil {
@@ -736,8 +735,10 @@ func (lw *LoopWatcher) watch(ctx context.Context, revision int64) (nextRevision
 				continue
 			}
 		}
+		lastReceivedResponseTime := time.Now()
 		log.Info("watch channel is created in watch loop",
 			zap.Int64("revision", revision), zap.String("name", lw.name), zap.String("key", lw.key))
+
 	watchChanLoop:
 		select {
 		case <-ctx.Done():