Skip to content

Commit

Permalink
Fix status update - changed in #1074
Browse files Browse the repository at this point in the history
  • Loading branch information
aledbf committed Aug 15, 2017
1 parent cafc5ba commit a2217ab
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions core/pkg/ingress/status/status.go
Original file line number Diff line number Diff line change
Expand Up @@ -92,10 +92,16 @@ type statusSync struct {
// Run starts the loop to keep the status in sync
func (s statusSync) Run(stopCh <-chan struct{}) {
go wait.Forever(s.elector.Run, 0)
go wait.Forever(s.update, updateInterval)
go s.syncQueue.Run(time.Second, stopCh)
<-stopCh
}

func (s *statusSync) update() {
// send a dummy object to the queue to force a sync
s.syncQueue.Enqueue("sync status")
}

// Shutdown stop the sync. In case the instance is the leader it will remove the current IP
// if there is no other instances running.
func (s statusSync) Shutdown() {
Expand Down

0 comments on commit a2217ab

Please sign in to comment.