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

fix notifier_sync

Browse source
This commit is contained in:
Simon Cruanes 2025-12-05 23:51:52 -05:00
parent da6ac17049
commit ee40e445d1
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/client/notifier_sync.ml
View file

@ -13,8 +13,10 @@ let delete = ignore
let[@inline] protect self f = Util_mutex.protect self.mutex f
(** NOTE: the mutex must be acquired *)
let wait self = Condition.wait self.cond self.mutex
let wait self =
Mutex.lock self.mutex;
Condition.wait self.cond self.mutex;
Mutex.unlock self.mutex
(** Ensure we get signalled when the queue goes from empty to non-empty *)
let register_bounded_queue (self : t) (bq : _ Bounded_queue.t) : unit =