mirror of
https://github.com/cmz0228/hysteria-dev.git
synced 2025-06-22 12:29:57 +00:00
fix tun timeout check
This commit is contained in:
parent
5b90ac21fa
commit
56825c5525
@ -275,7 +275,7 @@ func client(config *clientConfig) {
|
||||
"src": addr.String(),
|
||||
"dst": reqAddr,
|
||||
}).Debugf("TUN %s closed for timeout", strings.ToUpper(addr.Network()))
|
||||
} else if err.Error() == "deadline exceeded" && strings.HasPrefix(addr.Network(), "tcp") {
|
||||
} else if nErr, ok := err.(net.Error); ok && nErr.Timeout() && strings.HasPrefix(addr.Network(), "tcp") {
|
||||
logrus.WithFields(logrus.Fields{
|
||||
"src": addr.String(),
|
||||
"dst": reqAddr,
|
||||
|
@ -35,9 +35,11 @@ func (s *Server) relayTCP(clientConn, relayConn net.Conn) {
|
||||
}
|
||||
relayConn.Close()
|
||||
clientConn.Close()
|
||||
if closeErr != nil && closeErr.Error() == "deadline exceeded" {
|
||||
if clientConn, ok := clientConn.(tun2socks.TCPConn); ok {
|
||||
clientConn.Abort()
|
||||
if closeErr != nil {
|
||||
if err, ok := closeErr.(net.Error); ok && err.Timeout() {
|
||||
if clientConn, ok := clientConn.(tun2socks.TCPConn); ok {
|
||||
clientConn.Abort()
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
Loading…
x
Reference in New Issue
Block a user