simon/ocaml-opentelemetry
1
0
Fork 0
mirror of https://github.com/ocaml-tracing/ocaml-opentelemetry.git synced 2026-03-07 18:37:56 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix ocurl: have ticker thread stop when work queue is closed

Browse source
This commit is contained in:
Simon Cruanes 2023-09-19 10:13:36 -04:00
parent a62f1d891a
commit d1c59a59bc
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/client-ocurl/opentelemetry_client_ocurl.ml
View file

@ -435,10 +435,12 @@ let mk_backend ~stop ~config () : (module Collector.BACKEND) =
let setup_ticker_thread ~stop ~sleep_ms (module B : Collector.BACKEND) () = let setup_ticker_thread ~stop ~sleep_ms (module B : Collector.BACKEND) () =
let sleep_s = float sleep_ms /. 1000. in let sleep_s = float sleep_ms /. 1000. in
let tick_loop () = let tick_loop () =
while not @@ Atomic.get stop do try
Thread.delay sleep_s; while not @@ Atomic.get stop do
B.tick () Thread.delay sleep_s;
done B.tick ()
done
with B_queue.Closed -> ()
in in
start_bg_thread tick_loop start_bg_thread tick_loop