diff --git a/management/server/grpcserver.go b/management/server/grpcserver.go index 6af911e9d..2c2d917ab 100644 --- a/management/server/grpcserver.go +++ b/management/server/grpcserver.go @@ -255,11 +255,14 @@ func (s *GRPCServer) handleUpdates(ctx context.Context, accountID string, peerKe close(networkMapCh) return } + start := time.Now() select { case networkMapCh <- update: + log.WithContext(ctx).Debugf("forwarded an update for peer %s from the network map buffer in %v", peerKey.String(), time.Since(start)) case <-ctx.Done(): return } + time.Sleep(1 * time.Second) } }()