aboutsummaryrefslogtreecommitdiff
path: root/src/net/http
diff options
context:
space:
mode:
authorDamien Neil <dneil@google.com>2022-11-17 11:09:11 -0800
committerGopher Robot <gobot@golang.org>2022-11-17 19:25:42 +0000
commitb74aaa1427916368c5a1e0ba156f461b2a0f411a (patch)
treeab266008e64c7bb8eb7cd257d8b078d5e4e964b1 /src/net/http
parent5f7abeca5a584a847033bbd1bc1123872bb0925e (diff)
downloadgo-b74aaa1427916368c5a1e0ba156f461b2a0f411a.tar.xz
net/http: deflake TestResponseControllerSetFutureWriteDeadline
Don't set the server's write deadline until after the client has read the response headers, avoiding test failures if the deadline expires before or while writing headers. Fixes #56807. Change-Id: I5f80c108b360d030132a13661774a30fac453856 Reviewed-on: https://go-review.googlesource.com/c/go/+/451715 Auto-Submit: Damien Neil <dneil@google.com> TryBot-Result: Gopher Robot <gobot@golang.org> Run-TryBot: Damien Neil <dneil@google.com> Reviewed-by: Bryan Mills <bcmills@google.com>
Diffstat (limited to 'src/net/http')
-rw-r--r--src/net/http/responsecontroller_test.go7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/net/http/responsecontroller_test.go b/src/net/http/responsecontroller_test.go
index af036837a4..90c57016a7 100644
--- a/src/net/http/responsecontroller_test.go
+++ b/src/net/http/responsecontroller_test.go
@@ -132,8 +132,14 @@ func testResponseControllerSetFutureWriteDeadline(t *testing.T, mode testMode) {
t.Skip("skip until h2_bundle.go is updated")
}
errc := make(chan error, 1)
+ startwritec := make(chan struct{})
cst := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) {
ctl := NewResponseController(w)
+ w.WriteHeader(200)
+ if err := ctl.Flush(); err != nil {
+ t.Errorf("ctl.Flush() = %v, want nil", err)
+ }
+ <-startwritec // don't set the deadline until the client reads response headers
if err := ctl.SetWriteDeadline(time.Now().Add(1 * time.Millisecond)); err != nil {
t.Errorf("ctl.SetWriteDeadline() = %v, want nil", err)
}
@@ -142,6 +148,7 @@ func testResponseControllerSetFutureWriteDeadline(t *testing.T, mode testMode) {
}))
res, err := cst.c.Get(cst.ts.URL)
+ close(startwritec)
if err != nil {
t.Fatalf("unexpected connection error: %v", err)
}