mirrors/Xray-core
1
0
Fork 0
mirror of https://github.com/XTLS/Xray-core.git synced 2025-07-26 20:04:14 +00:00
Code Issues Projects Releases Packages Wiki Activity

Update client.go

Browse source
This commit is contained in:
风扇滑翔翼 2025-07-08 22:01:09 +08:00 • committed by GitHub
parent ec4f48d429
commit fd71c36e2c
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 3 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

7
common/mux/client.go
View file

@ -174,7 +174,6 @@ type ClientWorker struct {
link transport.Link link transport.Link
done *done.Instance done *done.Instance
strategy ClientStrategy strategy ClientStrategy
access sync.Mutex
} }
var ( var (
@ -277,6 +276,8 @@ func (m *ClientWorker) IsClosing() bool {
return false return false
} }
// IsFull returns true if this ClientWorker is unable to accept more connections.
// it might be because it is closing, or the number of connections has reached the limit.
func (m *ClientWorker) IsFull() bool { func (m *ClientWorker) IsFull() bool {
if m.IsClosing() || m.Closed() { if m.IsClosing() || m.Closed() {
return true return true
@ -290,14 +291,12 @@ func (m *ClientWorker) IsFull() bool {
} }
func (m *ClientWorker) Dispatch(ctx context.Context, link *transport.Link) bool { func (m *ClientWorker) Dispatch(ctx context.Context, link *transport.Link) bool {
m.access.Lock()
defer m.access.Unlock()
if m.IsFull() { if m.IsFull() {
return false return false
} }
sm := m.sessionManager sm := m.sessionManager
s := sm.Allocate() s := sm.Allocate(int(m.strategy.MaxConcurrency))
if s == nil { if s == nil {
return false return false
} }