From fd47118c51cf41de92fb4c00abdfad37cf9c5b22 Mon Sep 17 00:00:00 2001 From: Simon Cruanes Date: Fri, 10 Apr 2026 14:45:54 -0400 Subject: [PATCH] fix --- src/client/sync/bounded_queue_sync.ml | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/client/sync/bounded_queue_sync.ml b/src/client/sync/bounded_queue_sync.ml index 99025aa4..34c348d8 100644 --- a/src/client/sync/bounded_queue_sync.ml +++ b/src/client/sync/bounded_queue_sync.ml @@ -99,11 +99,12 @@ let push (self : _ state) x = ignore (Atomic.fetch_and_add self.n_discarded (List.length x) : int) | Pushed { num_discarded } -> if num_discarded > 0 then ( - ignore (Atomic.fetch_and_add self.n_discarded num_discarded : int); + let total = Atomic.fetch_and_add self.n_discarded num_discarded in Opentelemetry.Self_debug.log Warning (fun () -> Printf.sprintf - "otel: dropped %d signals (exporter queue full at %d)" - num_discarded self.high_watermark) + "otel: dropped %d signals (queue full: %d/%d, total dropped: %d)" + num_discarded (Q.size self.q) self.high_watermark + (total + num_discarded)) ); (* wake up potentially asleep consumers *) Cb_set.trigger self.on_non_empty