From a2279a8d7ed4c5b0e5916a3a053738d70dfad4d3 Mon Sep 17 00:00:00 2001 From: Casey Callendrello Date: Fri, 6 Dec 2019 22:50:52 +0100 Subject: [PATCH] proxy: add handler with same ResyncPeriod as shared informer. Works around a nasty bug where having multiple handlers with non-homogeneous resync times causes updates during connection disruption to be missed by one or more handlers. --- pkg/openshift-sdn/proxy.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/openshift-sdn/proxy.go b/pkg/openshift-sdn/proxy.go index 8d764aa8f..3a1d080bc 100644 --- a/pkg/openshift-sdn/proxy.go +++ b/pkg/openshift-sdn/proxy.go @@ -166,7 +166,7 @@ func (sdn *OpenShiftSDN) runProxy(waitChan chan<- bool) { // are registered yet. serviceConfig := pconfig.NewServiceConfig( sdn.informers.KubeInformers.Core().V1().Services(), - sdn.ProxyConfig.ConfigSyncPeriod.Duration, + sdn.ProxyConfig.IPTables.SyncPeriod.Duration, ) if enableUnidling { @@ -194,7 +194,7 @@ func (sdn *OpenShiftSDN) runProxy(waitChan chan<- bool) { endpointsConfig := pconfig.NewEndpointsConfig( sdn.informers.KubeInformers.Core().V1().Endpoints(), - sdn.ProxyConfig.ConfigSyncPeriod.Duration, + sdn.ProxyConfig.IPTables.SyncPeriod.Duration, ) // customized handling registration that inserts a filter if needed if err := sdn.OsdnProxy.Start(proxier, waitChan); err != nil {