simon/ocaml-opentelemetry
1
0
Fork 0
mirror of https://github.com/ocaml-tracing/ocaml-opentelemetry.git synced 2026-05-05 17:04:52 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix

Browse source
This commit is contained in:
Simon Cruanes 2026-04-10 14:45:54 -04:00
parent 9cb9c1081c
commit fd47118c51
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/client/sync/bounded_queue_sync.ml
View file

@ -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