fix golang lint

kubeovn · Jul 10, 2023 · d8b05d9 · d8b05d9
1 parent 95c2a80
commit d8b05d9
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 8 deletions.
diff --git a/pkg/daemon/gateway_linux.go b/pkg/daemon/gateway_linux.go
@@ -810,12 +810,10 @@ func (c *Controller) reconcileTProxyIPTableRules(protocol string) error {
 			continue
 		}
 
-		hostIP := pod.Status.HostIP
-
 		subnet, err := c.subnetsLister.Get(subnetName)
 		if err != nil {
 			err = fmt.Errorf("failed to get subnet '%s', err: %v", subnetName, err)
-			continue
+			return err
 		}
 
 		if subnet.Spec.Vpc == c.config.ClusterRouter {
@@ -868,11 +866,11 @@ func (c *Controller) reconcileTProxyIPTableRules(protocol string) error {
 			tProxyPreRoutingMarkMask := fmt.Sprintf("%#x/%#x", TProxyPreroutingMark, TProxyPreroutingMask)
 			if protocol == kubeovnv1.ProtocolIPv4 {
 				tproxyOutputRules = append(tproxyOutputRules, util.IPTableRule{Table: MANGLE, Chain: OvnOutput, Rule: strings.Fields(fmt.Sprintf(`-d %s/32 -p tcp -m tcp --dport %s -j MARK --set-xmark %s`, podIP, probePort, tProxyPostroutingMarkMask))})
-				tproxyPreRoutingRules = append(tproxyPreRoutingRules, util.IPTableRule{Table: MANGLE, Chain: OvnPrerouting, Rule: strings.Fields(fmt.Sprintf(`-d %s/32 -p tcp -m tcp --dport %s -j TPROXY --on-port %d --on-ip %s --tproxy-mark %s`, podIP, probePort, util.TProxyListenPort, hostIP, tProxyPreRoutingMarkMask))})
+				tproxyPreRoutingRules = append(tproxyPreRoutingRules, util.IPTableRule{Table: MANGLE, Chain: OvnPrerouting, Rule: strings.Fields(fmt.Sprintf(`-d %s/32 -p tcp -m tcp --dport %s -j TPROXY --on-port %d --on-ip %s --tproxy-mark %s`, podIP, probePort, util.TProxyListenPort, pod.Status.HostIP, tProxyPreRoutingMarkMask))})
 			}
 			if protocol == kubeovnv1.ProtocolIPv6 {
 				tproxyOutputRules = append(tproxyOutputRules, util.IPTableRule{Table: MANGLE, Chain: OvnOutput, Rule: strings.Fields(fmt.Sprintf(`-d %s/128 -p tcp -m tcp --dport %s -j MARK --set-xmark %s`, podIP, probePort, tProxyPostroutingMarkMask))})
-				tproxyPreRoutingRules = append(tproxyPreRoutingRules, util.IPTableRule{Table: MANGLE, Chain: OvnPrerouting, Rule: strings.Fields(fmt.Sprintf(`-d %s/128 -p tcp -m tcp --dport %s -j TPROXY --on-port %d --on-ip %s --tproxy-mark %s`, podIP, probePort, util.TProxyListenPort, hostIP, tProxyPreRoutingMarkMask))})
+				tproxyPreRoutingRules = append(tproxyPreRoutingRules, util.IPTableRule{Table: MANGLE, Chain: OvnPrerouting, Rule: strings.Fields(fmt.Sprintf(`-d %s/128 -p tcp -m tcp --dport %s -j TPROXY --on-port %d --on-ip %s --tproxy-mark %s`, podIP, probePort, util.TProxyListenPort, pod.Status.HostIP, tProxyPreRoutingMarkMask))})
 			}
 		}
 	}

diff --git a/pkg/daemon/tproxy.go b/pkg/daemon/tproxy.go
@@ -79,7 +79,7 @@ func (c *Controller) StartTProxyTCPPortProbe() {
 
 			subnet, err := c.subnetsLister.Get(subnetName)
 			if err != nil {
-				err = fmt.Errorf("failed to get subnet '%s', err: %v", subnetName, err)
+				klog.Errorf("failed to get subnet '%s', err: %v", subnetName, err)
 				continue
 			}
 

diff --git a/pkg/tproxy/tproxy_tcp.go b/pkg/tproxy/tproxy_tcp.go
@@ -1,3 +1,6 @@
+//go:build linux
+// +build linux
+
 package tproxy
 
 import (

diff --git a/test/e2e/kube-ovn/pod/pod.go b/test/e2e/kube-ovn/pod/pod.go
@@ -171,7 +171,7 @@ var _ = framework.Describe("[group:pod]", func() {
 			InitialDelaySeconds: 10,
 		}
 
-		pod = podClient.Create(pod)
+		_ = podClient.Create(pod)
 		time.Sleep(11 * time.Second)
 
 		pod = podClient.GetPod(podName)
@@ -222,7 +222,7 @@ var _ = framework.Describe("[group:pod]", func() {
 			InitialDelaySeconds: 10,
 		}
 
-		pod = podClient.Create(pod)
+		_ = podClient.Create(pod)
 		time.Sleep(11 * time.Second)
 
 		pod = podClient.GetPod(podName)