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

feat(curl-client): block some signals in background thread(s)

Browse source
This commit is contained in:
Simon Cruanes 2022-03-30 11:53:19 -04:00
parent 8f2a666a70
commit 6722c49bb0
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/client/opentelemetry_client_ocurl.ml
View file

@ -285,6 +285,14 @@ let mk_push (type a) ?batch () : (module PUSH with type elt = a) * (on_full_cb -
in
push, ((:=) on_full)
(* start a thread in the background, running [f()] *)
let start_bg_thread (f: unit -> unit) : unit =
let run() =
(* block some signals: USR1 USR2 TERM PIPE ALARM STOP, see [$ kill -L] *)
ignore (Thread.sigmask Unix.SIG_BLOCK [10; 12; 13; 14; 15; 19] : _ list);
f()
in
ignore (Thread.create run () : Thread.t)
(* make an emitter.
@ -417,7 +425,7 @@ let mk_emitter ~(config:Config.t) () : (module EMITTER) =
C.cleanup();
end
in
let _th_process_batches: Thread.t = Thread.create bg_thread () in
start_bg_thread bg_thread;
let wakeup () =
with_mutex_ m (fun () -> Condition.signal cond);
@ -441,8 +449,7 @@ let mk_emitter ~(config:Config.t) () : (module EMITTER) =
done
in
let _th_ticker : Thread.t = Thread.create tick_thread () in
()
start_bg_thread tick_thread;
);
let module M = struct