fix HTTP request writing if the Request.Body reads data and returns EOF

http3/request_writer.go

@@ -57,14 +57,13 @@ func (w *requestWriter) WriteRequest(str quic.Stream, req *http.Request, gzip bo
 		defer req.Body.Close()
 		b := make([]byte, bodyCopyBufferSize)
 		for {
-			n, err := req.Body.Read(b)
+			n, rerr := req.Body.Read(b)
-			if err == io.EOF {
+			if n == 0 {
-				break
+				if rerr == nil {
-			}
+					continue
-			if err != nil {
+				} else if rerr == io.EOF {
-				str.CancelWrite(quic.ErrorCode(errorRequestCanceled))
+					break
-				w.logger.Errorf("Error writing request: %s", err)
+				}
-				return
 			}
 			buf := &bytes.Buffer{}
 			(&dataFrame{Length: uint64(n)}).Write(buf)
@@ -76,6 +75,14 @@ func (w *requestWriter) WriteRequest(str quic.Stream, req *http.Request, gzip bo
 				w.logger.Errorf("Error writing request: %s", err)
 				return
 			}
+			if rerr != nil {
+				if rerr == io.EOF {
+					break
+				}
+				str.CancelWrite(quic.ErrorCode(errorRequestCanceled))
+				w.logger.Errorf("Error writing request: %s", rerr)
+				return
+			}
 		}
 		str.Close()
 	}()

http3/request_writer_test.go

@@ -16,6 +16,12 @@ import (
 	. "github.com/onsi/gomega"
 )
 
+type foobarReader struct{}
+
+func (r *foobarReader) Read(b []byte) (int, error) {
+	return copy(b, []byte("foobar")), io.EOF
+}
+
 var _ = Describe("Request Writer", func() {
 	var (
 		rw     *requestWriter
@@ -85,6 +91,23 @@ var _ = Describe("Request Writer", func() {
 		Expect(frame.(*dataFrame).Length).To(BeEquivalentTo(6))
 	})
 
+	It("writes a POST request, if the Body returns an EOF immediately", func() {
+		closed := make(chan struct{})
+		str.EXPECT().Close().Do(func() { close(closed) })
+		req, err := http.NewRequest("POST", "https://quic.clemente.io/upload.html", &foobarReader{})
+		Expect(err).ToNot(HaveOccurred())
+		Expect(rw.WriteRequest(str, req, false)).To(Succeed())
+
+		Eventually(closed).Should(BeClosed())
+		headerFields := decode(strBuf)
+		Expect(headerFields).To(HaveKeyWithValue(":method", "POST"))
+
+		frame, err := parseNextFrame(strBuf)
+		Expect(err).ToNot(HaveOccurred())
+		Expect(frame).To(BeAssignableToTypeOf(&dataFrame{}))
+		Expect(frame.(*dataFrame).Length).To(BeEquivalentTo(6))
+	})
+
 	It("sends cookies", func() {
 		str.EXPECT().Close()
 		req, err := http.NewRequest("GET", "https://quic.clemente.io/", nil)