diff --git a/connectivity/tests/host.go b/connectivity/tests/host.go index 53ae39db71..17113f99af 100644 --- 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 index 17b39c29df..00258eebde 100644 --- 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 index 56441ea492..e8edad45d0 100644 --- 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{