mirror of
https://github.com/fumiama/WireGold.git
synced 2026-06-12 12:50:28 +08:00
fix(listen): timeout loop
This commit is contained in:
@@ -54,6 +54,7 @@ func (m *Me) listenudp() (conn *net.UDPConn, err error) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
logrus.Warnln("[listen] set ddl err:", err)
|
logrus.Warnln("[listen] set ddl err:", err)
|
||||||
}
|
}
|
||||||
|
READ:
|
||||||
n, addr, err := conn.ReadFromUDP(lbf)
|
n, addr, err := conn.ReadFromUDP(lbf)
|
||||||
if m.loop == nil {
|
if m.loop == nil {
|
||||||
logrus.Warnln("[listen] quit listening")
|
logrus.Warnln("[listen] quit listening")
|
||||||
@@ -61,6 +62,7 @@ func (m *Me) listenudp() (conn *net.UDPConn, err error) {
|
|||||||
}
|
}
|
||||||
if errors.Is(err, os.ErrDeadlineExceeded) {
|
if errors.Is(err, os.ErrDeadlineExceeded) {
|
||||||
err = nil
|
err = nil
|
||||||
|
goto READ
|
||||||
}
|
}
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logrus.Warnln("[listen] read from udp err, reconnect:", err)
|
logrus.Warnln("[listen] read from udp err, reconnect:", err)
|
||||||
|
|||||||
Reference in New Issue
Block a user