fix lost vendor

Signed-off-by: bobz965 <zhangbingbing2_yewu@cmss.chinamobile.com>

Author: zbb88888

pkg/controller/pod.go

@@ -1036,6 +1036,19 @@ func (c *Controller) handleDeletePod(key string) error {
 	}
 	isVMPod, vmName := isVMPod(pod)
 	if isVMPod && c.config.EnableKeepVMIP {
+		ports, err := c.OVNNbClient.ListNormalLogicalSwitchPorts(true, map[string]string{"pod": podKey})
+		if err != nil {
+			klog.Errorf("failed to list lsps of pod '%s', %v", pod.Name, err)
+			return err
+		}
+		for _, port := range ports {
+			klog.Infof("clean migrate options for vm lsp %s", port.Name)
+			if err := c.OVNNbClient.CleanLogicalSwitchPortMigrateOptions(port.Name); err != nil {
+				err = fmt.Errorf("failed to clean migrate options for vm lsp %s, %v", port.Name, err)
+				klog.Error(err)
+				return err
+			}
+		}
 		vmToBeDel := c.isVMToDel(pod, vmName)
 		isDelete, err := appendCheckPodToDel(c, pod, vmName, util.VMInstance)
 		if pod.DeletionTimestamp != nil {
@@ -1142,19 +1155,6 @@ func (c *Controller) handleDeletePod(key string) error {
 				return err
 			}
 		}
-	} else if isVMPod {
-		ports, err := c.OVNNbClient.ListNormalLogicalSwitchPorts(true, map[string]string{"pod": podKey})
-		if err != nil {
-			klog.Errorf("failed to list lsps of pod '%s', %v", pod.Name, err)
-			return err
-		}
-		for _, port := range ports {
-			if err := c.OVNNbClient.CleanLogicalSwitchPortMigrateOptions(port.Name); err != nil {
-				err = fmt.Errorf("failed to clean migrate options for lsp %s, %v", port.Name, err)
-				klog.Error(err)
-				return err
-			}
-		}
 	}
 	for _, podNet := range podNets {
 		c.syncVirtualPortsQueue.Add(podNet.Subnet.Name)

pkg/ovs/ovn-nb-logical_switch_port.go

@@ -33,7 +33,7 @@ func buildLogicalSwitchPort(lspName, ip, mac, podName, namespace string, portSec
 
 	// addresses is the first element of addresses
 	lsp.Addresses = []string{strings.TrimSpace(strings.Join(addresses, " "))}
-
+	lsp.ExternalIDs["vendor"] = util.CniTypeName
 	if portSecurity {
 		if len(vips) != 0 {
 			addresses = append(addresses, vipList...)
@@ -864,7 +864,7 @@ func (c *OVNNbClient) GetLogicalSwitchPortMigrateOptions(lspName string) (*ovnnb
 			return lsp, splits[0], splits[1], nil
 		}
 	}
-	return nil, "", "", nil
+	return lsp, "", "", nil
 }
 
 func (c *OVNNbClient) ResetLogicalSwitchPortMigrateOptions(lspName, srcNodeName, targetNodeName string, migratedFail bool) error {
@@ -891,7 +891,6 @@ func (c *OVNNbClient) ResetLogicalSwitchPortMigrateOptions(lspName, srcNodeName,
 		lsp.Options["requested-chassis"] = targetNodeName
 	}
 	delete(lsp.Options, "activation-strategy")
-	klog.Infof("reset migrator logical switch port %s options: %v", lspName, lsp.Options)
 	if err := c.UpdateLogicalSwitchPort(lsp, &lsp.Options); err != nil {
 		err = fmt.Errorf("failed to reset options for migrator logical switch port %s: %v", lspName, err)
 		klog.Error(err)