mirrors/kube-router
1
0
Fork 0
mirror of https://github.com/cloudnativelabs/kube-router.git synced 2025-11-20 04:21:32 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix(NSC): actually remove IPVS definitions

Browse Source
This commit is contained in:
Aaron U'Ren 2021-07-24 18:25:37 -05:00
parent bbc0666a4c
commit fb070265a2
1 changed files with 13 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
pkg/controllers/proxy/network_services_controller.go
View File

@ -2361,17 +2361,22 @@ func (ln *linuxNetworking) getKubeDummyInterface() (netlink.Link, error) {
// Cleanup cleans all the configurations (IPVS, iptables, links) done
func (nsc *NetworkServicesController) Cleanup() {
// cleanup ipvs rules by flush
klog.Infof("Cleaning up IPVS configuration permanently")
klog.Infof("Cleaning up NetworkServiceController configurations...")
// cleanup ipvs rules by flush
handle, err := ipvs.New("")
if err != nil {
klog.Errorf("Failed to cleanup ipvs rules: %s", err.Error())
return
klog.Errorf("failed to get ipvs handle for cleaning ipvs definitions: %v", err)
} else {
klog.Infof("ipvs definitions don't have names associated with them for checking, during cleanup " +
"we assume that we own all of them and delete all ipvs definitions")
err = handle.Flush()
if err != nil {
klog.Errorf("unable to flush ipvs tables: %v", err)
}
handle.Close()
}
handle.Close()
// cleanup iptables masquerade rule
err = deleteMasqueradeIptablesRule()
if err != nil {
@ -2401,7 +2406,8 @@ func (nsc *NetworkServicesController) Cleanup() {
return
}
}
klog.Infof("Successfully cleaned the ipvs configuration done by kube-router")
klog.Infof("Successfully cleaned the NetworkServiceController configuration done by kube-router")
}
func (nsc *NetworkServicesController) newEndpointsEventHandler() cache.ResourceEventHandler {