From 15b9d0adcce54233ffb4224ebf09c0d510a12c2d Mon Sep 17 00:00:00 2001
From: changluyi <clyi@alauda.io>
Date: Mon, 10 Jul 2023 14:23:42 +0800
Subject: [PATCH] fix golang lint

---
 pkg/daemon/gateway_linux.go  |  8 +++-----
 pkg/daemon/tproxy.go         | 10 ++++++----
 pkg/tproxy/tproxy_tcp.go     |  3 +++
 test/e2e/kube-ovn/pod/pod.go |  4 ++--
 4 files changed, 14 insertions(+), 11 deletions(-)

diff --git a/pkg/daemon/gateway_linux.go b/pkg/daemon/gateway_linux.go
index 0b9cc4ba504..b22f2d1cdad 100644
--- 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
index 1b6f1d59784..9318df963ac 100644
--- 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
 			}
 
@@ -284,7 +284,7 @@ func listenTCP() {
 	for {
 		conn, err := tcpListener.Accept()
 		if err != nil {
-			if netErr, ok := err.(net.Error); ok && netErr.Temporary() {
+			if netErr, ok := err.(net.Error); ok {
 				klog.Errorf("Temporary error while accepting connection: %s", netErr)
 			}
 			klog.Fatalf("Unrecoverable error while accepting connection: %s", err)
@@ -365,7 +365,10 @@ func probePortInNs(podIP, probePort string, transferHTTPMessage bool, conn net.C
 			streamWait.Add(2)
 
 			streamConn := func(dst io.Writer, src io.Reader) {
-				io.Copy(dst, src)
+				if _, err := io.Copy(dst, src); err != nil {
+					klog.Errorf("copy stream from dst %v to src %v failed err: %v ", dst, src, err)
+				}
+
 				streamWait.Done()
 			}
 
@@ -377,7 +380,6 @@ func probePortInNs(podIP, probePort string, transferHTTPMessage bool, conn net.C
 		}
 		return nil
 	})
-	return
 }
 
 func getIPPortString(podIP, port string) string {
diff --git a/pkg/tproxy/tproxy_tcp.go b/pkg/tproxy/tproxy_tcp.go
index 2f0a8c527f4..4f833797f84 100644
--- 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
index 0a95679c733..3bb7a531552 100644
--- 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)