add debug log

Signed-off-by: Ryan Leung <rleungx@gmail.com>
rleungx · Nov 20, 2024 · 0903d7c · 0903d7c
1 parent 4f97ed8
commit 0903d7c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/syncer/client.go b/pkg/syncer/client.go
@@ -156,6 +156,7 @@ func (s *RegionSyncer) StartSyncWithLeader(addr string) {
 				log.Error("server failed to establish sync stream with leader", zap.String("server", s.server.Name()), zap.String("leader", s.server.GetLeader().GetName()), errs.ZapError(err))
 				select {
 				case <-ctx.Done():
+					log.Info("context is done, server stops to synchronize with leader", zap.String("server", s.server.Name()), zap.String("leader", s.server.GetLeader().GetName()))
 					return
 				case <-time.After(retryInterval):
 				}
@@ -172,6 +173,7 @@ func (s *RegionSyncer) StartSyncWithLeader(addr string) {
 					}
 					select {
 					case <-ctx.Done():
+						log.Info("context is done, server stops to synchronize with leader", zap.String("server", s.server.Name()), zap.String("leader", s.server.GetLeader().GetName()))
 						return
 					case <-time.After(retryInterval):
 					}