simon/ocaml-opentelemetry
1
0
Fork 0
mirror of https://github.com/ocaml-tracing/ocaml-opentelemetry.git synced 2026-03-09 12:23:32 -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 50728fd944
commit be34faee10
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
(** NOTE: the mutex must be acquired *)
let wait self = Eio.Condition.await self.cond self.mutex
let wait self =
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 *)
let register_bounded_queue (self : t) (bq : _ Bounded_queue.t) : unit =