From be34faee10755226dd1c8e5496114fff6afb2171 Mon Sep 17 00:00:00 2001 From: Simon Cruanes Date: Sun, 7 Dec 2025 22:11:40 -0500 Subject: [PATCH] client eio: fixes --- src/client-cohttp-eio/opentelemetry_client_cohttp_eio.ml | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/client-cohttp-eio/opentelemetry_client_cohttp_eio.ml b/src/client-cohttp-eio/opentelemetry_client_cohttp_eio.ml index 14e904b6..33e05830 100644 --- a/src/client-cohttp-eio/opentelemetry_client_cohttp_eio.ml +++ b/src/client-cohttp-eio/opentelemetry_client_cohttp_eio.ml @@ -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 =