From f519f2f49f83b52de2f4090c4378e0a376e0e7ec Mon Sep 17 00:00:00 2001 From: Simon Cruanes Date: Fri, 5 Dec 2025 16:08:16 -0500 Subject: [PATCH] detail --- src/client-ocurl-lwt/opentelemetry_client_ocurl_lwt.ml | 3 ++- src/client-ocurl/opentelemetry_client_ocurl.ml | 2 -- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/src/client-ocurl-lwt/opentelemetry_client_ocurl_lwt.ml b/src/client-ocurl-lwt/opentelemetry_client_ocurl_lwt.ml index b31160ed..720f2dd7 100644 --- a/src/client-ocurl-lwt/opentelemetry_client_ocurl_lwt.ml +++ b/src/client-ocurl-lwt/opentelemetry_client_ocurl_lwt.ml @@ -103,7 +103,8 @@ module Consumer_impl = struct } let shutdown self = - if not (Atomic.exchange self.stop true) then ( + Atomic.set self.stop true; + if not (Atomic.exchange self.cleaned true) then ( CNotifier.trigger self.notify; CNotifier.delete self.notify ) diff --git a/src/client-ocurl/opentelemetry_client_ocurl.ml b/src/client-ocurl/opentelemetry_client_ocurl.ml index bee44a6f..5db14538 100644 --- a/src/client-ocurl/opentelemetry_client_ocurl.ml +++ b/src/client-ocurl/opentelemetry_client_ocurl.ml @@ -23,7 +23,6 @@ module Consumer_impl = struct config: Config.t; mutable send_threads: Thread.t array; (** Threads that send data via http *) - cleaned: bool Atomic.t; (** True when we cleaned up after closing *) mcond: Util_thread.MCond.t; (** how to wait for the queue *) } @@ -133,7 +132,6 @@ module Consumer_impl = struct config; send_threads = [||]; bq = q; - cleaned = Atomic.make false; mcond = Util_thread.MCond.create (); } in