From 190590733136b6fa640dbd735773cd747f4b6414 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: Sat, 23 May 2026 21:42:34 +0800 Subject: [PATCH] initxmux --- transport/internet/splithttp/dialer.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/transport/internet/splithttp/dialer.go b/transport/internet/splithttp/dialer.go index 6598619e..13539269 100644 --- a/transport/internet/splithttp/dialer.go +++ b/transport/internet/splithttp/dialer.go @@ -439,17 +439,19 @@ func Dial(ctx context.Context, dest net.Destination, streamSettings *internet.Me var closed atomic.Int32 reader, writer := io.Pipe() + initXmuxClient := xmuxClient + initXmuxClient2 := xmuxClient2 conn := splitConn{ writer: writer, onClose: func() { if closed.Add(1) > 1 { return } - if xmuxClient != nil { - xmuxClient.OpenUsage.Add(-1) + if initXmuxClient != nil { + initXmuxClient.OpenUsage.Add(-1) } - if xmuxClient2 != nil && xmuxClient2 != xmuxClient { - xmuxClient2.OpenUsage.Add(-1) + if initXmuxClient2 != nil && initXmuxClient2 != initXmuxClient { + initXmuxClient2.OpenUsage.Add(-1) } }, } @@ -544,9 +546,7 @@ func Dial(ctx context.Context, dest net.Destination, streamSettings *internet.Me if xmuxClient != nil && (xmuxClient.LeftRequests.Add(-1) <= 0 || (xmuxClient.UnreusableAt != time.Time{} && lastWrite.After(xmuxClient.UnreusableAt))) { - xmuxClient.OpenUsage.Add(-1) httpClient, xmuxClient = getHTTPClient(ctx, dest, streamSettings) - xmuxClient.OpenUsage.Add(1) } go func() {