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

test binary

Browse source
This commit is contained in:
Simon Cruanes 2025-12-09 21:21:53 -05:00
parent 0986c2aade
commit 6c832df3a6
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 30 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
tests/bin/emit1_stdout.ml
View file

@ -15,6 +15,8 @@ let n = ref max_int
let num_sleep = Atomic.make 0 let num_sleep = Atomic.make 0
let stress_alloc_ = ref true
let num_tr = Atomic.make 0 let num_tr = Atomic.make 0
let run_job () = let run_job () =
@ -42,8 +44,10 @@ let run_job () =
"loop.inner" "loop.inner"
in in
Unix.sleepf !sleep_outer; if !sleep_outer > 0. then (
Atomic.incr num_sleep; Unix.sleepf !sleep_outer;
Atomic.incr num_sleep
);
let logger = OT.Logger.get_main () in let logger = OT.Logger.get_main () in
OT.Emitter.emit logger OT.Emitter.emit logger
@ -57,13 +61,21 @@ let run_job () =
try try
Atomic.incr num_tr; Atomic.incr num_tr;
let@ _ = (* allocate some stuff *)
OT.Tracer.with_ tracer ~kind:OT.Span.Span_kind_internal ~parent:scope (if !stress_alloc_ then
"alloc" let@ _ =
in OT.Tracer.with_ tracer ~kind:OT.Span.Span_kind_internal
~parent:scope "alloc"
in
let _arr : _ array =
Sys.opaque_identity @@ Array.make (25 * 25551) 42.0
in
ignore _arr);
Unix.sleepf !sleep_inner; if !sleep_inner > 0. then (
Atomic.incr num_sleep; Unix.sleepf !sleep_inner;
Atomic.incr num_sleep
);
if j = 4 && !i mod 13 = 0 then failwith "oh no"; if j = 4 && !i mod 13 = 0 then failwith "oh no";
@ -71,7 +83,9 @@ let run_job () =
OT.Span.add_event scope (OT.Event.make "done with alloc") OT.Span.add_event scope (OT.Event.make "done with alloc")
with Failure _ -> () with Failure _ -> ()
done done
done done;
(* Printf.eprintf "emit1.run_job: exit\n%!"; *)
()
let run () = let run () =
OT.Gc_metrics.setup_on_main_exporter (); OT.Gc_metrics.setup_on_main_exporter ();
@ -108,11 +122,15 @@ let () =
let batch_metrics = ref 3 in let batch_metrics = ref 3 in
let batch_logs = ref 400 in let batch_logs = ref 400 in
let queued = ref false in let queued = ref false in
let self_trace = ref true in
let n_bg_threads = ref 0 in let n_bg_threads = ref 0 in
let opts = let opts =
[ [
"--debug", Arg.Bool (( := ) debug), " enable debug output"; "--debug", Arg.Bool (( := ) debug), " enable debug output";
( "--stress-alloc",
Arg.Bool (( := ) stress_alloc_),
" perform heavy allocs in inner loop" );
( "--batch-metrics", ( "--batch-metrics",
Arg.Int (( := ) batch_metrics), Arg.Int (( := ) batch_metrics),
" size of metrics batch" ); " size of metrics batch" );
@ -122,6 +140,7 @@ let () =
"--sleep-outer", Arg.Set_float sleep_outer, " sleep (in s) in outer loop"; "--sleep-outer", Arg.Set_float sleep_outer, " sleep (in s) in outer loop";
"-j", Arg.Set_int n_jobs, " number of parallel jobs"; "-j", Arg.Set_int n_jobs, " number of parallel jobs";
"--bg-threads", Arg.Set_int n_bg_threads, " number of background threads"; "--bg-threads", Arg.Set_int n_bg_threads, " number of background threads";
"--no-self-trace", Arg.Clear self_trace, " disable self tracing";
"-n", Arg.Set_int n, " number of iterations (default ∞)"; "-n", Arg.Set_int n, " number of iterations (default ∞)";
"--queued", Arg.Set queued, " queue exporter"; "--queued", Arg.Set queued, " queue exporter";
] ]
@ -146,6 +165,8 @@ let () =
OT.Main_exporter.set exporter; OT.Main_exporter.set exporter;
if !self_trace then Opentelemetry_client.Self_trace.set_enabled true;
let@ () = let@ () =
Fun.protect ~finally:(fun () -> Fun.protect ~finally:(fun () ->
let elapsed = Unix.gettimeofday () -. ts_start in let elapsed = Unix.gettimeofday () -. ts_start in