add log

pkg/protocol/http1/req/request.go

@@ -46,6 +46,7 @@ import (
 	"encoding/base64"
 	"errors"
 	"fmt"
+	"github.com/cloudwego/hertz/pkg/common/hlog"
 	"io"
 	"mime/multipart"
 
@@ -253,6 +254,7 @@ func write(req *protocol.Request, w network.Writer, usingProxy bool) error {
 // then errBodyTooLarge is returned.
 func ContinueReadBodyStream(req *protocol.Request, zr network.Reader, maxBodySize int, preParseMultipartForm ...bool) error {
 	var err error
+	hlog.Infof("Read stream req body contentLength  = %d", req.Header.ContentLength())
 	contentLength := req.Header.ContentLength()
 	if contentLength > 0 {
 		if len(preParseMultipartForm) == 0 || preParseMultipartForm[0] {
@@ -287,6 +289,7 @@ func ContinueReadBodyStream(req *protocol.Request, zr network.Reader, maxBodySiz
 	bodyBuf.Reset()
 	bodyBuf.B, err = ext.ReadBodyWithStreaming(zr, contentLength, maxBodySize, bodyBuf.B)
 	if err != nil {
+		hlog.Infof("ext.ReadBodyWithStreaming err = %v", err)
 		if errors.Is(err, errs.ErrBodyTooLarge) {
 			req.Header.SetContentLength(contentLength)
 			req.ConstructBodyStream(bodyBuf, ext.AcquireBodyStream(bodyBuf, zr, req.Header.Trailer(), contentLength))

pkg/protocol/http1/server.go

@@ -20,6 +20,7 @@ import (
 	"context"
 	"crypto/tls"
 	"errors"
+	"github.com/cloudwego/hertz/pkg/common/hlog"
 	"io"
 	"net"
 	"sync"
@@ -233,6 +234,7 @@ func (s Server) Serve(c context.Context, conn network.Conn) (err error) {
 			}
 			// Read body
 			if s.StreamRequestBody {
+				hlog.Infof("Read stream req body MaxRequestBodySize = %d", s.MaxRequestBodySize)
 				err = req.ReadBodyStream(&ctx.Request, zr, s.MaxRequestBodySize, s.GetOnly, !s.DisablePreParseMultipartForm)
 			} else {
 				err = req.ReadLimitBody(&ctx.Request, zr, s.MaxRequestBodySize, s.GetOnly, !s.DisablePreParseMultipartForm)