From 676f201c837b79c3f1630084a832a2ea1b0c710b Mon Sep 17 00:00:00 2001 From: Pascal Fischer Date: Thu, 8 May 2025 20:08:42 +0200 Subject: [PATCH] add more logs --- management/server/peer.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/management/server/peer.go b/management/server/peer.go index 43a68e425..5990e75e8 100644 --- a/management/server/peer.go +++ b/management/server/peer.go @@ -1200,6 +1200,7 @@ func (am *DefaultAccountManager) checkIfUserOwnsPeer(ctx context.Context, accoun // UpdateAccountPeers updates all peers that belong to an account. // Should be called when changes have to be synced to peers. func (am *DefaultAccountManager) UpdateAccountPeers(ctx context.Context, accountID string) { + globalStart := time.Now() start := time.Now() account, err := am.requestBuffer.GetAccountWithBackpressure(ctx, accountID) if err != nil { @@ -1227,11 +1228,13 @@ func (am *DefaultAccountManager) UpdateAccountPeers(ctx context.Context, account resourcePolicies := account.GetResourcePoliciesMap() routers := account.GetResourceRoutersMap() + start = time.Now() proxyNetworkMaps, err := am.proxyController.GetProxyNetworkMapsAll(ctx, accountID, account.Peers) if err != nil { log.WithContext(ctx).Errorf("failed to get proxy network maps: %v", err) return } + log.WithContext(ctx).Infof("updateAccountPeers: getProxyNetworkMaps took %s", time.Since(start)) for _, peer := range account.Peers { if !am.peersUpdateManager.HasChannel(peer.ID) { @@ -1264,14 +1267,20 @@ func (am *DefaultAccountManager) UpdateAccountPeers(ctx context.Context, account return } + start = time.Now() update := toSyncResponse(ctx, nil, p, nil, nil, remotePeerNetworkMap, dnsDomain, postureChecks, dnsCache, account.Settings.RoutingPeerDNSResolutionEnabled, extraSetting) + log.WithContext(ctx).Infof("updateAccountPeers: toSyncResponse took %s", time.Since(start)) + start = time.Now() am.peersUpdateManager.SendUpdate(ctx, p.ID, &UpdateMessage{Update: update, NetworkMap: remotePeerNetworkMap}) + log.WithContext(ctx).Infof("updateAccountPeers: sending update toSyncResponse took %s", time.Since(start)) }(peer) } // wg.Wait() + log.WithContext(ctx).Infof("updateAccountPeers: waiting for updates to complete took %s", time.Since(globalStart)) + if am.metrics != nil { am.metrics.AccountManagerMetrics().CountUpdateAccountPeersDuration(time.Since(start)) }