debug

antrea-io · Apr 26, 2022 · 4b990e4 · 4b990e4
1 parent 5a1651e
commit 4b990e4
Show file tree

Hide file tree

Showing 2 changed files with 32 additions and 5 deletions.
diff --git a/ci/kind/test-e2e-kind.sh b/ci/kind/test-e2e-kind.sh
@@ -216,7 +216,7 @@ function run_test {
   sleep 1
 
   if $coverage; then
-      go test -v -timeout=80m antrea.io/antrea/test/e2e -provider=kind --logs-export-dir=$ANTREA_LOG_DIR --coverage --coverage-dir $ANTREA_COV_DIR --skip=$skiplist
+      go test -v -timeout=80m -run=TestTraceflow/testTraceflowInterNode/traceflowGroupTest/interNodeTraceflowIPv4 antrea.io/antrea/test/e2e -provider=kind --logs-export-dir=$ANTREA_LOG_DIR --coverage --coverage-dir $ANTREA_COV_DIR --skip=$skiplist
   else
       go test -v -timeout=75m antrea.io/antrea/test/e2e -provider=kind --logs-export-dir=$ANTREA_LOG_DIR --skip=$skiplist
   fi

diff --git a/test/e2e/traceflow_test.go b/test/e2e/traceflow_test.go
@@ -16,6 +16,7 @@ package e2e
 
 import (
 	"context"
+	"encoding/json"
 	"fmt"
 	"net"
 	"reflect"
@@ -1971,9 +1972,9 @@ func testTraceflowInterNode(t *testing.T, data *TestData) {
 		for _, tc := range testcases {
 			tc := tc
 			t.Run(tc.name, func(t *testing.T) {
-				if len(clusterInfo.windowsNodes) == 0 {
-					t.Parallel()
-				}
+				//if len(clusterInfo.windowsNodes) == 0 {
+				//	t.Parallel()
+				//}
 				runTestTraceflow(t, data, tc)
 			})
 		}
@@ -2046,13 +2047,39 @@ func (data *TestData) waitForTraceflow(t *testing.T, name string, phase v1alpha1
 		return true, nil
 	}); err != nil {
 		if tf != nil {
-			t.Errorf("Latest Traceflow status: %v", tf.Status)
+			t.Errorf("Latest Traceflow status: %+v", tf.Status)
 		}
+		debugLog(t, data, tf)
 		return nil, err
 	}
 	return tf, nil
 }
 
+func debugLog(t *testing.T, data *TestData, tf *v1alpha1.Traceflow) {
+	rc, stdout, stderr, err2 := data.RunCommandOnNode(controlPlaneNodeName(), "kubectl get po -A -owide")
+	t.Logf("Pods: %d, %s, %s, %+v", rc, stdout, stderr, err2)
+	podName, _ := data.getAntreaPodOnNode(controlPlaneNodeName())
+	stdout, stderr, err2 = data.RunCommandFromPod(antreaNamespace, podName, "antrea-agent", []string{"ovs-ofctl", "-O", "OpenFlow13", "dump-flows", "br-int"})
+	t.Logf("Master flow: %s, %s, %+v", stdout, stderr, err2)
+	podName, _ = data.getAntreaPodOnNode(nodeName(1))
+	stdout, stderr, err2 = data.RunCommandFromPod(antreaNamespace, podName, "antrea-agent", []string{"ovs-ofctl", "-O", "OpenFlow13", "dump-flows", "br-int"})
+	t.Logf("Worker flow: %s, %s, %+v", stdout, stderr, err2)
+	if len(clusterInfo.windowsNodes) != 0 {
+		nodeIdx0 := clusterInfo.windowsNodes[0]
+		rc, stdout, stderr, err2 = data.RunCommandOnNode(nodeName(nodeIdx0), "ovs-ofctl -O OpenFlow13 dump-flows br-int")
+		t.Logf("Windows0 flow: %d, %s, %s, %+v", rc, stdout, stderr, err2)
+		nodeIdx1 := clusterInfo.windowsNodes[1]
+		rc, stdout, stderr, err2 = data.RunCommandOnNode(nodeName(nodeIdx1), "ovs-ofctl -O OpenFlow13 dump-flows br-int")
+		t.Logf("Windows1 flow: %d, %s, %s, %+v", rc, stdout, stderr, err2)
+		reasonMap := map[string]string{}
+		json.Unmarshal([]byte(tf.Status.Reason), &reasonMap)
+		cmd := fmt.Sprintf("ovs-appctl ofproto/trace br-int in_port=%s,%s,nw_ttl=64,dl_src=%s,dl_dst=%s,nw_src=%s,nw_dst=%s,nw_tos=%s", reasonMap["in_port"], reasonMap["proto"], reasonMap["dl_src"], reasonMap["dl_dst"], reasonMap["nw_src"], reasonMap["nw_dst"], reasonMap["nw_tos"])
+		t.Logf("cmd: %s", cmd)
+		rc, stdout, stderr, err2 = data.RunCommandOnNode(nodeName(nodeIdx0), cmd)
+		t.Logf("Windows0 trace: %d, %s, %s, %+v", rc, stdout, stderr, err2)
+	}
+}
+
 // compareObservations compares expected results and actual results.
 func compareObservations(expected v1alpha1.NodeResult, actual v1alpha1.NodeResult) error {
 	if expected.Node != actual.Node {