From ad0b78a7acc917ded6b58469204a3fafe261897e Mon Sep 17 00:00:00 2001 From: Maycon Santos Date: Tue, 8 Jul 2025 02:04:05 +0200 Subject: [PATCH] add request id to ephemeral cleanup --- management/server/ephemeral.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/management/server/ephemeral.go b/management/server/ephemeral.go index 7cdfb51ce..4bf7dba2b 100644 --- a/management/server/ephemeral.go +++ b/management/server/ephemeral.go @@ -5,10 +5,12 @@ import ( "sync" "time" + "github.com/google/uuid" log "github.com/sirupsen/logrus" nbAccount "github.com/netbirdio/netbird/management/server/account" "github.com/netbirdio/netbird/management/server/activity" + nbContext "github.com/netbirdio/netbird/management/server/context" nbpeer "github.com/netbirdio/netbird/management/server/peer" "github.com/netbirdio/netbird/management/server/store" ) @@ -138,6 +140,9 @@ func (e *EphemeralManager) loadEphemeralPeers(ctx context.Context) { func (e *EphemeralManager) cleanup(ctx context.Context) { log.Tracef("on ephemeral cleanup") + reqID := uuid.New().String() + //nolint + ctx = context.WithValue(ctx, nbContext.RequestIDKey, reqID) deletePeers := make(map[string]*ephemeralPeer) e.peersLock.Lock() @@ -176,6 +181,7 @@ func (e *EphemeralManager) cleanup(ctx context.Context) { } } for accountID := range bufferAccountCall { + log.WithContext(ctx).Debugf("ephemeral - buffer update account peers for account: %s", accountID) e.accountManager.BufferUpdateAccountPeers(ctx, accountID) } }