From 875101de9b238ebecfc14c1f7b0d019a9a248c11 Mon Sep 17 00:00:00 2001 From: Simon Cruanes Date: Wed, 4 Mar 2026 13:11:04 -0500 Subject: [PATCH] debug in bounded queue sync --- src/client/sync/bounded_queue_sync.ml | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/client/sync/bounded_queue_sync.ml b/src/client/sync/bounded_queue_sync.ml index 79b524ee..dfad51e9 100644 --- a/src/client/sync/bounded_queue_sync.ml +++ b/src/client/sync/bounded_queue_sync.ml @@ -98,9 +98,12 @@ let push (self : _ state) x = | Closed -> ignore (Atomic.fetch_and_add self.n_discarded (List.length x) : int) | Pushed { num_discarded } -> - if num_discarded > 0 then + if num_discarded > 0 then ( ignore (Atomic.fetch_and_add self.n_discarded num_discarded : int); - + Opentelemetry.Self_debug.log Warning (fun () -> + Printf.sprintf "otel: dropped %d signals (exporter queue full)" + num_discarded) + ); (* wake up potentially asleep consumers *) Cb_set.trigger self.on_non_empty )