report IP families that are being tested

Signed-off-by: Pratyay Banerjee <[email protected]>
cilium · Mar 16, 2023 · acebe27 · acebe27
1 parent eecce64
commit acebe27
Show file tree

Hide file tree

Showing 3 changed files with 20 additions and 13 deletions.
diff --git a/connectivity/tests/host.go b/connectivity/tests/host.go
@@ -36,24 +36,28 @@ func (s *podToHost) Run(ctx context.Context, t *check.Test) {
 			node := node
 
 			t.ForEachIPFamily(func(ipFam check.IPFamily) {
+				dstAddrs := []string{}
 				for _, addr := range node.Status.Addresses {
 					if check.GetIPFamily(addr.Address) != ipFam {
 						continue
 					}
+					dstAddrs = append(dstAddrs, addr.Address)
+				}
+				if len(dstAddrs) == 0 {
+					return
+				}
 
-					dst := check.ICMPEndpoint("", addr.Address)
-					ipFam := check.GetIPFamily(addr.Address)
-
-					t.NewAction(s, fmt.Sprintf("ping-%d", i), &pod, dst, ipFam).Run(func(a *check.Action) {
-						a.ExecInPod(ctx, ct.PingCommand(dst, ipFam))
+				dst := check.ICMPEndpoint("", dstAddrs[0])
+				msg := fmt.Sprintf("ping-%s-%d", ipFam, i)
+				t.NewAction(s, msg, &pod, dst, ipFam).Run(func(a *check.Action) {
+					a.ExecInPod(ctx, ct.PingCommand(dst, ipFam))
 
-						a.ValidateFlows(ctx, pod, a.GetEgressRequirements(check.FlowParameters{
-							Protocol: check.ICMP,
-						}))
-					})
+					a.ValidateFlows(ctx, pod, a.GetEgressRequirements(check.FlowParameters{
+						Protocol: check.ICMP,
+					}))
+				})
 
-					i++
-				}
+				i++
 			})
 		}
 	}

diff --git a/connectivity/tests/pod.go b/connectivity/tests/pod.go
@@ -50,7 +50,8 @@ func (s *podToPod) Run(ctx context.Context, t *check.Test) {
 				continue
 			}
 			t.ForEachIPFamily(func(ipFam check.IPFamily) {
-				t.NewAction(s, fmt.Sprintf("curl-%d", i), &client, echo, ipFam).Run(func(a *check.Action) {
+				actionDesc := fmt.Sprintf("curl-%s-%d", ipFam.String(), i)
+				t.NewAction(s, actionDesc, &client, echo, ipFam).Run(func(a *check.Action) {
 					if s.method == "" {
 						a.ExecInPod(ctx, ct.CurlCommand(echo, ipFam))
 					} else {

diff --git a/connectivity/tests/service.go b/connectivity/tests/service.go
@@ -49,7 +49,9 @@ func (s *podToService) Run(ctx context.Context, t *check.Test) {
 				continue
 			}
 
-			t.NewAction(s, fmt.Sprintf("curl-%d", i), &pod, svc, check.IPFamilyAny).Run(func(a *check.Action) {
+			actionDesc := fmt.Sprintf("curl-%s-%d", check.IPFamilyAny, i)
+
+			t.NewAction(s, actionDesc, &pod, svc, check.IPFamilyAny).Run(func(a *check.Action) {
 				a.ExecInPod(ctx, ct.CurlCommand(svc, check.IPFamilyAny))
 
 				a.ValidateFlows(ctx, pod, a.GetEgressRequirements(check.FlowParameters{