From 74e28b6402fc31644036ff015c99b6f5a8e9ddc6 Mon Sep 17 00:00:00 2001 From: Lion-Wei Date: Thu, 19 Apr 2018 17:02:44 +0800 Subject: [PATCH] fix ipvs delay on sync rules --- pkg/proxy/ipvs/proxier.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pkg/proxy/ipvs/proxier.go b/pkg/proxy/ipvs/proxier.go index 6f61baa4f1..9994f49c6b 100644 --- a/pkg/proxy/ipvs/proxier.go +++ b/pkg/proxy/ipvs/proxier.go @@ -639,8 +639,10 @@ func (proxier *Proxier) OnEndpointsDelete(endpoints *api.Endpoints) { func (proxier *Proxier) OnEndpointsSynced() { proxier.mu.Lock() proxier.endpointsSynced = true + proxier.setInitialized(proxier.servicesSynced && proxier.endpointsSynced) proxier.mu.Unlock() + // Sync unconditionally - this is called once per lifetime. proxier.syncProxyRules() }