Fixes #1331 Signed-off-by: Brad Fitzpatrick <bradfitz@tailscale.com>main
parent
4f7d60ad42
commit
52e24aa966
@ -0,0 +1,81 @@ |
|||||||
|
// Copyright (c) 2020 Tailscale Inc & AUTHORS All rights reserved.
|
||||||
|
// Use of this source code is governed by a BSD-style
|
||||||
|
// license that can be found in the LICENSE file.
|
||||||
|
|
||||||
|
// +build darwin,!redo,!ios
|
||||||
|
// (Exclude redo, because we don't want this code in the App Store
|
||||||
|
// version's sandbox, where it won't work, and also don't want it on
|
||||||
|
// iOS. This is just for utun-using non-sandboxed cmd/tailscaled on macOS.
|
||||||
|
|
||||||
|
package interfaces |
||||||
|
|
||||||
|
import ( |
||||||
|
"errors" |
||||||
|
"fmt" |
||||||
|
"net" |
||||||
|
"syscall" |
||||||
|
|
||||||
|
"golang.org/x/net/route" |
||||||
|
) |
||||||
|
|
||||||
|
func DefaultRouteInterface() (string, error) { |
||||||
|
idx, err := DefaultRouteInterfaceIndex() |
||||||
|
if err != nil { |
||||||
|
return "", err |
||||||
|
} |
||||||
|
iface, err := net.InterfaceByIndex(idx) |
||||||
|
if err != nil { |
||||||
|
return "", err |
||||||
|
} |
||||||
|
return iface.Name, nil |
||||||
|
} |
||||||
|
|
||||||
|
func DefaultRouteInterfaceIndex() (int, error) { |
||||||
|
// $ netstat -nr
|
||||||
|
// Routing tables
|
||||||
|
// Internet:
|
||||||
|
// Destination Gateway Flags Netif Expire
|
||||||
|
// default 10.0.0.1 UGSc en0 <-- want this one
|
||||||
|
// default 10.0.0.1 UGScI en1
|
||||||
|
|
||||||
|
// From man netstat:
|
||||||
|
// U RTF_UP Route usable
|
||||||
|
// G RTF_GATEWAY Destination requires forwarding by intermediary
|
||||||
|
// S RTF_STATIC Manually added
|
||||||
|
// c RTF_PRCLONING Protocol-specified generate new routes on use
|
||||||
|
// I RTF_IFSCOPE Route is associated with an interface scope
|
||||||
|
|
||||||
|
rib, err := route.FetchRIB(syscall.AF_UNSPEC, syscall.NET_RT_DUMP2, 0) |
||||||
|
if err != nil { |
||||||
|
return 0, fmt.Errorf("FetchRIB: %w", err) |
||||||
|
} |
||||||
|
msgs, err := route.ParseRIB(syscall.NET_RT_IFLIST2, rib) |
||||||
|
if err != nil { |
||||||
|
return 0, fmt.Errorf("Parse: %w", err) |
||||||
|
} |
||||||
|
indexSeen := map[int]int{} // index => count
|
||||||
|
for _, m := range msgs { |
||||||
|
rm, ok := m.(*route.RouteMessage) |
||||||
|
if !ok { |
||||||
|
continue |
||||||
|
} |
||||||
|
const RTF_GATEWAY = 0x2 |
||||||
|
const RTF_IFSCOPE = 0x1000000 |
||||||
|
if rm.Flags&RTF_GATEWAY == 0 { |
||||||
|
continue |
||||||
|
} |
||||||
|
if rm.Flags&RTF_IFSCOPE != 0 { |
||||||
|
continue |
||||||
|
} |
||||||
|
indexSeen[rm.Index]++ |
||||||
|
} |
||||||
|
if len(indexSeen) == 0 { |
||||||
|
return 0, errors.New("no gateway index found") |
||||||
|
} |
||||||
|
if len(indexSeen) == 1 { |
||||||
|
for idx := range indexSeen { |
||||||
|
return idx, nil |
||||||
|
} |
||||||
|
} |
||||||
|
return 0, fmt.Errorf("ambiguous gateway interfaces found: %v", indexSeen) |
||||||
|
} |
||||||
@ -0,0 +1,52 @@ |
|||||||
|
// Copyright (c) 2021 Tailscale Inc & AUTHORS All rights reserved.
|
||||||
|
// Use of this source code is governed by a BSD-style
|
||||||
|
// license that can be found in the LICENSE file.
|
||||||
|
|
||||||
|
// +build darwin,!redo
|
||||||
|
|
||||||
|
package netns |
||||||
|
|
||||||
|
import ( |
||||||
|
"fmt" |
||||||
|
"log" |
||||||
|
"strings" |
||||||
|
"syscall" |
||||||
|
|
||||||
|
"golang.org/x/sys/unix" |
||||||
|
"tailscale.com/net/interfaces" |
||||||
|
) |
||||||
|
|
||||||
|
// control marks c as necessary to dial in a separate network namespace.
|
||||||
|
//
|
||||||
|
// It's intentionally the same signature as net.Dialer.Control
|
||||||
|
// and net.ListenConfig.Control.
|
||||||
|
func control(network, address string, c syscall.RawConn) error { |
||||||
|
if strings.HasPrefix(address, "127.") || address == "::1" { |
||||||
|
// Don't bind to an interface for localhost connections.
|
||||||
|
return nil |
||||||
|
} |
||||||
|
idx, err := interfaces.DefaultRouteInterfaceIndex() |
||||||
|
if err != nil { |
||||||
|
log.Printf("netns: DefaultRouteInterfaceIndex: %v", err) |
||||||
|
return nil |
||||||
|
} |
||||||
|
v6 := strings.Contains(address, "]:") || strings.HasSuffix(network, "6") // hacky test for v6
|
||||||
|
proto := unix.IPPROTO_IP |
||||||
|
opt := unix.IP_BOUND_IF |
||||||
|
if v6 { |
||||||
|
proto = unix.IPPROTO_IPV6 |
||||||
|
opt = unix.IPV6_BOUND_IF |
||||||
|
} |
||||||
|
|
||||||
|
var sockErr error |
||||||
|
err = c.Control(func(fd uintptr) { |
||||||
|
sockErr = unix.SetsockoptInt(int(fd), proto, opt, idx) |
||||||
|
}) |
||||||
|
if err != nil { |
||||||
|
return fmt.Errorf("RawConn.Control on %T: %w", c, err) |
||||||
|
} |
||||||
|
if sockErr != nil { |
||||||
|
log.Printf("netns: control(%q, %q), v6=%v, index=%v: %v", network, address, v6, idx, sockErr) |
||||||
|
} |
||||||
|
return sockErr |
||||||
|
} |
||||||
Loading…
Reference in new issue