sing-box/common/dialer/default.go

190 lines
6.1 KiB
Go
Raw Normal View History

package dialer
import (
"context"
"net"
"time"
"github.com/sagernet/sing-box/adapter"
2023-03-03 11:26:54 +00:00
"github.com/sagernet/sing-box/common/dialer/conntrack"
2022-07-24 14:54:16 +00:00
"github.com/sagernet/sing-box/common/warning"
2022-07-06 07:01:09 +00:00
C "github.com/sagernet/sing-box/constant"
"github.com/sagernet/sing-box/option"
2022-07-08 15:03:57 +00:00
"github.com/sagernet/sing/common/control"
2022-08-29 11:58:58 +00:00
E "github.com/sagernet/sing/common/exceptions"
2022-07-08 15:03:57 +00:00
M "github.com/sagernet/sing/common/metadata"
2022-07-29 16:29:22 +00:00
N "github.com/sagernet/sing/common/network"
2023-02-07 10:06:25 +00:00
"github.com/sagernet/tfo-go"
)
2022-07-24 14:54:16 +00:00
var warnBindInterfaceOnUnsupportedPlatform = warning.New(
func() bool {
2022-08-05 08:55:46 +00:00
return !(C.IsLinux || C.IsWindows || C.IsDarwin)
2022-07-24 14:54:16 +00:00
},
"outbound option `bind_interface` is only supported on Linux and Windows",
)
var warnRoutingMarkOnUnsupportedPlatform = warning.New(
func() bool {
return !C.IsLinux
},
"outbound option `routing_mark` is only supported on Linux",
)
var warnReuseAdderOnUnsupportedPlatform = warning.New(
func() bool {
return !(C.IsDarwin || C.IsDragonfly || C.IsFreebsd || C.IsLinux || C.IsNetbsd || C.IsOpenbsd || C.IsSolaris || C.IsWindows)
},
"outbound option `reuse_addr` is unsupported on current platform",
)
var warnProtectPathOnNonAndroid = warning.New(
func() bool {
return !C.IsAndroid
},
"outbound option `protect_path` is only supported on Android",
)
var warnTFOOnUnsupportedPlatform = warning.New(
func() bool {
return !(C.IsDarwin || C.IsFreebsd || C.IsLinux || C.IsWindows)
},
"outbound option `tcp_fast_open` is unsupported on current platform",
)
2022-07-07 13:47:21 +00:00
type DefaultDialer struct {
2022-11-03 03:51:09 +00:00
dialer4 tfo.Dialer
dialer6 tfo.Dialer
udpDialer4 net.Dialer
udpDialer6 net.Dialer
2022-08-22 06:35:05 +00:00
udpListener net.ListenConfig
2022-11-03 03:51:09 +00:00
udpAddr4 string
udpAddr6 string
}
func NewDefault(router adapter.Router, options option.DialerOptions) *DefaultDialer {
var dialer net.Dialer
var listener net.ListenConfig
if options.BindInterface != "" {
2022-07-24 14:54:16 +00:00
warnBindInterfaceOnUnsupportedPlatform.Check()
2022-09-14 04:46:02 +00:00
bindFunc := control.BindToInterface(router.InterfaceFinder(), options.BindInterface, -1)
2022-08-04 14:01:20 +00:00
dialer.Control = control.Append(dialer.Control, bindFunc)
listener.Control = control.Append(listener.Control, bindFunc)
} else if router.AutoDetectInterface() {
2022-10-25 04:55:00 +00:00
bindFunc := router.AutoDetectInterfaceFunc()
2022-09-14 04:46:02 +00:00
dialer.Control = control.Append(dialer.Control, bindFunc)
listener.Control = control.Append(listener.Control, bindFunc)
2022-07-15 03:51:51 +00:00
} else if router.DefaultInterface() != "" {
2022-09-14 04:46:02 +00:00
bindFunc := control.BindToInterface(router.InterfaceFinder(), router.DefaultInterface(), -1)
2022-08-04 14:01:20 +00:00
dialer.Control = control.Append(dialer.Control, bindFunc)
listener.Control = control.Append(listener.Control, bindFunc)
}
if options.RoutingMark != 0 {
2022-07-24 14:54:16 +00:00
warnRoutingMarkOnUnsupportedPlatform.Check()
dialer.Control = control.Append(dialer.Control, control.RoutingMark(options.RoutingMark))
listener.Control = control.Append(listener.Control, control.RoutingMark(options.RoutingMark))
2022-07-24 09:46:25 +00:00
} else if router.DefaultMark() != 0 {
dialer.Control = control.Append(dialer.Control, control.RoutingMark(router.DefaultMark()))
listener.Control = control.Append(listener.Control, control.RoutingMark(router.DefaultMark()))
}
if options.ReuseAddr {
2022-07-24 14:54:16 +00:00
warnReuseAdderOnUnsupportedPlatform.Check()
listener.Control = control.Append(listener.Control, control.ReuseAddr())
}
2022-07-06 06:45:56 +00:00
if options.ProtectPath != "" {
2022-07-24 14:54:16 +00:00
warnProtectPathOnNonAndroid.Check()
2022-07-11 10:44:59 +00:00
dialer.Control = control.Append(dialer.Control, control.ProtectPath(options.ProtectPath))
listener.Control = control.Append(listener.Control, control.ProtectPath(options.ProtectPath))
2022-07-06 06:45:56 +00:00
}
if options.ConnectTimeout != 0 {
2022-07-08 04:58:43 +00:00
dialer.Timeout = time.Duration(options.ConnectTimeout)
2022-07-18 12:40:14 +00:00
} else {
2022-07-25 14:02:39 +00:00
dialer.Timeout = C.TCPTimeout
}
2022-07-24 14:54:16 +00:00
if options.TCPFastOpen {
warnTFOOnUnsupportedPlatform.Check()
}
var udpFragment bool
if options.UDPFragment != nil {
udpFragment = *options.UDPFragment
} else {
udpFragment = options.UDPFragmentDefault
}
if !udpFragment {
2022-09-05 16:54:57 +00:00
dialer.Control = control.Append(dialer.Control, control.DisableUDPFragment())
listener.Control = control.Append(listener.Control, control.DisableUDPFragment())
}
2022-11-03 03:51:09 +00:00
var (
dialer4 = dialer
udpDialer4 = dialer
udpAddr4 string
)
if options.Inet4BindAddress != nil {
bindAddr := options.Inet4BindAddress.Build()
dialer4.LocalAddr = &net.TCPAddr{IP: bindAddr.AsSlice()}
udpDialer4.LocalAddr = &net.UDPAddr{IP: bindAddr.AsSlice()}
udpAddr4 = M.SocksaddrFrom(bindAddr, 0).String()
2022-08-25 06:49:49 +00:00
}
2022-11-03 03:51:09 +00:00
var (
dialer6 = dialer
udpDialer6 = dialer
udpAddr6 string
)
if options.Inet6BindAddress != nil {
bindAddr := options.Inet6BindAddress.Build()
dialer6.LocalAddr = &net.TCPAddr{IP: bindAddr.AsSlice()}
udpDialer6.LocalAddr = &net.UDPAddr{IP: bindAddr.AsSlice()}
udpAddr6 = M.SocksaddrFrom(bindAddr, 0).String()
}
return &DefaultDialer{
tfo.Dialer{Dialer: dialer4, DisableTFO: !options.TCPFastOpen},
tfo.Dialer{Dialer: dialer6, DisableTFO: !options.TCPFastOpen},
udpDialer4,
udpDialer6,
listener,
udpAddr4,
udpAddr6,
2022-08-22 06:28:23 +00:00
}
}
2022-07-07 13:47:21 +00:00
func (d *DefaultDialer) DialContext(ctx context.Context, network string, address M.Socksaddr) (net.Conn, error) {
2022-08-29 11:58:58 +00:00
if !address.IsValid() {
return nil, E.New("invalid address")
}
2022-08-22 06:35:05 +00:00
switch N.NetworkName(network) {
case N.NetworkUDP:
2022-11-03 03:51:09 +00:00
if !address.IsIPv6() {
return d.udpDialer4.DialContext(ctx, network, address.String())
} else {
return d.udpDialer6.DialContext(ctx, network, address.String())
}
}
if !address.IsIPv6() {
2023-03-03 11:26:54 +00:00
return trackConn(DialSlowContext(&d.dialer4, ctx, network, address))
2022-11-03 03:51:09 +00:00
} else {
2023-03-03 11:26:54 +00:00
return trackConn(DialSlowContext(&d.dialer6, ctx, network, address))
2022-08-22 06:35:05 +00:00
}
}
2022-07-07 13:47:21 +00:00
func (d *DefaultDialer) ListenPacket(ctx context.Context, destination M.Socksaddr) (net.PacketConn, error) {
if !destination.IsIPv6() {
2023-03-03 11:26:54 +00:00
return trackPacketConn(d.udpListener.ListenPacket(ctx, N.NetworkUDP, d.udpAddr4))
2022-11-03 03:51:09 +00:00
} else {
2023-03-03 11:26:54 +00:00
return trackPacketConn(d.udpListener.ListenPacket(ctx, N.NetworkUDP, d.udpAddr6))
2022-11-03 03:51:09 +00:00
}
2022-07-07 13:47:21 +00:00
}
2023-03-03 11:26:54 +00:00
func trackConn(conn net.Conn, err error) (net.Conn, error) {
if !conntrack.Enabled || err != nil {
return conn, err
}
2023-03-16 02:55:06 +00:00
return conntrack.NewConn(conn)
2023-03-03 11:26:54 +00:00
}
func trackPacketConn(conn net.PacketConn, err error) (net.PacketConn, error) {
if !conntrack.Enabled || err != nil {
return conn, err
}
2023-03-16 02:55:06 +00:00
return conntrack.NewPacketConn(conn)
2023-03-03 11:26:54 +00:00
}