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

client eio: fixes

Browse source
This commit is contained in:
Simon Cruanes 2025-12-07 22:11:40 -05:00
parent d49346c82c
commit 6e3f7e5dc2
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-cohttp-eio/opentelemetry_client_cohttp_eio.ml
View file

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