From a2217ab1beba906f7ca35a8e3841622552f8ecb4 Mon Sep 17 00:00:00 2001 From: Manuel de Brito Fontes Date: Tue, 15 Aug 2017 18:34:36 -0300 Subject: [PATCH] Fix status update - changed in #1074 --- core/pkg/ingress/status/status.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/core/pkg/ingress/status/status.go b/core/pkg/ingress/status/status.go index 036057a325..5ba8556205 100644 --- a/core/pkg/ingress/status/status.go +++ b/core/pkg/ingress/status/status.go @@ -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() {