From c6a76ff281fd38401f620a146cb14e6b95d48889 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=A3=8E=E6=89=87=E6=BB=91=E7=BF=94=E7=BF=BC?= Date: Mon, 22 Dec 2025 05:13:52 +0000 Subject: [PATCH] format --- common/buf/copy.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/common/buf/copy.go b/common/buf/copy.go index 6219b30b..9ec5b50e 100644 --- a/common/buf/copy.go +++ b/common/buf/copy.go @@ -5,9 +5,9 @@ import ( "sync" "time" - "github.com/xtls/xray-core/features/policy" "github.com/xtls/xray-core/common/errors" "github.com/xtls/xray-core/common/signal" + "github.com/xtls/xray-core/features/policy" "github.com/xtls/xray-core/features/stats" ) @@ -147,7 +147,7 @@ func copyV(r *SingleReader, w Writer, handler *copyHandler) error { // 0 in ARM MIPS MIPSLE // 4kb in ARM64 MIPS64 MIPS64LE // 512kb in others - channelBuffer := (policy.SessionDefault().Buffer.PerConnection)/Size + channelBuffer := (policy.SessionDefault().Buffer.PerConnection) / Size if channelBuffer <= 0 { channelBuffer = 4 } @@ -217,9 +217,8 @@ func copyV(r *SingleReader, w Writer, handler *copyHandler) error { } }() wg.Wait() - for range cache { - // drain cache - b := <-cache + // drain cache + for b := range cache { b.Release() } if wErr != nil {