ipn/ipnlocal: make peerapi work in netstack mode

Signed-off-by: Brad Fitzpatrick <bradfitz@tailscale.com>
pull/1618/head
Brad Fitzpatrick 3 years ago
parent 4c83bbf850
commit f01091babe

@ -1490,7 +1490,7 @@ func (b *LocalBackend) initPeerAPIListener() {
defer b.mu.Unlock() defer b.mu.Unlock()
for _, pln := range b.peerAPIListeners { for _, pln := range b.peerAPIListeners {
pln.ln.Close() pln.Close()
} }
b.peerAPIListeners = nil b.peerAPIListeners = nil
@ -1527,20 +1527,32 @@ func (b *LocalBackend) initPeerAPIListener() {
selfNode: selfNode, selfNode: selfNode,
} }
for _, a := range b.netMap.Addresses { isNetstack := wgengine.IsNetstack(b.e)
ln, err := ps.listen(a.IP, b.prevIfState) for i, a := range b.netMap.Addresses {
if err != nil { var ln net.Listener
b.logf("[unexpected] peerAPI listen(%q) error: %v", a.IP, err) var err error
continue skipListen := i > 0 && isNetstack
if !skipListen {
ln, err = ps.listen(a.IP, b.prevIfState)
if err != nil {
b.logf("[unexpected] peerapi listen(%q) error: %v", a.IP, err)
continue
}
} }
pln := &peerAPIListener{ pln := &peerAPIListener{
ps: ps, ps: ps,
ip: a.IP, ip: a.IP,
ln: ln, ln: ln, // nil for 2nd+ on netstack
lb: b, lb: b,
} }
pln.urlStr = "http://" + net.JoinHostPort(a.IP.String(), strconv.Itoa(pln.Port())) var port int
if skipListen {
port = b.peerAPIListeners[0].Port()
} else {
port = pln.Port()
}
pln.urlStr = "http://" + net.JoinHostPort(a.IP.String(), strconv.Itoa(port))
b.logf("peerapi: serving on %s", pln.urlStr)
go pln.serve() go pln.serve()
b.peerAPIListeners = append(b.peerAPIListeners, pln) b.peerAPIListeners = append(b.peerAPIListeners, pln)
} }

@ -24,6 +24,7 @@ import (
"inet.af/netaddr" "inet.af/netaddr"
"tailscale.com/net/interfaces" "tailscale.com/net/interfaces"
"tailscale.com/tailcfg" "tailscale.com/tailcfg"
"tailscale.com/wgengine"
) )
var initListenConfig func(*net.ListenConfig, netaddr.IP, *interfaces.State, string) error var initListenConfig func(*net.ListenConfig, netaddr.IP, *interfaces.State, string) error
@ -51,6 +52,10 @@ func (s *peerAPIServer) listen(ip netaddr.IP, ifState *interfaces.State) (ln net
} }
} }
if wgengine.IsNetstack(s.b.e) {
ipStr = ""
}
tcp4or6 := "tcp4" tcp4or6 := "tcp4"
if ip.Is6() { if ip.Is6() {
tcp4or6 = "tcp6" tcp4or6 = "tcp6"
@ -81,12 +86,22 @@ func (s *peerAPIServer) listen(ip netaddr.IP, ifState *interfaces.State) (ln net
type peerAPIListener struct { type peerAPIListener struct {
ps *peerAPIServer ps *peerAPIServer
ip netaddr.IP ip netaddr.IP
ln net.Listener ln net.Listener // or nil for 2nd+ address family in netstack mdoe
lb *LocalBackend lb *LocalBackend
urlStr string urlStr string
} }
func (pln *peerAPIListener) Close() error {
if pln.ln != nil {
return pln.ln.Close()
}
return nil
}
func (pln *peerAPIListener) Port() int { func (pln *peerAPIListener) Port() int {
if pln.ln == nil {
return 0
}
ta, ok := pln.ln.Addr().(*net.TCPAddr) ta, ok := pln.ln.Addr().(*net.TCPAddr)
if !ok { if !ok {
return 0 return 0
@ -95,6 +110,9 @@ func (pln *peerAPIListener) Port() int {
} }
func (pln *peerAPIListener) serve() { func (pln *peerAPIListener) serve() {
if pln.ln == nil {
return
}
defer pln.ln.Close() defer pln.ln.Close()
logf := pln.lb.logf logf := pln.lb.logf
for { for {

Loading…
Cancel
Save