diff options
| author | Dmitri Shuralyov <dmitshur@golang.org> | 2026-01-24 13:03:14 -0500 |
|---|---|---|
| committer | Gopher Robot <gobot@golang.org> | 2026-02-06 14:53:30 -0800 |
| commit | cbb37e310e2edd7148c8501567e190746e6d98d2 (patch) | |
| tree | c74a8112ecca81e4f6651f56dcdf5e9d1e0ae718 /src/net/http | |
| parent | d1ec0ecec956eb10c3daf40160193daf407c7614 (diff) | |
| download | go-cbb37e310e2edd7148c8501567e190746e6d98d2.tar.xz | |
net/http: fix WaitGroup race in TestTransportNoReuseAfterEarlyResponse
The remaining race reported in go.dev/issue/66519 is that it's possible
for copying.Wait to start running before all copying.Add calls complete.
It happens infrequently as is, but padding both Wait and Add calls with
a 100 ms sleep makes it highly reproducible.
Arranging the Add call to happen before responding "foo" to the POST
request should be enough to guarantee that Wait doesn't start running
until all Add calls have already happened.
While here, delete a blank line that gets more in the way of reading
error handling code than it helps.
For #64252.
Fixes #66519 (optimistically).
Change-Id: Ibf264d8cc5ffc2495e8ae8e66a15591310c65e71
Reviewed-on: https://go-review.googlesource.com/c/go/+/739060
Reviewed-by: Dmitri Shuralyov <dmitshur@google.com>
LUCI-TryBot-Result: Go LUCI <golang-scoped@luci-project-accounts.iam.gserviceaccount.com>
Reviewed-by: Damien Neil <dneil@google.com>
Auto-Submit: Dmitri Shuralyov <dmitshur@golang.org>
Diffstat (limited to 'src/net/http')
| -rw-r--r-- | src/net/http/client_test.go | 1 | ||||
| -rw-r--r-- | src/net/http/transport_test.go | 10 |
2 files changed, 5 insertions, 6 deletions
diff --git a/src/net/http/client_test.go b/src/net/http/client_test.go index d184f72031..9952ed52c6 100644 --- a/src/net/http/client_test.go +++ b/src/net/http/client_test.go @@ -438,7 +438,6 @@ func testRedirectsByMethod(t *testing.T, mode testMode, method string, table []r req, _ := NewRequest(method, ts.URL+tt.suffix, strings.NewReader(content)) req.GetBody = func() (io.ReadCloser, error) { return io.NopCloser(strings.NewReader(content)), nil } res, err := c.Do(req) - if err != nil { t.Fatal(err) } diff --git a/src/net/http/transport_test.go b/src/net/http/transport_test.go index 37e6cbb8e3..799384e5ac 100644 --- a/src/net/http/transport_test.go +++ b/src/net/http/transport_test.go @@ -3877,7 +3877,7 @@ func testTransportNoReuseAfterEarlyResponse(t *testing.T, mode testMode) { c net.Conn } var getOkay bool - var copying sync.WaitGroup + var willCopy sync.WaitGroup closeConn := func() { sconn.Lock() defer sconn.Unlock() @@ -3891,7 +3891,7 @@ func testTransportNoReuseAfterEarlyResponse(t *testing.T, mode testMode) { } defer func() { closeConn() - copying.Wait() + willCopy.Wait() }() ts := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) { @@ -3903,12 +3903,12 @@ func testTransportNoReuseAfterEarlyResponse(t *testing.T, mode testMode) { sconn.Lock() sconn.c = conn sconn.Unlock() - conn.Write([]byte("HTTP/1.1 200 OK\r\nContent-Length: 3\r\n\r\nfoo")) // keep-alive - copying.Add(1) + willCopy.Add(1) + conn.Write([]byte("HTTP/1.1 200 OK\r\nContent-Length: 3\r\n\r\nfoo")) // keep-alive go func() { io.Copy(io.Discard, conn) - copying.Done() + willCopy.Done() }() })).ts c := ts.Client() |