detail

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
     )

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