diff --git a/management/server/peer.go b/management/server/peer.go index 8f3eb2331..b82a9cb80 100644 --- a/management/server/peer.go +++ b/management/server/peer.go @@ -23,6 +23,7 @@ import ( routerTypes "github.com/netbirdio/netbird/management/server/networks/routers/types" "github.com/netbirdio/netbird/management/server/permissions/modules" "github.com/netbirdio/netbird/management/server/permissions/operations" + "github.com/netbirdio/netbird/util" "github.com/netbirdio/netbird/management/server/posture" "github.com/netbirdio/netbird/management/server/store" @@ -1183,6 +1184,8 @@ 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) { + log.WithContext(ctx).Tracef("updating peers for account %s from %s", accountID, util.GetCallerName()) + account, err := am.requestBuffer.GetAccountWithBackpressure(ctx, accountID) if err != nil { log.WithContext(ctx).Errorf("failed to send out updates to peers. failed to get account: %v", err) diff --git a/util/runtime.go b/util/runtime.go new file mode 100644 index 000000000..3b420e15b --- /dev/null +++ b/util/runtime.go @@ -0,0 +1,15 @@ +package util + +import "runtime" + +func GetCallerName() string { + pc, _, _, ok := runtime.Caller(2) + if !ok { + return "unknown" + } + fn := runtime.FuncForPC(pc) + if fn == nil { + return "unknown" + } + return fn.Name() +}