github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-23 19:08:44 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #111219 from dcbw/proxy-sync-on-node-events

Browse Source 
proxy: queue syncs on node events rather than syncing immediately
This commit is contained in:
Kubernetes Prow Robot
2022-07-19 05:34:18 -07:00
committed by GitHub
parent eeb12bb3af f197509879
commit a521af7007
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/proxy/iptables/proxier.go
View File

@@ -633,7 +633,7 @@ func (proxier *Proxier) OnNodeAdd(node *v1.Node) {
proxier.mu.Unlock() proxier.mu.Unlock()
klog.V(4).InfoS("Updated proxier node labels", "labels", node.Labels) klog.V(4).InfoS("Updated proxier node labels", "labels", node.Labels)
proxier.syncProxyRules() proxier.Sync()
} }
// OnNodeUpdate is called whenever modification of an existing // OnNodeUpdate is called whenever modification of an existing
@@ -657,7 +657,7 @@ func (proxier *Proxier) OnNodeUpdate(oldNode, node *v1.Node) {
proxier.mu.Unlock() proxier.mu.Unlock()
klog.V(4).InfoS("Updated proxier node labels", "labels", node.Labels) klog.V(4).InfoS("Updated proxier node labels", "labels", node.Labels)
proxier.syncProxyRules() proxier.Sync()
} }
// OnNodeDelete is called whenever deletion of an existing node // OnNodeDelete is called whenever deletion of an existing node
@@ -672,7 +672,7 @@ func (proxier *Proxier) OnNodeDelete(node *v1.Node) {
proxier.nodeLabels = nil proxier.nodeLabels = nil
proxier.mu.Unlock() proxier.mu.Unlock()
proxier.syncProxyRules() proxier.Sync()
} }
// OnNodeSynced is called once all the initial event handlers were // OnNodeSynced is called once all the initial event handlers were

6
pkg/proxy/ipvs/proxier.go
View File

@@ -955,7 +955,7 @@ func (proxier *Proxier) OnNodeAdd(node *v1.Node) {
proxier.mu.Unlock() proxier.mu.Unlock()
klog.V(4).InfoS("Updated proxier node labels", "labels", node.Labels) klog.V(4).InfoS("Updated proxier node labels", "labels", node.Labels)
proxier.syncProxyRules() proxier.Sync()
} }
// OnNodeUpdate is called whenever modification of an existing // OnNodeUpdate is called whenever modification of an existing
@@ -978,7 +978,7 @@ func (proxier *Proxier) OnNodeUpdate(oldNode, node *v1.Node) {
proxier.mu.Unlock() proxier.mu.Unlock()
klog.V(4).InfoS("Updated proxier node labels", "labels", node.Labels) klog.V(4).InfoS("Updated proxier node labels", "labels", node.Labels)
proxier.syncProxyRules() proxier.Sync()
} }
// OnNodeDelete is called whenever deletion of an existing node // OnNodeDelete is called whenever deletion of an existing node
@@ -992,7 +992,7 @@ func (proxier *Proxier) OnNodeDelete(node *v1.Node) {
proxier.nodeLabels = nil proxier.nodeLabels = nil
proxier.mu.Unlock() proxier.mu.Unlock()
proxier.syncProxyRules() proxier.Sync()
} }
// OnNodeSynced is called once all the initial event handlers were // OnNodeSynced is called once all the initial event handlers were