WIP feat: add option sets whether reset args when reset

pkg/app/server/option.go

@@ -394,3 +394,9 @@ func WithDisableDefaultContentType(disable bool) config.Option {
 		o.NoDefaultContentType = disable
 	}}
 }
+
+func WithDisableRecycleArgs(disable bool) config.Option {
+	return config.Option{F: func(o *config.Options) {
+		o.DisableReuseArgs = disable
+	}}
+}

pkg/common/config/option.go

@@ -119,6 +119,7 @@ type Options struct {
 	//     * content-type -> Content-Type
 	//     * cONTENT-lenGTH -> Content-Length
 	DisableHeaderNamesNormalizing bool
+	DisableReuseArgs              bool
 }
 
 func (o *Options) Apply(opts []Option) {
@@ -256,6 +257,8 @@ func NewOptions(opts []Option) *Options {
 
 		// Disabled header names' normalization, default false
 		DisableHeaderNamesNormalizing: false,
+		// Disable recycling request arguments, default false
+		DisableReuseArgs: false,
 	}
 	options.Apply(opts)
 	return options

pkg/protocol/args.go

@@ -63,8 +63,13 @@ type argsScanner struct {
 type Args struct {
 	noCopy nocopy.NoCopy //lint:ignore U1000 until noCopy is used
 
-	args []argsKV
-	buf  []byte
+	args  []argsKV
+	buf   []byte
+	reuse bool
+}
+
+func (a *Args) SetReuseArgs(b bool) {
+	a.reuse = b
 }
 
 // Set sets 'key=value' argument.
@@ -74,6 +79,9 @@ func (a *Args) Set(key, value string) {
 
 // Reset clears query args.
 func (a *Args) Reset() {
+	if a.reuse {
+		a.args = []argsKV{}
+	}
 	a.args = a.args[:0]
 }
 

pkg/protocol/http1/server.go

@@ -62,6 +62,7 @@ type Option struct {
 	DisableKeepalive              bool
 	NoDefaultServerHeader         bool
 	DisableHeaderNamesNormalizing bool
+	DisableReuseArgs              bool
 	MaxRequestBodySize            int
 	IdleTimeout                   time.Duration
 	ReadTimeout                   time.Duration
@@ -191,6 +192,9 @@ func (s Server) Serve(c context.Context, conn network.Conn) (err error) {
 			ctx.Response.Header.DisableNormalizing()
 		}
 
+		ctx.Request.PostArgs().SetReuseArgs(s.DisableReuseArgs)
+		ctx.Request.URI().QueryArgs().SetReuseArgs(s.DisableReuseArgs)
+
 		// Read Headers
 		if err = req.ReadHeader(&ctx.Request.Header, zr); err == nil {
 			if s.EnableTrace {

pkg/route/engine.go

@@ -1067,6 +1067,7 @@ func newHttp1OptionFromEngine(engine *Engine) *http1.Option {
 		DisableHeaderNamesNormalizing: engine.options.DisableHeaderNamesNormalizing,
 		NoDefaultDate:                 engine.options.NoDefaultDate,
 		NoDefaultContentType:          engine.options.NoDefaultContentType,
+		DisableReuseArgs:              engine.options.DisableReuseArgs,
 	}
 	// Idle timeout of standard network must not be zero. Set it to -1 seconds if it is zero.
 	// Due to the different triggering ways of the network library, see the actual use of this value for the detailed reasons.