mirror of
https://github.com/ICKelin/gtun.git
synced 2025-09-26 19:11:15 +08:00
fix: fix quic reconnect fail
This commit is contained in:
@@ -191,16 +191,16 @@ func (p *TProxyUDP) serve(lconn *net.UDPConn) error {
|
|||||||
p.udpsessLock.Unlock()
|
p.udpsessLock.Unlock()
|
||||||
sess := p.routeManager.Route(p.region, dip)
|
sess := p.routeManager.Route(p.region, dip)
|
||||||
if sess == nil {
|
if sess == nil {
|
||||||
// force close to trigger reconnect
|
|
||||||
// quic CAN'T get close state by sess.IsClose()
|
|
||||||
// Close to trigger quic reconnect
|
|
||||||
sess.Close()
|
|
||||||
logs.Error("no route to host: %s", dip)
|
logs.Error("no route to host: %s", dip)
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
stream, err := sess.OpenStream()
|
stream, err := sess.OpenStream()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
// force close to trigger reconnect
|
||||||
|
// quic CAN'T get close state by sess.IsClose()
|
||||||
|
// Close to trigger quic reconnect
|
||||||
|
sess.Close()
|
||||||
logs.Error("open stream fail: %v", err)
|
logs.Error("open stream fail: %v", err)
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user