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

bench: add counter

Browse source
This commit is contained in:
Simon Cruanes 2023-12-14 20:48:46 -05:00
parent e53cffbf12
commit e052893759
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
tests/bin/emit1.ml
View file

@ -11,6 +11,8 @@ let sleep_outer = ref 2.0
let n_jobs = ref 1
let n = ref max_int
let num_sleep = Atomic.make 0
let stress_alloc_ = ref true
@ -22,13 +24,18 @@ let num_tr = Atomic.make 0
let run_job () =
let@ () = Fun.protect ~finally:(fun () -> Atomic.set stop true) in
let i = ref 0 in
while not @@ Atomic.get stop do
let cnt = ref 0 in
while (not @@ Atomic.get stop) && !cnt < !n do
let@ _scope =
Atomic.incr num_tr;
T.Trace.with_ ~kind:T.Span.Span_kind_producer "loop.outer"
~attrs:[ "i", `Int !i ]
in
(* Printf.printf "cnt=%d\n%!" !cnt; *)
incr cnt;
for j = 0 to 4 do
(* parent scope is found via thread local storage *)
let@ scope =
@ -109,6 +116,7 @@ let () =
"--sleep-outer", Arg.Set_float sleep_outer, " sleep (in s) in outer loop";
"-j", Arg.Set_int n_jobs, " number of parallel jobs";
"--bg-threads", Arg.Set_int n_bg_threads, " number of background threads";
"-n", Arg.Set_int n, " number of iterations (default ∞)";
]
|> Arg.align
in