diff --git a/conformance/utils/http/mirror.go b/conformance/utils/http/mirror.go index 99d0621d26..0ac85ec5ae 100644 --- a/conformance/utils/http/mirror.go +++ b/conformance/utils/http/mirror.go @@ -41,6 +41,8 @@ func ExpectMirroredRequest(t *testing.T, client client.Client, clientset clients var wg sync.WaitGroup wg.Add(len(mirrorPods)) + assertionStart := time.Now() + for _, mirrorPod := range mirrorPods { go func(mirrorPod MirroredBackend) { defer wg.Done() @@ -50,7 +52,7 @@ func ExpectMirroredRequest(t *testing.T, client client.Client, clientset clients tlog.Log(t, "Searching for the mirrored request log") tlog.Logf(t, `Reading "%s/%s" logs`, mirrorPod.Namespace, mirrorPod.Name) - logs, err := kubernetes.DumpEchoLogs(mirrorPod.Namespace, mirrorPod.Name, client, clientset, time.Now()) + logs, err := kubernetes.DumpEchoLogs(mirrorPod.Namespace, mirrorPod.Name, client, clientset, assertionStart) if err != nil { tlog.Logf(t, `Couldn't read "%s/%s" logs: %v`, mirrorPod.Namespace, mirrorPod.Name, err) return false