mirror of
https://github.com/v2fly/v2ray-core.git
synced 2025-02-20 23:47:21 -05:00
Merge branch 'master' of https://github.com/v2ray/v2ray-core
This commit is contained in:
commit
2a3facab5a
@ -42,7 +42,7 @@ func (s *session) closeUplink() {
|
||||
allDone = s.uplinkClosed && s.downlinkClosed
|
||||
s.Unlock()
|
||||
if allDone {
|
||||
s.parent.remove(s.id)
|
||||
go s.parent.remove(s.id)
|
||||
}
|
||||
}
|
||||
|
||||
@ -53,7 +53,7 @@ func (s *session) closeDownlink() {
|
||||
allDone = s.uplinkClosed && s.downlinkClosed
|
||||
s.Unlock()
|
||||
if allDone {
|
||||
s.parent.remove(s.id)
|
||||
go s.parent.remove(s.id)
|
||||
}
|
||||
}
|
||||
|
||||
@ -279,6 +279,15 @@ func (m *Client) fetchOutput() {
|
||||
break
|
||||
}
|
||||
}
|
||||
|
||||
// Close all downlinks
|
||||
m.access.RLock()
|
||||
for _, s := range m.sessions {
|
||||
s.closeUplink()
|
||||
s.closeDownlink()
|
||||
s.output.CloseError()
|
||||
}
|
||||
m.access.RUnlock()
|
||||
}
|
||||
|
||||
type Server struct {
|
||||
|
Loading…
x
Reference in New Issue
Block a user