diff --git a/internal/server/pool.go b/internal/server/pool.go index 551b230..bb3420b 100644 --- a/internal/server/pool.go +++ b/internal/server/pool.go @@ -274,7 +274,7 @@ type PoolStats struct { func (p *GoroutinePool) WrapHandler(handler fasthttp.RequestHandler) fasthttp.RequestHandler { return func(ctx *fasthttp.RequestCtx) { // 使用池执行处理器 - _ = p.Submit(ctx, func(innerCtx *fasthttp.RequestCtx) { + _ = p.Submit(ctx, func(_ *fasthttp.RequestCtx) { handler(ctx) }) } diff --git a/internal/server/pool_test.go b/internal/server/pool_test.go index 63f1095..0b4db3a 100644 --- a/internal/server/pool_test.go +++ b/internal/server/pool_test.go @@ -83,7 +83,7 @@ func TestPoolSubmit(t *testing.T) { defer p.Stop() var executed atomic.Bool - task := func(ctx *fasthttp.RequestCtx) { + task := func(*fasthttp.RequestCtx) { executed.Store(true) } @@ -142,7 +142,7 @@ func TestPoolConcurrentSubmit(t *testing.T) { wg.Add(1) go func() { defer wg.Done() - _ = p.Submit(nil, func(ctx *fasthttp.RequestCtx) { + _ = p.Submit(nil, func(_ *fasthttp.RequestCtx) { counter.Add(1) }) }() @@ -165,7 +165,7 @@ func TestPoolSubmitWhenStopped(t *testing.T) { // 不启动池 var executed atomic.Bool - task := func(ctx *fasthttp.RequestCtx) { + task := func(_ *fasthttp.RequestCtx) { executed.Store(true) } @@ -219,7 +219,7 @@ func TestPoolWrapHandler_WhenStopped(t *testing.T) { // 不启动池 var executed atomic.Bool - originalHandler := func(ctx *fasthttp.RequestCtx) { + originalHandler := func(*fasthttp.RequestCtx) { executed.Store(true) } diff --git a/internal/server/server.go b/internal/server/server.go index 56997f0..231eb1f 100644 --- a/internal/server/server.go +++ b/internal/server/server.go @@ -296,7 +296,7 @@ func (s *Server) buildMiddlewareChain(serverCfg *config.ServerConfig) (*middlewa serverCfg.Security.Headers.ContentSecurityPolicy != "" || serverCfg.Security.Headers.ReferrerPolicy != "" || serverCfg.Security.Headers.PermissionsPolicy != "" { - headers := security.NewSecurityHeadersWithHSTS(&serverCfg.Security.Headers, &serverCfg.SSL.HSTS) + headers := security.NewHeadersWithHSTS(&serverCfg.Security.Headers, &serverCfg.SSL.HSTS) middlewares = append(middlewares, headers) } diff --git a/internal/server/server_test.go b/internal/server/server_test.go index 4c02d84..463f453 100644 --- a/internal/server/server_test.go +++ b/internal/server/server_test.go @@ -618,7 +618,7 @@ func TestServer_TrackStats_EmptyBody(t *testing.T) { s := New(cfg) - handler := func(ctx *fasthttp.RequestCtx) { + handler := func(_ *fasthttp.RequestCtx) { // 空响应 }