diff --git a/test/conformance/api/v1/single_threaded_test.go b/test/conformance/api/v1/single_threaded_test.go index e88fa0aaba47..189cfee20171 100644 --- a/test/conformance/api/v1/single_threaded_test.go +++ b/test/conformance/api/v1/single_threaded_test.go @@ -76,7 +76,9 @@ func TestSingleConcurrency(t *testing.T) { t.Logf("Maintaining %d concurrent requests for %v.", concurrency, duration) group, _ := errgroup.WithContext(context.Background()) for i := 0; i < concurrency; i++ { + threadIdx := i group.Go(func() error { + requestIdx := 0 done := time.After(duration) req, err := http.NewRequest(http.MethodGet, url.String(), nil) if err != nil { @@ -89,13 +91,14 @@ func TestSingleConcurrency(t *testing.T) { return nil default: res, err := client.Do(req) + requestIdx = requestIdx + 1 if err != nil { - return fmt.Errorf("error making request %w", err) + return fmt.Errorf("error making request, thread index: %d, request index: %d: %w", threadIdx, requestIdx, err) } if res.StatusCode == http.StatusInternalServerError { return errors.New("detected concurrent requests") } else if res.StatusCode != http.StatusOK { - return fmt.Errorf("non 200 response %v", res.StatusCode) + return fmt.Errorf("non 200 response, thread index: %d, request index: %d, response %s", threadIdx, requestIdx, res) } } } diff --git a/test/conformance/api/v1alpha1/single_threaded_test.go b/test/conformance/api/v1alpha1/single_threaded_test.go index 4b1ebd4c406c..a143c3cd7764 100644 --- a/test/conformance/api/v1alpha1/single_threaded_test.go +++ b/test/conformance/api/v1alpha1/single_threaded_test.go @@ -77,7 +77,9 @@ func TestSingleConcurrency(t *testing.T) { t.Logf("Maintaining %d concurrent requests for %v.", concurrency, duration) group, _ := errgroup.WithContext(context.Background()) for i := 0; i < concurrency; i++ { + threadIdx := i group.Go(func() error { + requestIdx := 0 done := time.After(duration) req, err := http.NewRequest(http.MethodGet, url.String(), nil) if err != nil { @@ -90,13 +92,14 @@ func TestSingleConcurrency(t *testing.T) { return nil default: res, err := client.Do(req) + requestIdx = requestIdx + 1 if err != nil { - return fmt.Errorf("error making request %w", err) + return fmt.Errorf("error making request, thread index: %d, request index: %d: %w", threadIdx, requestIdx, err) } if res.StatusCode == http.StatusInternalServerError { return errors.New("detected concurrent requests") } else if res.StatusCode != http.StatusOK { - return fmt.Errorf("non 200 response %v", res.StatusCode) + return fmt.Errorf("non 200 response, thread index: %d, request index: %d, response %s", threadIdx, requestIdx, res) } } } diff --git a/test/conformance/api/v1beta1/single_threaded_test.go b/test/conformance/api/v1beta1/single_threaded_test.go index efaea42834f3..a094bb3a42b6 100644 --- a/test/conformance/api/v1beta1/single_threaded_test.go +++ b/test/conformance/api/v1beta1/single_threaded_test.go @@ -76,7 +76,9 @@ func TestSingleConcurrency(t *testing.T) { t.Logf("Maintaining %d concurrent requests for %v.", concurrency, duration) group, _ := errgroup.WithContext(context.Background()) for i := 0; i < concurrency; i++ { + threadIdx := i group.Go(func() error { + requestIdx := 0 done := time.After(duration) req, err := http.NewRequest(http.MethodGet, url.String(), nil) if err != nil { @@ -89,13 +91,14 @@ func TestSingleConcurrency(t *testing.T) { return nil default: res, err := client.Do(req) + requestIdx = requestIdx + 1 if err != nil { - return fmt.Errorf("error making request %w", err) + return fmt.Errorf("error making request, thread index: %d, request index: %d: %w", threadIdx, requestIdx, err) } if res.StatusCode == http.StatusInternalServerError { return errors.New("detected concurrent requests") } else if res.StatusCode != http.StatusOK { - return fmt.Errorf("non 200 response %v", res.StatusCode) + return fmt.Errorf("non 200 response, thread index: %d, request index: %d, response %s", threadIdx, requestIdx, res) } } }