|
@@ -10,7 +10,6 @@ package udp
|
|
|
|
|
|
|
|
import (
|
|
import (
|
|
|
"context"
|
|
"context"
|
|
|
- "errors"
|
|
|
|
|
"fmt"
|
|
"fmt"
|
|
|
"net"
|
|
"net"
|
|
|
"net/netip"
|
|
"net/netip"
|
|
@@ -83,15 +82,6 @@ func (u *GenericConn) ListenOut(r EncReader) error {
|
|
|
n, rua, err := u.ReadFromUDPAddrPort(buffer)
|
|
n, rua, err := u.ReadFromUDPAddrPort(buffer)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
return err
|
|
return err
|
|
|
- if errors.Is(err, net.ErrClosed) {
|
|
|
|
|
- return err
|
|
|
|
|
- }
|
|
|
|
|
- // Dampen unexpected message warns to once per minute
|
|
|
|
|
- if lastRecvErr.IsZero() || time.Since(lastRecvErr) > time.Minute {
|
|
|
|
|
- lastRecvErr = time.Now()
|
|
|
|
|
- u.l.WithError(err).Warn("unexpected udp socket receive error")
|
|
|
|
|
- }
|
|
|
|
|
- continue
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
r(netip.AddrPortFrom(rua.Addr().Unmap(), rua.Port()), buffer[:n])
|
|
r(netip.AddrPortFrom(rua.Addr().Unmap(), rua.Port()), buffer[:n])
|