Put EvenRawerHeadersCopy backfind-header-corruption

1 files changed, 12 insertions, 4 deletions

diff --git a/header.go b/header.go
index 4119b0f..591f9d1 100644
--- a/header.go
+++ b/header.go
@@ -77,9 +77,10 @@ type RequestHeader struct {
 	// wire.
 	rawHeadersCopy []byte
 
-	NeededMore int
-	Peeks      []int
-	Buffered   []int
+	NeededMore           int
+	Peeks                []int
+	Buffered             []int
+	EvenRawerHeadersCopy []byte
 }
 
 // SetContentRange sets 'Content-Range: bytes startPos-endPos/contentLength'
@@ -735,6 +736,7 @@ func (h *RequestHeader) CopyTo(dst *RequestHeader) {
 	dst.NeededMore = h.NeededMore
 	dst.Peeks = append(dst.Peeks[:0], h.Peeks...)
 	dst.Buffered = append(dst.Buffered[:0], h.Buffered...)
+	dst.EvenRawerHeadersCopy = append(dst.EvenRawerHeadersCopy[:0], h.EvenRawerHeadersCopy...)
 }
 
 // VisitAll calls f for each header.
@@ -1392,8 +1394,14 @@ func (h *RequestHeader) tryRead(r *bufio.Reader, n int) error {
 	h.resetSkipNormalize()
 	b, err := r.Peek(n)
 
+	buffered := r.Buffered()
 	h.Peeks = append(h.Peeks, n)
-	h.Buffered = append(h.Buffered, r.Buffered())
+	h.Buffered = append(h.Buffered, buffered)
+	if c := cap(h.EvenRawerHeadersCopy); c < buffered {
+		h.EvenRawerHeadersCopy = make([]byte, buffered)
+	}
+	peeked, _ := r.Peek(buffered)
+	h.EvenRawerHeadersCopy = append(h.EvenRawerHeadersCopy[:0], peeked...)
 
 	if len(b) == 0 {
 		if err == io.EOF {