sing-box/common/dialer/default.go

162 lines
5.2 KiB
Go
Raw Normal View History

package dialer
import (
"context"
"net"
"time"
"github.com/sagernet/sing-box/adapter"
2023-09-20 06:12:08 +00:00
"github.com/sagernet/sing-box/common/conntrack"
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"
)
2022-07-07 13:47:21 +00:00
type DefaultDialer struct {
2023-08-16 09:47:24 +00:00
dialer4 tcpDialer
dialer6 tcpDialer
2022-11-03 03:51:09 +00:00
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
}
2023-08-08 08:14:03 +00:00
func NewDefault(router adapter.Router, options option.DialerOptions) (*DefaultDialer, error) {
var dialer net.Dialer
var listener net.ListenConfig
if options.BindInterface != "" {
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 {
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 {
listener.Control = control.Append(listener.Control, control.ReuseAddr())
}
2022-07-06 06:45:56 +00:00
if options.ProtectPath != "" {
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
}
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()
}
2023-08-08 08:14:03 +00:00
if options.TCPMultiPath {
2023-08-16 09:47:24 +00:00
if !go121Available {
2023-08-08 08:14:03 +00:00
return nil, E.New("MultiPath TCP requires go1.21, please recompile your binary.")
}
setMultiPathTCP(&dialer4)
}
2023-08-16 09:47:24 +00:00
tcpDialer4, err := newTCPDialer(dialer4, options.TCPFastOpen)
if err != nil {
return nil, err
}
tcpDialer6, err := newTCPDialer(dialer6, options.TCPFastOpen)
if err != nil {
return nil, err
}
2022-11-03 03:51:09 +00:00
return &DefaultDialer{
2023-08-16 09:47:24 +00:00
tcpDialer4,
tcpDialer6,
2022-11-03 03:51:09 +00:00
udpDialer4,
udpDialer6,
listener,
udpAddr4,
udpAddr6,
2023-08-08 08:14:03 +00:00
}, nil
}
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 trackConn(d.udpDialer4.DialContext(ctx, network, address.String()))
2022-11-03 03:51:09 +00:00
} else {
return trackConn(d.udpDialer6.DialContext(ctx, network, address.String()))
2022-11-03 03:51:09 +00:00
}
}
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) {
2023-10-03 03:08:25 +00:00
if destination.IsIPv6() {
2023-03-03 11:26:54 +00:00
return trackPacketConn(d.udpListener.ListenPacket(ctx, N.NetworkUDP, d.udpAddr6))
2023-10-03 03:08:25 +00:00
} else if destination.IsIPv4() && !destination.Addr.IsUnspecified() {
return trackPacketConn(d.udpListener.ListenPacket(ctx, N.NetworkUDP+"4", d.udpAddr4))
} else {
return trackPacketConn(d.udpListener.ListenPacket(ctx, N.NetworkUDP, d.udpAddr4))
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
}