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

Prevent remove ray

Browse source
This commit is contained in:
风扇滑翔翼 2025-07-15 16:11:14 +00:00 • committed by GitHub
parent 523e583299
commit 399ec65c8c
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 7 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

8
transport/internet/udp/dispatcher.go
View file

@ -44,6 +44,10 @@ func NewDispatcher(dispatcher routing.Dispatcher, callback ResponseCallback) *Di
func (v *Dispatcher) RemoveRay() { func (v *Dispatcher) RemoveRay() {
v.Lock() v.Lock()
defer v.Unlock() defer v.Unlock()
v.removeRay()
}
func (v *Dispatcher) removeRay() {
if v.conn != nil { if v.conn != nil {
common.Interrupt(v.conn.link.Reader) common.Interrupt(v.conn.link.Reader)
common.Close(v.conn.link.Writer) common.Close(v.conn.link.Writer)
@ -64,9 +68,11 @@ func (v *Dispatcher) getInboundRay(ctx context.Context, dest net.Destination) (*
ctx, cancel := context.WithCancel(ctx) ctx, cancel := context.WithCancel(ctx)
entry := &connEntry{} entry := &connEntry{}
removeRay := func() { removeRay := func() {
v.Lock()
defer v.Unlock()
if entry == v.conn { if entry == v.conn {
cancel() cancel()
v.RemoveRay() v.removeRay()
} else { } else {
errors.LogError(ctx, "removeRay trying to remove a conn that not belongs to it, canceling.") errors.LogError(ctx, "removeRay trying to remove a conn that not belongs to it, canceling.")
} }