lzhr/v2fly
1
0
Fork 0
mirror of https://github.com/v2fly/v2ray-core.git synced 2025-01-02 07:26:24 -05:00
Code Issues Releases Wiki Activity

Fix: Remove udp conn twice

Browse Source
This commit is contained in:
Ovear 2021-09-27 12:47:43 +08:00 committed by Xiaokang Wang
parent a4cd3110f1
commit 75eead5a6e
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
app/proxyman/inbound/worker.go
View File

@ -153,6 +153,11 @@ type udpConn struct {
done *done.Instance done *done.Instance
uplink stats.Counter uplink stats.Counter
downlink stats.Counter downlink stats.Counter
inactive bool
}
func (c *udpConn) setInactive() {
c.inactive = true
} }
func (c *udpConn) updateActivity() { func (c *udpConn) updateActivity() {
@ -315,7 +320,13 @@ func (w *udpWorker) callback(b *buf.Buffer, source net.Destination, originalDest
newError("connection ends").Base(err).WriteToLog(session.ExportIDToError(ctx)) newError("connection ends").Base(err).WriteToLog(session.ExportIDToError(ctx))
} }
conn.Close() conn.Close()
w.removeConn(id) // conn not removed by checker TODO may be lock worker here is better
if !conn.inactive {
conn.setInactive()
w.removeConn(id)
} else {
newError("connection already removed by checker: ", conn).AtDebug().WriteToLog(session.ExportIDToError(ctx))
}
}() }()
} }
} }
@ -344,7 +355,10 @@ func (w *udpWorker) clean() error {
for addr, conn := range w.activeConn { for addr, conn := range w.activeConn {
if nowSec-atomic.LoadInt64(&conn.lastActivityTime) > 8 { // TODO Timeout too small if nowSec-atomic.LoadInt64(&conn.lastActivityTime) > 8 { // TODO Timeout too small
delete(w.activeConn, addr) if !conn.inactive {
conn.setInactive()
delete(w.activeConn, addr)
}
conn.Close() conn.Close()
} }
} }