fix: start informer when controller is leader

kubeovn · May 15, 2019 · 0f9d1e4 · 0f9d1e4
1 parent 22da454
commit 0f9d1e4
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go
@@ -197,8 +197,8 @@ func (c *Controller) Run(stopCh <-chan struct{}) error {
 	})
 	c.elector = elector
 	for {
-		klog.Info("waiting for a leader")
-		if c.hasLeader() {
+		klog.Info("waiting for becoming a leader")
+		if c.isLeader() {
 			break
 		}
 		time.Sleep(1 * time.Second)

diff --git a/pkg/controller/election.go b/pkg/controller/election.go
@@ -68,6 +68,7 @@ func setupLeaderElection(config *leaderElectionConfig) *leaderelection.LeaderEle
 			if config.OnStoppedLeading != nil {
 				config.OnStoppedLeading()
 			}
+			klog.Fatalf("leaderelection lost")
 		},
 		OnNewLeader: func(identity string) {
 			klog.Infof("new leader elected: %v", identity)