fix

Signed-off-by: clyi <clyi@alauda.io>

Author: changluyi

pkg/daemon/flow_rules_linux.go

@@ -74,3 +74,15 @@ func buildFlowKey(kind, ip string, port uint16, protocol, extra string) string {
 	}
 	return fmt.Sprintf("%s-%s-%s-%d-%s", kind, ip, protocol, port, extra)
 }
+
+func (c *Controller) getPortID(bridgeName, portName string) (int, error) {
+	if c.ovsClient == nil {
+		return 0, fmt.Errorf("ovs client not initialized")
+	}
+
+	portInfo, err := c.ovsClient.OpenFlow.DumpPort(bridgeName, portName)
+	if err != nil {
+		return 0, fmt.Errorf("failed to dump port %s on bridge %s: %w", portName, bridgeName, err)
+	}
+	return portInfo.PortID, nil
+}

pkg/daemon/flow_sync_linux.go

@@ -1,8 +1,6 @@
 package daemon
 
 import (
-	"errors"
-	"fmt"
 	"strconv"
 	"strings"
 	"time"
@@ -171,18 +169,6 @@ func (c *Controller) runFlowSync(stopCh <-chan struct{}) {
 	}
 }
 
-func (c *Controller) getPortID(bridgeName, portName string) (int, error) {
-	if c.ovsClient == nil {
-		return 0, errors.New("ovs client not initialized")
-	}
-
-	portInfo, err := c.ovsClient.OpenFlow.DumpPort(bridgeName, portName)
-	if err != nil {
-		return 0, fmt.Errorf("failed to dump port %s on bridge %s: %w", portName, bridgeName, err)
-	}
-	return portInfo.PortID, nil
-}
-
 func (c *Controller) setFlowCache(cache map[string]map[string][]string, bridgeName, key string, flows []string) {
 	c.flowCacheMutex.Lock()
 	defer c.flowCacheMutex.Unlock()