diff --git a/pkg/proxy/iptables/proxier.go b/pkg/proxy/iptables/proxier.go index 6b759ece813..55e9d678fb8 100644 --- a/pkg/proxy/iptables/proxier.go +++ b/pkg/proxy/iptables/proxier.go @@ -633,7 +633,7 @@ func (proxier *Proxier) OnNodeAdd(node *v1.Node) { proxier.mu.Unlock() klog.V(4).InfoS("Updated proxier node labels", "labels", node.Labels) - proxier.syncProxyRules() + proxier.Sync() } // OnNodeUpdate is called whenever modification of an existing @@ -657,7 +657,7 @@ func (proxier *Proxier) OnNodeUpdate(oldNode, node *v1.Node) { proxier.mu.Unlock() klog.V(4).InfoS("Updated proxier node labels", "labels", node.Labels) - proxier.syncProxyRules() + proxier.Sync() } // OnNodeDelete is called whenever deletion of an existing node @@ -672,7 +672,7 @@ func (proxier *Proxier) OnNodeDelete(node *v1.Node) { proxier.nodeLabels = nil proxier.mu.Unlock() - proxier.syncProxyRules() + proxier.Sync() } // OnNodeSynced is called once all the initial event handlers were diff --git a/pkg/proxy/ipvs/proxier.go b/pkg/proxy/ipvs/proxier.go index 823ca8e5324..f99378a3f24 100644 --- a/pkg/proxy/ipvs/proxier.go +++ b/pkg/proxy/ipvs/proxier.go @@ -955,7 +955,7 @@ func (proxier *Proxier) OnNodeAdd(node *v1.Node) { proxier.mu.Unlock() klog.V(4).InfoS("Updated proxier node labels", "labels", node.Labels) - proxier.syncProxyRules() + proxier.Sync() } // OnNodeUpdate is called whenever modification of an existing @@ -978,7 +978,7 @@ func (proxier *Proxier) OnNodeUpdate(oldNode, node *v1.Node) { proxier.mu.Unlock() klog.V(4).InfoS("Updated proxier node labels", "labels", node.Labels) - proxier.syncProxyRules() + proxier.Sync() } // OnNodeDelete is called whenever deletion of an existing node @@ -992,7 +992,7 @@ func (proxier *Proxier) OnNodeDelete(node *v1.Node) { proxier.nodeLabels = nil proxier.mu.Unlock() - proxier.syncProxyRules() + proxier.Sync() } // OnNodeSynced is called once all the initial event handlers were