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

tef: emit last message when worker exits

Browse source
This commit is contained in:
Simon Cruanes 2023-12-07 16:15:21 -05:00
parent 721212be27
commit 079949d139
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 5 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/tef/trace_tef.ml
View file

@ -328,6 +328,11 @@ let bg_thread ~out (events : event B_queue.t) : unit =
List.iter handle_ev local List.iter handle_ev local
done done
with B_queue.Closed -> with B_queue.Closed ->
(* write a message about us closing *)
Writer.emit_instant_event ~name:"tef-worker.exit"
~tid:(Thread.id @@ Thread.self ())
~ts:(now_us ()) ~args:[] writer;
(* warn if app didn't close all spans *) (* warn if app didn't close all spans *)
if Span_tbl.length spans > 0 then if Span_tbl.length spans > 0 then
Printf.eprintf "trace-tef: warning: %d spans were not closed\n%!" Printf.eprintf "trace-tef: warning: %d spans were not closed\n%!"