extern/netbird
1
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2025-06-20 09:47:49 +02:00
Code Issues Packages Projects Releases Wiki Activity

increment network serial on peer meta changed

Browse Source
This commit is contained in:
Pascal Fischer 2025-06-19 12:46:50 +02:00
parent ec57c685a9
commit 4795e2fbc4
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
management/server/peer.go
View File

@ -754,9 +754,6 @@ func (am *DefaultAccountManager) SyncPeer(ctx context.Context, sync types.PeerSy
if updated { if updated {
am.metrics.AccountManagerMetrics().CountPeerMetUpdate() am.metrics.AccountManagerMetrics().CountPeerMetUpdate()
log.WithContext(ctx).Tracef("peer %s metadata updated", peer.ID) log.WithContext(ctx).Tracef("peer %s metadata updated", peer.ID)
if err = transaction.IncrementNetworkSerial(ctx, store.LockingStrengthUpdate, accountID); err != nil {
return err
}
if err = transaction.SavePeer(ctx, store.LockingStrengthUpdate, accountID, peer); err != nil { if err = transaction.SavePeer(ctx, store.LockingStrengthUpdate, accountID, peer); err != nil {
return err return err
} }
@ -766,6 +763,13 @@ func (am *DefaultAccountManager) SyncPeer(ctx context.Context, sync types.PeerSy
return err return err
} }
} }
if isStatusChanged || sync.UpdateAccountPeers || (updated && len(postureChecks) > 0) {
if err = transaction.IncrementNetworkSerial(ctx, store.LockingStrengthUpdate, accountID); err != nil {
return err
}
}
return nil return nil
}) })
if err != nil { if err != nil {
@ -894,14 +898,15 @@ func (am *DefaultAccountManager) LoginPeer(ctx context.Context, login types.Peer
} }
if shouldStorePeer { if shouldStorePeer {
if err = transaction.IncrementNetworkSerial(ctx, store.LockingStrengthUpdate, accountID); err != nil {
return err
}
if err = transaction.SavePeer(ctx, store.LockingStrengthUpdate, accountID, peer); err != nil { if err = transaction.SavePeer(ctx, store.LockingStrengthUpdate, accountID, peer); err != nil {
return err return err
} }
} }
if updateRemotePeers || isStatusChanged || (isPeerUpdated && len(postureChecks) > 0) {
err = transaction.IncrementNetworkSerial(ctx, store.LockingStrengthUpdate, accountID)
}
return nil return nil
}) })
if err != nil { if err != nil {