mirrors/kube-router
1
0
Fork 0
mirror of https://github.com/cloudnativelabs/kube-router.git synced 2025-10-06 15:31:05 +02:00
Code Issues Packages Projects Releases Wiki Activity

perform clean-up of external ip from custom route table for external ip only if the table is not empty (#437)

Browse Source
This commit is contained in:
Murali Reddy 2018-05-13 12:38:25 +05:30 committed by GitHub
parent 6d86656f5e
commit 0538a2a93e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1686,17 +1686,19 @@ func (ln *linuxNetworking) setupRoutesForExternalIPForDSR(serviceInfoMap service
}
}
// clean up stale external IPs
for _, line := range strings.Split(strings.Trim(outStr, "\n"), "\n") {
route := strings.Split(strings.Trim(line, " "), " ")
ip := route[0]
if !activeExternalIPs[ip] {
args := []string{"route", "del", "table", externalIPRouteTableId}
args = append(args, route...)
if err = exec.Command("ip", args...).Run(); err != nil {
glog.Errorf("Failed to del route for %v in custom route table for external IP's due to: %s", ip, err)
continue
// check if there are any pbr in externalIPRouteTableId for external IP's
if len(outStr) > 0 {
// clean up stale external IPs
for _, line := range strings.Split(strings.Trim(outStr, "\n"), "\n") {
route := strings.Split(strings.Trim(line, " "), " ")
ip := route[0]
if !activeExternalIPs[ip] {
args := []string{"route", "del", "table", externalIPRouteTableId}
args = append(args, route...)
if err = exec.Command("ip", args...).Run(); err != nil {
glog.Errorf("Failed to del route for %v in custom route table for external IP's due to: %s", ip, err)
continue
}
}
}
}