fix

Signed-off-by: zirain <[email protected]>

Author: zirain

test/e2e/tests/preservecase.go

@@ -16,6 +16,10 @@ import (
 	"net/http/httputil"
 	"regexp"
 	"testing"
+	"time"
+
+	"k8s.io/apimachinery/pkg/util/wait"
+	"sigs.k8s.io/gateway-api/conformance/utils/tlog"
 
 	corev1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/types"
@@ -113,41 +117,37 @@ var PreserveCaseTest = suite.ConformanceTest{
 			gwAddr := kubernetes.GatewayAndHTTPRoutesMustBeAccepted(t, suite.Client, suite.TimeoutConfig, suite.ControllerName, kubernetes.NewGatewayRef(gwNN), routeNN)
 
 			WaitForPods(t, suite.Client, "gateway-preserve-case-backend", map[string]string{"app": "preserve-case"}, corev1.PodRunning, PodReady)
-			// Send a request to a valid path and expect a successful response
-			http.MakeRequestAndExpectEventuallyConsistentResponse(t, suite.RoundTripper, suite.TimeoutConfig, gwAddr, http.ExpectedResponse{
-				Request: http.Request{
-					Path: "/preserve?headers=ReSpOnSeHeAdEr",
-					Headers: map[string]string{
-						"SpEcIaL": "Header",
-					},
-				},
-				Response: http.Response{
-					StatusCode: 200,
-				},
-				Namespace: ns,
-			})
 
-			// Can't use the standard method for checking the response, since the remote side isn't the
-			// conformance echo server and it returns a differently formatted response.
-			expectedResponse := http.ExpectedResponse{
-				Request: http.Request{
-					Path: "/preserve?headers=ReSpOnSeHeAdEr",
-					Headers: map[string]string{
-						"SpEcIaL": "Header",
+			err := wait.PollUntilContextTimeout(context.TODO(), time.Second, suite.TimeoutConfig.DeleteTimeout, true, func(ctx context.Context) (bool, error) {
+				// Can't use the standard method for checking the response, since the remote side isn't the
+				// conformance echo server and it returns a differently formatted response.
+				expectedResponse := http.ExpectedResponse{
+					Request: http.Request{
+						Path: "/preserve?headers=ReSpOnSeHeAdEr",
+						Headers: map[string]string{
+							"SpEcIaL": "Header",
+						},
 					},
-				},
-				Namespace: ns,
-			}
-
-			var rt nethttp.RoundTripper
-			req := http.MakeRequest(t, &expectedResponse, gwAddr, "HTTP", "http")
-			respBody, err := casePreservingRoundTrip(req, rt, suite)
+					Namespace: ns,
+				}
+
+				var rt nethttp.RoundTripper
+				req := http.MakeRequest(t, &expectedResponse, gwAddr, "HTTP", "http")
+				respBody, err := casePreservingRoundTrip(req, rt, suite)
+				if err != nil {
+					tlog.Logf(t, "failed to get expected response: %v", err)
+					return false, nil
+				}
+
+				if _, found := respBody["SpEcIaL"]; !found {
+					tlog.Logf(t, "case was not preserved for test header: %+v", respBody)
+					return false, nil
+				}
+
+				return true, nil
+			})
 			if err != nil {
-				t.Errorf("failed to get expected response: %v", err)
-			}
-
-			if _, found := respBody["SpEcIaL"]; !found {
-				t.Errorf("case was not preserved for test header: %+v", respBody)
+				tlog.Errorf(t, "failed to get expected response: %v", err)
 			}
 		})
 	},