wgengine/magicsock: move trustBestAddrUntil forward on non-disco rx (#10274)

This is gated behind the silent disco control knob, which is still in
its infancy. Prior to this change disco pong reception was the only
event that could move trustBestAddrUntil forward, so even though we
weren't heartbeating, we would kick off discovery pings every
trustUDPAddrDuration and mirror to DERP.

Updates #540

Signed-off-by: Jordan Whited <jordan@tailscale.com>
pull/10276/head
Jordan Whited 1 year ago committed by GitHub
parent 57129205e6
commit 2ff54f9d12
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -239,14 +239,22 @@ func (de *endpoint) initFakeUDPAddr() {
func (de *endpoint) noteRecvActivity(ipp netip.AddrPort) { func (de *endpoint) noteRecvActivity(ipp netip.AddrPort) {
now := mono.Now() now := mono.Now()
// TODO(raggi): this probably applies relatively equally well to disco
// managed endpoints, but that would be a less conservative change.
if de.isWireguardOnly { if de.isWireguardOnly {
de.mu.Lock() de.mu.Lock()
de.bestAddr.AddrPort = ipp de.bestAddr.AddrPort = ipp
de.bestAddrAt = now de.bestAddrAt = now
de.trustBestAddrUntil = now.Add(5 * time.Second) de.trustBestAddrUntil = now.Add(5 * time.Second)
de.mu.Unlock() de.mu.Unlock()
} else {
// TODO(jwhited): subject to change as part of silent disco effort.
// Necessary when heartbeat is disabled for the endpoint, otherwise we
// kick off discovery disco pings every trustUDPAddrDuration and mirror
// to DERP.
de.mu.Lock()
if de.heartbeatDisabled && de.bestAddr.AddrPort == ipp {
de.trustBestAddrUntil = now.Add(trustUDPAddrDuration)
}
de.mu.Unlock()
} }
elapsed := now.Sub(de.lastRecv.LoadAtomic()) elapsed := now.Sub(de.lastRecv.LoadAtomic())

Loading…
Cancel
Save