From 7950f17da5bf04e076cabf1005e728845947ceee Mon Sep 17 00:00:00 2001 From: xfy Date: Fri, 10 Apr 2026 09:40:47 +0800 Subject: [PATCH] =?UTF-8?q?refactor(server):=20=E9=80=82=E9=85=8D=E5=8F=98?= =?UTF-8?q?=E9=87=8F=E7=B3=BB=E7=BB=9F=E9=87=8D=E5=91=BD=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 适配 variable.NewContext/ReleaseContext 重命名 Co-Authored-By: Claude Opus 4.6 --- internal/server/pool.go | 2 +- internal/server/pool_test.go | 8 ++++---- internal/server/server.go | 2 +- internal/server/server_test.go | 2 +- 4 files changed, 7 insertions(+), 7 deletions(-) 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) { // 空响应 }