12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061 |
- package dialer
- import (
- "context"
- "net"
- "net/netip"
- "syscall"
- "github.com/metacubex/mihomo/component/iface"
- "golang.org/x/sys/unix"
- )
- func bindControl(ifaceIdx int) controlFn {
- return func(ctx context.Context, network, address string, c syscall.RawConn) (err error) {
- addrPort, err := netip.ParseAddrPort(address)
- if err == nil && !addrPort.Addr().IsGlobalUnicast() {
- return
- }
- var innerErr error
- err = c.Control(func(fd uintptr) {
- switch network {
- case "tcp4", "udp4":
- innerErr = unix.SetsockoptInt(int(fd), unix.IPPROTO_IP, unix.IP_BOUND_IF, ifaceIdx)
- case "tcp6", "udp6":
- innerErr = unix.SetsockoptInt(int(fd), unix.IPPROTO_IPV6, unix.IPV6_BOUND_IF, ifaceIdx)
- }
- })
- if innerErr != nil {
- err = innerErr
- }
- return
- }
- }
- func bindIfaceToDialer(ifaceName string, dialer *net.Dialer, _ string, _ netip.Addr) error {
- ifaceObj, err := iface.ResolveInterface(ifaceName)
- if err != nil {
- return err
- }
- addControlToDialer(dialer, bindControl(ifaceObj.Index))
- return nil
- }
- func bindIfaceToListenConfig(ifaceName string, lc *net.ListenConfig, _, address string, rAddrPort netip.AddrPort) (string, error) {
- ifaceObj, err := iface.ResolveInterface(ifaceName)
- if err != nil {
- return "", err
- }
- addControlToListenConfig(lc, bindControl(ifaceObj.Index))
- return address, nil
- }
- func ParseNetwork(network string, addr netip.Addr) string {
- return network
- }
|