mirror of
https://github.com/fatedier/frp.git
synced 2025-06-17 09:08:21 +00:00
Merge a13b23e7ed247b2a07a796a4336fc1697b0ca4cb into acf33db4e4b6c9cf9182d93280299010637b6324
This commit is contained in:
commit
7a86364fe7
@ -65,7 +65,7 @@ type Wrapper struct {
|
|||||||
// underlying proxy
|
// underlying proxy
|
||||||
pxy Proxy
|
pxy Proxy
|
||||||
|
|
||||||
// if ProxyConf has healcheck config
|
// if ProxyConf has health check config
|
||||||
// monitor will watch if it is alive
|
// monitor will watch if it is alive
|
||||||
monitor *health.Monitor
|
monitor *health.Monitor
|
||||||
|
|
||||||
|
@ -157,9 +157,9 @@ func (sv *XTCPVisitor) keepTunnelOpenWorker() {
|
|||||||
|
|
||||||
func (sv *XTCPVisitor) handleConn(userConn net.Conn) {
|
func (sv *XTCPVisitor) handleConn(userConn net.Conn) {
|
||||||
xl := xlog.FromContextSafe(sv.ctx)
|
xl := xlog.FromContextSafe(sv.ctx)
|
||||||
isConnTrasfered := false
|
isConnTransferred := false
|
||||||
defer func() {
|
defer func() {
|
||||||
if !isConnTrasfered {
|
if !isConnTransferred {
|
||||||
userConn.Close()
|
userConn.Close()
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
@ -187,7 +187,7 @@ func (sv *XTCPVisitor) handleConn(userConn net.Conn) {
|
|||||||
xl.Errorf("transfer connection to visitor %s error: %v", sv.cfg.FallbackTo, err)
|
xl.Errorf("transfer connection to visitor %s error: %v", sv.cfg.FallbackTo, err)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
isConnTrasfered = true
|
isConnTransferred = true
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user