RM TCPKeepAliveConfig

pull/4932/head
xqzr 2025-07-25 17:40:14 +08:00 committed by GitHub
parent ba2f6cfd87
commit 560704db35
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 10 deletions

View File

@ -3,7 +3,6 @@ package internet
import ( import (
"context" "context"
"math/rand" "math/rand"
gonet "net"
"syscall" "syscall"
"time" "time"
@ -88,22 +87,14 @@ func (d *DefaultSystemDialer) Dial(ctx context.Context, src net.Address, dest ne
Dest: destAddr, Dest: destAddr,
}, nil }, nil
} }
TCPKeepAlive := time.Duration(0) TCPKeepAlive := time.Duration(45)
TCPKeepAliveConfig := gonet.KeepAliveConfig {
Enable: true,
Idle: 45 * time.Second,
Interval: 45 * time.Second,
Count: -1,
}
if sockopt != nil && (sockopt.TcpKeepAliveInterval != 0 || sockopt.TcpKeepAliveIdle != 0) { if sockopt != nil && (sockopt.TcpKeepAliveInterval != 0 || sockopt.TcpKeepAliveIdle != 0) {
TCPKeepAlive = time.Duration(-1) TCPKeepAlive = time.Duration(-1)
TCPKeepAliveConfig.Enable = false
} }
dialer := &net.Dialer{ dialer := &net.Dialer{
Timeout: time.Second * 16, Timeout: time.Second * 16,
LocalAddr: resolveSrcAddr(dest.Network, src), LocalAddr: resolveSrcAddr(dest.Network, src),
KeepAlive: TCPKeepAlive, KeepAlive: TCPKeepAlive,
KeepAliveConfig: TCPKeepAliveConfig,
} }
if sockopt != nil || len(d.controllers) > 0 { if sockopt != nil || len(d.controllers) > 0 {