simon/ocaml-opentelemetry
1
0
Fork 0
mirror of https://github.com/ocaml-tracing/ocaml-opentelemetry.git synced 2026-03-12 05:26:17 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: emit traces, too

Browse source
This commit is contained in:
Simon Cruanes 2022-04-12 13:50:50 -04:00
parent 3f3a39eee7
commit 2c1c67bfe8
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/client/opentelemetry_client_ocurl.ml
View file

@ -399,22 +399,24 @@ let mk_emitter ~(config:Config.t) () : (module EMITTER) =
if force || (not force && E_metrics.is_big_enough ()) then ( if force || (not force && E_metrics.is_big_enough ()) then (
let batch = ref [AList.pop_all gc_metrics] in let batch = ref [AList.pop_all gc_metrics] in
E_metrics.pop_iter_all (fun l -> batch := l :: !batch); E_metrics.pop_iter_all (fun l -> batch := l :: !batch);
if not (batch_is_empty !batch) then ( let do_something = not (l_is_empty !batch) in
if do_something then (
send_metrics_http !batch; send_metrics_http !batch;
); );
Atomic.set last_wakeup (Mtime_clock.now()); Atomic.set last_wakeup (Mtime_clock.now());
true do_something
) else false ) else false
in in
let emit_traces ?(force=false) () : bool = let emit_traces ?(force=false) () : bool =
if force || (not force && E_trace.is_big_enough ()) then ( if force || (not force && E_trace.is_big_enough ()) then (
let batch = ref [] in let batch = ref [] in
E_trace.pop_iter_all (fun l -> batch := l :: !batch); E_trace.pop_iter_all (fun l -> batch := l :: !batch);
if not (l_is_empty !batch) then ( let do_something = not (l_is_empty !batch) in
if do_something then (
send_traces_http !batch; send_traces_http !batch;
); );
Atomic.set last_wakeup (Mtime_clock.now()); Atomic.set last_wakeup (Mtime_clock.now());
true do_something
) else false ) else false
in in