Do not spawn keep alive channel before lock taken

pg-sharding · Mar 29, 2024 · 9079bef · 9079bef
1 parent 7fd4346
commit 9079bef
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/coordinator/provider/coordinator.go b/coordinator/provider/coordinator.go
@@ -215,6 +215,7 @@ var _ coordinator.Coordinator = &qdbCoordinator{}
 // TODO : unit tests
 func (qc *qdbCoordinator) watchRouters(ctx context.Context) {
 	for {
+		/* check we are still coordinator */
 		spqrlog.Zero.Debug().Msg("start routers watch iteration")
 
 		// TODO: lock router
@@ -278,6 +279,7 @@ func (qc *qdbCoordinator) watchRouters(ctx context.Context) {
 			}
 		}
 
+		// TODO: configure sleep
 		time.Sleep(time.Second)
 	}
 }