simon/ocaml-trace
1
0
Fork 0
mirror of https://github.com/ocaml-tracing/ocaml-trace.git synced 2026-03-08 03:47:57 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

tef: remove dead code

Browse source
This commit is contained in:
Simon Cruanes 2023-06-09 22:48:45 -04:00
parent 29fc25e598
commit 7958d7bc3b
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 6 additions and 41 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

47
src/tef/trace_tef.ml
View file

@ -34,22 +34,12 @@ let protect ~finally f =
type event = type event =
| E_message of { | E_message of {
(*
__FUNCTION__: string;
__FILE__: string;
__LINE__: int;
*)
tid: int; tid: int;
msg: string; msg: string;
time_us: float; time_us: float;
data: (string * user_data) list; data: (string * user_data) list;
} }
| E_define_span of { | E_define_span of {
(*
__FUNCTION__: string;
__FILE__: string;
__LINE__: int;
*)
tid: int; tid: int;
name: string; name: string;
time_us: float; time_us: float;
@ -73,11 +63,6 @@ module Span_tbl = Hashtbl.Make (struct
end) end)
type span_info = { type span_info = {
(*
__FUNCTION__: string;
__FILE__: string;
__LINE__: int;
*)
tid: int; tid: int;
name: string; name: string;
start_us: float; start_us: float;
@ -204,26 +189,15 @@ let bg_thread ~out (events : event B_queue.t) : unit =
(* how to deal with an event *) (* how to deal with an event *)
let handle_ev (ev : event) : unit = let handle_ev (ev : event) : unit =
match ev with match ev with
| E_message | E_message { tid; msg; time_us; data } ->
{ (* __FUNCTION__; __FILE__; __LINE__; *) tid; msg; time_us; data } ->
Writer.emit_instant_event ~tid ~name:msg ~ts:time_us ~args:data writer Writer.emit_instant_event ~tid ~name:msg ~ts:time_us ~args:data writer
| E_define_span | E_define_span { tid; name; id; time_us; data } ->
{ (* __FUNCTION__; __FILE__; __LINE__; *) tid; name; id; time_us; data }
->
(* save the span so we find it at exit *) (* save the span so we find it at exit *)
Span_tbl.add spans id Span_tbl.add spans id { tid; name; start_us = time_us; data }
{
(* __FUNCTION__; __FILE__; __LINE__; *) tid;
name;
start_us = time_us;
data;
}
| E_exit_span { id; time_us = stop_us } -> | E_exit_span { id; time_us = stop_us } ->
(match Span_tbl.find_opt spans id with (match Span_tbl.find_opt spans id with
| None -> (* bug! TODO: emit warning *) () | None -> (* bug! TODO: emit warning *) ()
| Some | Some { tid; name; start_us; data } ->
{ (* __FUNCTION__; __FILE__; __LINE__; *) tid; name; start_us; data }
->
Span_tbl.remove spans id; Span_tbl.remove spans id;
Writer.emit_duration_event ~tid ~name ~start:start_us ~end_:stop_us Writer.emit_duration_event ~tid ~name ~start:start_us ~end_:stop_us
~args:data writer) ~args:data writer)
@ -279,14 +253,7 @@ let collector ~out () : collector =
let tid = get_tid_ () in let tid = get_tid_ () in
let time_us = now_us () in let time_us = now_us () in
B_queue.push events B_queue.push events
(E_define_span (E_define_span { tid; name; time_us; id = span; data });
{
(* __FUNCTION__; __FILE__; __LINE__; *) tid;
name;
time_us;
id = span;
data;
});
span span
let exit_span span : unit = let exit_span span : unit =
@ -296,9 +263,7 @@ let collector ~out () : collector =
let message ?span:_ ~data msg : unit = let message ?span:_ ~data msg : unit =
let time_us = now_us () in let time_us = now_us () in
let tid = get_tid_ () in let tid = get_tid_ () in
B_queue.push events B_queue.push events (E_message { tid; time_us; msg; data })
(E_message
{ (* __FUNCTION__; __FILE__; __LINE__; *) tid; time_us; msg; data })
let name_process name : unit = B_queue.push events (E_name_process { name }) let name_process name : unit = B_queue.push events (E_name_process { name })