diff --git a/pkg/proto/udp/udp.go b/pkg/proto/udp/udp.go index 21c41680..70b51900 100644 --- a/pkg/proto/udp/udp.go +++ b/pkg/proto/udp/udp.go @@ -140,6 +140,8 @@ func Forwarder(dstAddr *net.UDPAddr, readCh <-chan *msg.UDPPacket, sendCh chan<- _, err = udpConn.Write(buf) if err != nil { udpConn.Close() + } else { + _ = udpConn.SetReadDeadline(time.Now().Add(30 * time.Second)) } if !ok {