github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 03:41:45 +00:00
Code Issues Projects Releases Wiki Activity

Move variable closer to it's use

Browse Source
This commit is contained in:
Lars Ekman 2023-02-19 17:54:00 +01:00
parent 3325c7031d
commit 17e2c7d535
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1024,9 +1024,7 @@ func (proxier *Proxier) syncProxyRules() {
// activeIPVSServices represents IPVS service successfully created in this round of sync // activeIPVSServices represents IPVS service successfully created in this round of sync
activeIPVSServices := sets.New[string]() activeIPVSServices := sets.New[string]()
// currentIPVSServices represent IPVS services listed from the system // activeBindAddrs Represents addresses we want on the defaultDummyDevice after this round of sync
currentIPVSServices := make(map[string]*utilipvs.VirtualServer)
// activeBindAddrs represents ip address successfully bind to defaultDummyDevice in this round of sync
activeBindAddrs := sets.New[string]() activeBindAddrs := sets.New[string]()
bindedAddresses, err := proxier.netlinkHandle.GetLocalAddresses(defaultDummyDevice) bindedAddresses, err := proxier.netlinkHandle.GetLocalAddresses(defaultDummyDevice)
@ -1552,7 +1550,9 @@ func (proxier *Proxier) syncProxyRules() {
} }
} }
// Clean up legacy IPVS services and unbind addresses // currentIPVSServices represent IPVS services listed from the system
// (including any we have created in this sync)
currentIPVSServices := make(map[string]*utilipvs.VirtualServer)
appliedSvcs, err := proxier.ipvs.GetVirtualServers() appliedSvcs, err := proxier.ipvs.GetVirtualServers()
if err == nil { if err == nil {
for _, appliedSvc := range appliedSvcs { for _, appliedSvc := range appliedSvcs {