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

update test

Browse source
This commit is contained in:
Simon Cruanes 2023-06-16 22:58:17 -04:00
parent 832113fe02
commit e03be377f1
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 1 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
tests/bin/emit1.ml
View file

@ -3,7 +3,7 @@ module Atomic = Opentelemetry_atomic.Atomic
let spf = Printf.sprintf let spf = Printf.sprintf
let ( let@ ) f x = f x let ( let@ ) = ( @@ )
let sleep_inner = ref 0.1 let sleep_inner = ref 0.1
@ -98,21 +98,13 @@ let () =
let ts_start = Unix.gettimeofday () in let ts_start = Unix.gettimeofday () in
let debug = ref false in let debug = ref false in
let thread = ref true in
let n_bg_threads = ref 0 in let n_bg_threads = ref 0 in
let batch_traces = ref 400 in
let batch_metrics = ref 3 in
let opts = let opts =
[ [
"--debug", Arg.Bool (( := ) debug), " enable debug output"; "--debug", Arg.Bool (( := ) debug), " enable debug output";
"--thread", Arg.Bool (( := ) thread), " use a background thread";
( "--stress-alloc", ( "--stress-alloc",
Arg.Bool (( := ) stress_alloc_), Arg.Bool (( := ) stress_alloc_),
" perform heavy allocs in inner loop" ); " perform heavy allocs in inner loop" );
"--batch-traces", Arg.Int (( := ) batch_traces), " size of traces batch";
( "--batch-metrics",
Arg.Int (( := ) batch_metrics),
" size of metrics batch" );
"--sleep-inner", Arg.Set_float sleep_inner, " sleep (in s) in inner loop"; "--sleep-inner", Arg.Set_float sleep_inner, " sleep (in s) in inner loop";
"--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";
@ -123,17 +115,8 @@ let () =
Arg.parse opts (fun _ -> ()) "emit1 [opt]*"; Arg.parse opts (fun _ -> ()) "emit1 [opt]*";
let some_if_nzero r =
if !r > 0 then
Some !r
else
None
in
let config = let config =
Opentelemetry_client_ocurl.Config.make ~debug:!debug Opentelemetry_client_ocurl.Config.make ~debug:!debug
~batch_traces:(some_if_nzero batch_traces)
~batch_metrics:(some_if_nzero batch_metrics)
~thread:!thread
?bg_threads: ?bg_threads:
(let n = !n_bg_threads in (let n = !n_bg_threads in
if n = 0 then if n = 0 then