|
|
@ -68,9 +68,6 @@ func NewInternodeDialContext(dialTimeout time.Duration) DialContext { |
|
|
|
return func(ctx context.Context, network, addr string) (net.Conn, error) { |
|
|
|
return func(ctx context.Context, network, addr string) (net.Conn, error) { |
|
|
|
dialer := &net.Dialer{ |
|
|
|
dialer := &net.Dialer{ |
|
|
|
Timeout: dialTimeout, |
|
|
|
Timeout: dialTimeout, |
|
|
|
// If zero, Go defaults to '300ms', we will default to 100ms instead.
|
|
|
|
|
|
|
|
// https://tools.ietf.org/html/rfc6555
|
|
|
|
|
|
|
|
FallbackDelay: 100 * time.Millisecond, |
|
|
|
|
|
|
|
Control: func(network, address string, c syscall.RawConn) error { |
|
|
|
Control: func(network, address string, c syscall.RawConn) error { |
|
|
|
return setInternalTCPParameters(c) |
|
|
|
return setInternalTCPParameters(c) |
|
|
|
}, |
|
|
|
}, |
|
|
@ -84,9 +81,6 @@ func NewCustomDialContext(dialTimeout time.Duration) DialContext { |
|
|
|
return func(ctx context.Context, network, addr string) (net.Conn, error) { |
|
|
|
return func(ctx context.Context, network, addr string) (net.Conn, error) { |
|
|
|
dialer := &net.Dialer{ |
|
|
|
dialer := &net.Dialer{ |
|
|
|
Timeout: dialTimeout, |
|
|
|
Timeout: dialTimeout, |
|
|
|
// If zero, Go defaults to '300ms', we will default to 100ms instead.
|
|
|
|
|
|
|
|
// https://tools.ietf.org/html/rfc6555
|
|
|
|
|
|
|
|
FallbackDelay: 100 * time.Millisecond, |
|
|
|
|
|
|
|
Control: func(network, address string, c syscall.RawConn) error { |
|
|
|
Control: func(network, address string, c syscall.RawConn) error { |
|
|
|
return c.Control(func(fdPtr uintptr) { |
|
|
|
return c.Control(func(fdPtr uintptr) { |
|
|
|
// got socket file descriptor to set parameters.
|
|
|
|
// got socket file descriptor to set parameters.
|
|
|
|