From 12c2f638455cd864baff58e010d43f72309cc292 Mon Sep 17 00:00:00 2001 From: pascal Date: Thu, 18 Jun 2026 13:59:29 +0200 Subject: [PATCH] update affected peers on sync --- management/server/peer.go | 2 +- management/server/peer/peer.go | 7 +++++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/management/server/peer.go b/management/server/peer.go index bc5e9a4fb..0d1bb9a97 100644 --- a/management/server/peer.go +++ b/management/server/peer.go @@ -1049,7 +1049,7 @@ func (am *DefaultAccountManager) SyncPeer(ctx context.Context, sync types.PeerSy if isStatusChanged || sync.UpdateAccountPeers || ipv6CapabilityChanged || updated || versionChanged { changedPeerIDs := []string{peer.ID} - affectedPeerIDs := am.syncPeerAffectedPeers(ctx, accountID, peer.ID, nmap, peerNotValid, updated, len(postureChecks) > 0) + affectedPeerIDs := am.resolveAffectedPeersForPeerChanges(ctx, am.Store, accountID, changedPeerIDs) if err = am.networkMapController.OnPeersUpdated(ctx, accountID, changedPeerIDs, affectedPeerIDs); err != nil { return nil, nil, nil, 0, fmt.Errorf("notify network map controller of peer update: %w", err) } diff --git a/management/server/peer/peer.go b/management/server/peer/peer.go index ad072ed8a..dd566f106 100644 --- a/management/server/peer/peer.go +++ b/management/server/peer/peer.go @@ -283,8 +283,11 @@ func (p *Peer) UpdateMetaIfNew(meta PeerSystemMeta) (updated, versionChanged boo versionInfo = fmt.Sprintf("version changed: %s -> %s, ", oldVersion, meta.WtVersion) } - log.WithFields(log.Fields{"peer": p.ID, "key": p.Key}). - Infof("peer meta updated, %s%d field(s) changed: %s", versionInfo, len(diff), strings.Join(diff, ", ")) + if versionChanged || updated { + log.WithFields(log.Fields{"peer": p.ID, "key": p.Key}). + Infof("peer meta updated, %s%d field(s) changed: %s", versionInfo, len(diff), strings.Join(diff, ", ")) + } + return updated, versionChanged }