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

UDP: faster close (in some rare situations)

Browse source
This commit is contained in:
patterniha 2025-07-19 11:59:59 +03:30
parent 83686ebfaa
commit 212382ccbb
4 changed files with 11 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

7
app/proxyman/inbound/worker.go
View file

@ -161,6 +161,7 @@ type udpConn struct {
uplink stats.Counter
downlink stats.Counter
inactive bool
cancel context.CancelFunc
}
func (c *udpConn) setInactive() {
@ -203,6 +204,9 @@ func (c *udpConn) Write(buf []byte) (int, error) {
}
func (c *udpConn) Close() error {
if c.cancel != nil {
c.cancel()
}
common.Must(c.done.Close())
common.Must(common.Close(c.writer))
return nil
@ -306,7 +310,8 @@ func (w *udpWorker) callback(b *buf.Buffer, source net.Destination, originalDest
common.Must(w.checker.Start())
go func() {
ctx := w.ctx
ctx, cancel := context.WithCancel(w.ctx)
conn.cancel = cancel
sid := session.NewID()
ctx = c.ContextWithID(ctx, sid)