diff options
| author | Brad Fitzpatrick <bradfitz@golang.org> | 2016-09-30 10:40:58 -0700 |
|---|---|---|
| committer | Brad Fitzpatrick <bradfitz@golang.org> | 2016-09-30 19:45:34 +0000 |
| commit | 9491e7d65e09644eb7db4e2ed5ff0139571cedf3 (patch) | |
| tree | a6ac35613bf1a51dfba3ce03d40ecc5d141e178c /src/net/http/transfer.go | |
| parent | ab6ba99484b637bad0c5a5fa2c590834c14746c7 (diff) | |
| download | go-9491e7d65e09644eb7db4e2ed5ff0139571cedf3.tar.xz | |
net/http: refactor testing of Request.Body on 0 ContentLength
Code movement only, to look more like the equivalent http2 code, and
to make an upcoming fix look more obvious.
Updates #16002 (to be fixed once this code is in)
Change-Id: Iaa4f965be14e98f9996e7c4624afe6e19bed1a80
Reviewed-on: https://go-review.googlesource.com/30087
Run-TryBot: Brad Fitzpatrick <bradfitz@golang.org>
TryBot-Result: Gobot Gobot <gobot@golang.org>
Reviewed-by: Ian Lance Taylor <iant@golang.org>
Reviewed-by: Joe Tsai <thebrokentoaster@gmail.com>
Diffstat (limited to 'src/net/http/transfer.go')
| -rw-r--r-- | src/net/http/transfer.go | 34 |
1 files changed, 7 insertions, 27 deletions
diff --git a/src/net/http/transfer.go b/src/net/http/transfer.go index 851469ccbc..9d31b71f32 100644 --- a/src/net/http/transfer.go +++ b/src/net/http/transfer.go @@ -59,37 +59,17 @@ func newTransferWriter(r interface{}) (t *transferWriter, err error) { return nil, fmt.Errorf("http: Request.ContentLength=%d with nil Body", rr.ContentLength) } t.Method = valueOrDefault(rr.Method, "GET") - t.Body = rr.Body - t.BodyCloser = rr.Body - t.ContentLength = rr.ContentLength t.Close = rr.Close t.TransferEncoding = rr.TransferEncoding t.Trailer = rr.Trailer atLeastHTTP11 = rr.ProtoAtLeast(1, 1) - if t.Body != nil && len(t.TransferEncoding) == 0 && atLeastHTTP11 { - if t.ContentLength == 0 { - // Test to see if it's actually zero or just unset. - var buf [1]byte - n, rerr := io.ReadFull(t.Body, buf[:]) - if rerr != nil && rerr != io.EOF { - t.ContentLength = -1 - t.Body = errorReader{rerr} - } else if n == 1 { - // Oh, guess there is data in this Body Reader after all. - // The ContentLength field just wasn't set. - // Stich the Body back together again, re-attaching our - // consumed byte. - t.ContentLength = -1 - t.Body = io.MultiReader(bytes.NewReader(buf[:]), t.Body) - } else { - // Body is actually empty. - t.Body = nil - t.BodyCloser = nil - } - } - if t.ContentLength < 0 { - t.TransferEncoding = []string{"chunked"} - } + + t.Body, t.ContentLength = rr.bodyAndLength() + if t.Body != nil { + t.BodyCloser = rr.Body + } + if t.ContentLength < 0 && len(t.TransferEncoding) == 0 && atLeastHTTP11 { + t.TransferEncoding = []string{"chunked"} } case *Response: t.IsResponse = true |
