From c115434d53e777dded374769e7f4354f05e11753 Mon Sep 17 00:00:00 2001
From: Pascal Fischer <pascal@netbird.io>
Date: Wed, 8 Oct 2025 22:52:31 +0200
Subject: [PATCH] log pop

---
 management/server/grpcserver.go    | 14 ++++++++------
 management/server/updatechannel.go | 10 +++++-----
 2 files changed, 13 insertions(+), 11 deletions(-)

diff --git a/management/server/grpcserver.go b/management/server/grpcserver.go
index 26cba1ba5..8c0b275e6 100644
--- a/management/server/grpcserver.go
+++ b/management/server/grpcserver.go
@@ -266,27 +266,29 @@ func (s *GRPCServer) handleUpdates(ctx context.Context, accountID string, peerKe
 	// Start goroutine to Pop from buffer
 	go func() {
 		for {
+			start := time.Now()
 			update, overwrites, timeSinceLastPop, ok := updates.NetworkMap.Pop(ctx)
+			log.WithContext(ctx).Debugf("popped an update for peer %s from the network map buffer in %v (overwrites: %d)", peerKey.String(), time.Since(start), overwrites)
 			if !ok {
 				close(networkMapCh)
 				return
 			}
-			start := time.Now()
+			// start := time.Now()
 			select {
 			case networkMapCh <- networkMapUpdate{
 				msg:              update,
 				overwrites:       overwrites,
 				timeSinceLastPop: timeSinceLastPop,
 			}:
-				log.WithContext(ctx).Debugf("forwarded an update for peer %s from the network map buffer in %v (overwrites: %d)", peerKey.String(), time.Since(start), overwrites)
+				// log.WithContext(ctx).Debugf("forwarded an update for peer %s from the network map buffer in %v (overwrites: %d)", peerKey.String(), time.Since(start), overwrites)
 
 				// Adaptive debounce: increase delay based on overwrite rate
 				// If many overwrites happened, wait longer to let things settle
 				debounce := s.calculateDebounce(overwrites, timeSinceLastPop)
 				if debounce > 0 {
-					start = time.Now()
+					// start = time.Now()
 					time.Sleep(debounce)
-					log.WithContext(ctx).Debugf("debounced for %v for peer %s (overwrites: %d)", time.Since(start), peerKey.String(), overwrites)
+					// log.WithContext(ctx).Debugf("debounced for %v for peer %s (overwrites: %d)", time.Since(start), peerKey.String(), overwrites)
 				}
 			case <-ctx.Done():
 				return
@@ -307,7 +309,7 @@ func (s *GRPCServer) handleUpdates(ctx context.Context, accountID string, peerKe
 				s.cancelPeerRoutines(ctx, accountID, peer)
 				return nil
 			}
-			log.WithContext(ctx).Debugf("received an update for peer %s", peerKey.String())
+			// log.WithContext(ctx).Debugf("received an update for peer %s", peerKey.String())
 
 			if err := s.sendUpdate(ctx, accountID, peerKey, peer, update, srv); err != nil {
 				log.WithContext(ctx).Debugf("error while sending an update to peer %s: %v", peerKey.String(), err)
@@ -320,7 +322,7 @@ func (s *GRPCServer) handleUpdates(ctx context.Context, accountID string, peerKe
 				s.cancelPeerRoutines(ctx, accountID, peer)
 				return nil
 			}
-			log.WithContext(ctx).Debugf("sending latest update to peer %s (overwrites: %d)", peerKey.String(), updateData.overwrites)
+			// log.WithContext(ctx).Debugf("sending latest update to peer %s (overwrites: %d)", peerKey.String(), updateData.overwrites)
 			if err := s.sendUpdate(ctx, accountID, peerKey, peer, updateData.msg, srv); err != nil {
 				return err
 			}
diff --git a/management/server/updatechannel.go b/management/server/updatechannel.go
index 3839fbbaf..a90217c73 100644
--- a/management/server/updatechannel.go
+++ b/management/server/updatechannel.go
@@ -73,13 +73,13 @@ func (p *PeersUpdateManager) SendImportantUpdate(ctx context.Context, peerID str
 		found = true
 		select {
 		case channel.Important <- update:
-			log.WithContext(ctx).Debugf("update was sent to important channel for peer %s", peerID)
+			// log.WithContext(ctx).Debugf("update was sent to important channel for peer %s", peerID)
 		default:
 			dropped = true
-			log.WithContext(ctx).Warnf("important channel for peer %s is %d full or closed", peerID, len(channel.Important))
+			// log.WithContext(ctx).Warnf("important channel for peer %s is %d full or closed", peerID, len(channel.Important))
 		}
 	} else {
-		log.WithContext(ctx).Debugf("peer %s has no important channel", peerID)
+		// log.WithContext(ctx).Debugf("peer %s has no important channel", peerID)
 	}
 }
 
@@ -100,9 +100,9 @@ func (p *PeersUpdateManager) SendNetworkMapUpdate(ctx context.Context, peerID st
 	if channel, ok := p.peerChannels[peerID]; ok {
 		found = true
 		channel.NetworkMap.Push(update)
-		log.WithContext(ctx).Debugf("update was sent to network map buffer for peer %s", peerID)
+		// log.WithContext(ctx).Debugf("update was sent to network map buffer for peer %s", peerID)
 	} else {
-		log.WithContext(ctx).Debugf("peer %s has no network map buffer", peerID)
+		// log.WithContext(ctx).Debugf("peer %s has no network map buffer", peerID)
 	}
 }