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
+	disableReuse bool
+}
+
+func (a *Args) SetDisableReuseArgs(b bool) {
+	a.disableReuse = 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.disableReuse {
+		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
@@ -140,6 +141,9 @@ func (s Server) Serve(c context.Context, conn network.Conn) (err error) {
 	ctx.HTMLRender = s.HTMLRender
 	ctx.SetConn(conn)
 	ctx.Request.SetIsTLS(s.TLS != nil)
+	ctx.Request.PostArgs().SetDisableReuseArgs(s.DisableReuseArgs)
+	ctx.Request.URI().QueryArgs().SetDisableReuseArgs(s.DisableReuseArgs)
+
 	ctx.SetEnableTrace(s.EnableTrace)
 
 	if !s.NoDefaultServerHeader {

pkg/protocol/request.go

@@ -181,7 +181,7 @@ func (req *Request) Scheme() []byte {
 	return req.uri.Scheme()
 }
 
-// For keepalive connection reuse.
+// For keepalive connection disableReuse.
 // It is roughly the same as ResetSkipHeader, except that the connection related fields are removed:
 // - req.isTLS
 func (req *Request) resetSkipHeaderAndConn() {

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.