delete ipam record and static route when gc lsp (#1490)

pkg/controller/gc.go

@@ -3,6 +3,7 @@ package controller
 import (
 	"context"
 	"fmt"
+	"net"
 	"strings"
 	"time"
 
@@ -247,6 +248,8 @@ func (c *Controller) markAndCleanLSP() error {
 			if !lastNoPodLSP[lsp] {
 				noPodLSP[lsp] = true
 			} else {
+				nameNsMap, podAddres := c.ovnClient.GetLspExternalIds(lsp)
+
 				klog.Infof("gc logical switch port %s", lsp)
 				if err := c.ovnClient.DeleteLogicalSwitchPort(lsp); err != nil {
 					klog.Errorf("failed to delete lsp %s, %v", lsp, err)
@@ -258,6 +261,20 @@ func (c *Controller) markAndCleanLSP() error {
 						return err
 					}
 				}
+
+				for podName, nsName := range nameNsMap {
+					key := fmt.Sprintf("%s/%s", nsName, podName)
+					c.ipam.ReleaseAddressByPod(key)
+				}
+
+				for _, podAddr := range podAddres {
+					if net.ParseIP(podAddr).To4() != nil || net.ParseIP(podAddr).To16() != nil {
+						if err := c.ovnClient.DeleteStaticRoute(podAddr, c.config.ClusterRouter); err != nil {
+							klog.Errorf("failed to delete static route when gc lsp %s, ip %v", lsp, podAddr)
+							continue
+						}
+					}
+				}
 			}
 		}
 	}

pkg/ovs/ovn-nbctl.go

@@ -2003,3 +2003,38 @@ func (c *Client) SetLBCIDR(svccidr string) error {
 	}
 	return nil
 }
+
+func (c *Client) GetLspExternalIds(lsp string) (map[string]string, []string) {
+	result, err := c.CustomFindEntity("Logical_Switch_Port", []string{"external_ids", "addresses"}, fmt.Sprintf("name=%s", lsp))
+	if err != nil {
+		klog.Errorf("customFindEntity failed, %v", err)
+		return nil, nil
+	}
+	if len(result) == 0 {
+		return nil, nil
+	}
+
+	nameNsMap := make(map[string]string, 1)
+	for _, l := range result[0]["external_ids"] {
+		if len(strings.TrimSpace(l)) == 0 {
+			continue
+		}
+		parts := strings.Split(strings.TrimSpace(l), "=")
+		if len(parts) != 2 {
+			continue
+		}
+		if strings.TrimSpace(parts[0]) != "pod" {
+			continue
+		}
+
+		podInfo := strings.Split(strings.TrimSpace(parts[1]), "/")
+		if len(podInfo) != 2 {
+			continue
+		}
+		podNs := podInfo[0]
+		podName := podInfo[1]
+		nameNsMap[podName] = podNs
+	}
+
+	return nameNsMap, result[0]["addresses"]
+}