From e1cf2eec091193ec50c0a870e1c9f64dead2a3aa Mon Sep 17 00:00:00 2001 From: Laurent Bernaille Date: Fri, 22 Jun 2018 22:53:03 +0200 Subject: [PATCH] Always create kubeClusterIPSet --- pkg/proxy/ipvs/proxier.go | 11 ++++------- 1 file changed, 4 insertions(+), 7 deletions(-) diff --git a/pkg/proxy/ipvs/proxier.go b/pkg/proxy/ipvs/proxier.go index caf802133fb..dbbc505cb80 100644 --- a/pkg/proxy/ipvs/proxier.go +++ b/pkg/proxy/ipvs/proxier.go @@ -789,14 +789,11 @@ func (proxier *Proxier) syncProxyRules() { } // add service Cluster IP:Port to kubeServiceAccess ip set for the purpose of solving hairpin. // proxier.kubeServiceAccessSet.activeEntries.Insert(entry.String()) - // Install masquerade rules if 'masqueradeAll' or 'clusterCIDR' is specified. - if proxier.masqueradeAll || len(proxier.clusterCIDR) > 0 { - if valid := proxier.ipsetList[kubeClusterIPSet].validateEntry(entry); !valid { - glog.Errorf("%s", fmt.Sprintf(EntryInvalidErr, entry, proxier.ipsetList[kubeClusterIPSet].Name)) - continue - } - proxier.ipsetList[kubeClusterIPSet].activeEntries.Insert(entry.String()) + if valid := proxier.ipsetList[kubeClusterIPSet].validateEntry(entry); !valid { + glog.Errorf("%s", fmt.Sprintf(EntryInvalidErr, entry, proxier.ipsetList[kubeClusterIPSet].Name)) + continue } + proxier.ipsetList[kubeClusterIPSet].activeEntries.Insert(entry.String()) // ipvs call serv := &utilipvs.VirtualServer{ Address: svcInfo.ClusterIP,