xmengnet/mihomo
1
1
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

chore: disconnect when suspended

Browse source
This commit is contained in:
gVisor bot 2023-03-14 22:57:43 +08:00
parent d2b5e19b68
commit 931dd615e3
1 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
tunnel/tunnel.go
View file

@ -12,6 +12,7 @@ import (
"time" "time"
"github.com/jpillora/backoff" "github.com/jpillora/backoff"
"go.uber.org/atomic"
N "github.com/Dreamacro/clash/common/net" N "github.com/Dreamacro/clash/common/net"
"github.com/Dreamacro/clash/component/nat" "github.com/Dreamacro/clash/component/nat"
@ -26,7 +27,7 @@ import (
) )
var ( var (
status C.TunnelStatus status = atomic.NewInt32(int32(C.TunnelSuspend))
tcpQueue = make(chan C.ConnContext, 200) tcpQueue = make(chan C.ConnContext, 200)
udpQueue = make(chan C.PacketAdapter, 200) udpQueue = make(chan C.PacketAdapter, 200)
natTable = nat.New() natTable = nat.New()
@ -51,15 +52,18 @@ var (
) )
func OnSuspend() { func OnSuspend() {
status = C.TunnelSuspend status.Store(int32(C.TunnelSuspend))
for _, c := range statistic.DefaultManager.Snapshot().Connections {
_ = c.Close()
}
} }
func OnInnerLoading() { func OnInnerLoading() {
status = C.TunnelInner status.Store(int32(C.TunnelInner))
} }
func OnRunning() { func OnRunning() {
status = C.TunnelRunning status.Store(int32(C.TunnelRunning))
} }
func SetFakeIPRange(p netip.Prefix) { func SetFakeIPRange(p netip.Prefix) {
@ -172,6 +176,7 @@ func SetFindProcessMode(mode P.FindProcessMode) {
} }
func isHandle(t C.Type) bool { func isHandle(t C.Type) bool {
status := C.TunnelStatus(status.Load())
return status == C.TunnelRunning || (status == C.TunnelInner && t == C.INNER) return status == C.TunnelRunning || (status == C.TunnelInner && t == C.INNER)
} }