Move linkstate boring change filtering to magicsock

So we can at least re-STUN on boring updates.

Signed-off-by: Brad Fitzpatrick <bradfitz@tailscale.com>

wgengine/magicsock/magicsock.go

@@ -63,6 +63,9 @@ type Conn struct {
 	connCtx       context.Context // closed on Conn.Close
 	connCtxCancel func()          // closes connCtx
 
+	linkChangeMu sync.Mutex
+	linkState    *interfaces.State
+
 	// addrsByUDP is a map of every remote ip:port to a priority
 	// list of endpoint addresses for a peer.
 	// The priority list is provided by wgengine configuration.
@@ -201,6 +204,7 @@ func Listen(opts Options) (*Conn, error) {
 		derpTLSConfig: opts.derpTLSConfig,
 		derps:         derpmap.Prod(),
 	}
+	c.linkState, _ = getLinkState()
 	if len(opts.STUN) > 0 {
 		c.derps = derpmap.NewTestWorld(opts.STUN...)
 	}
@@ -1080,9 +1084,35 @@ func (c *Conn) reSTUN() {
 	}
 }
 
+// LinkChange should be called whenever something changed with the
+// network, no matter how minor. The LinkChange method then looks
+// at the state of the network and decides whether the change from
+// before is interesting enough to warrant taking action on.
 func (c *Conn) LinkChange() {
 	defer c.reSTUN()
 
+	c.linkChangeMu.Lock()
+	defer c.linkChangeMu.Unlock()
+
+	cur, err := getLinkState()
+	if err != nil {
+		return
+	}
+	if c.linkState != nil && !cur.Equal(c.linkState) {
+		c.linkState = cur
+		c.rebind()
+	}
+}
+
+func getLinkState() (*interfaces.State, error) {
+	s, err := interfaces.GetState()
+	if s != nil {
+		s.RemoveTailscaleInterfaces()
+	}
+	return s, err
+}
+
+func (c *Conn) rebind() {
 	if c.pconnPort != 0 {
 		c.pconn.mu.Lock()
 		if err := c.pconn.pconn.Close(); err != nil {
@@ -1098,7 +1128,6 @@ func (c *Conn) LinkChange() {
 		c.logf("magicsock: link change unable to bind fixed port %d: %v, falling back to random port", c.pconnPort, err)
 		c.pconn.mu.Unlock()
 	}
-
 	c.logf("magicsock: link change, binding new port")
 	packetConn, err := net.ListenPacket("udp4", ":0")
 	if err != nil {

wgengine/monitor/monitor.go

@@ -7,14 +7,9 @@
 package monitor
 
 import (
-	"fmt"
-	"net"
-	"runtime"
-	"strings"
 	"sync"
 	"time"
 
-	"tailscale.com/net/interfaces"
 	"tailscale.com/types/logger"
 )
 
@@ -104,7 +99,6 @@ func (m *Mon) Close() error {
 // the change channel of changes, and stopping when a stop is issued.
 func (m *Mon) pump() {
 	defer m.goroutines.Done()
-	last := interfaceSummary()
 	for {
 		_, err := m.om.Receive()
 		if err != nil {
@@ -118,14 +112,6 @@ func (m *Mon) pump() {
 			time.Sleep(time.Second)
 			continue
 		}
-
-		cur := interfaceSummary()
-		if cur == last {
-			continue
-		}
-		m.logf("wgengine/monitor: now %v (was %v)", cur, last)
-		last = cur
-
 		select {
 		case m.change <- struct{}{}:
 		case <-m.stop:
@@ -154,17 +140,3 @@ func (m *Mon) debounce() {
 		}
 	}
 }
-
-func interfaceSummary() string {
-	var sb strings.Builder
-	_ = interfaces.ForeachInterfaceAddress(func(ni interfaces.Interface, addr net.IP) {
-		if runtime.GOOS == "linux" && strings.HasPrefix(ni.Name, "tailscale") {
-			// Skip tailscale0, etc on Linux.
-			return
-		}
-		if ni.IsUp() {
-			fmt.Fprintf(&sb, "%s=%s ", ni.Name, addr)
-		}
-	})
-	return strings.TrimSpace(sb.String())
-}