fix(超时处理): 进一步修复超时处理

This commit is contained in:
2026-01-22 20:21:43 +08:00
parent 32b8a908db
commit cefda21aa8
+1 -1
View File
@@ -110,10 +110,10 @@ func performTest(conn net.PacketConn, serverAddr string, network string, timeout
if _, err := conn.WriteTo(req, dst); err != nil { if _, err := conn.WriteTo(req, dst); err != nil {
return nil, nil, err return nil, nil, err
} }
conn.SetReadDeadline(time.Now().Add(timeout))
defer conn.SetReadDeadline(time.Time{}) defer conn.SetReadDeadline(time.Time{})
buf := make([]byte, 2048) buf := make([]byte, 2048)
for i := 0; i < 3; i++ { for i := 0; i < 3; i++ {
conn.SetReadDeadline(time.Now().Add(timeout))
n, addr, err := conn.ReadFrom(buf) n, addr, err := conn.ReadFrom(buf)
if err != nil { if err != nil {
if nerr, ok := err.(net.Error); ok && nerr.Timeout() { if nerr, ok := err.(net.Error); ok && nerr.Timeout() {