mirror of
https://github.com/ocaml-tracing/ocaml-opentelemetry.git
synced 2026-03-08 03:47:59 -04:00
fix: same
This commit is contained in:
parent
2c1c67bfe8
commit
3448e33d29
1 changed files with 4 additions and 3 deletions
|
|
@ -450,9 +450,10 @@ let mk_emitter ~(config:Config.t) () : (module EMITTER) =
|
|||
while !continue do
|
||||
let@ () = guard in
|
||||
let timeout = batch_timeout() in
|
||||
if emit_metrics ~force:timeout () then ()
|
||||
else if emit_traces ~force:timeout () then ()
|
||||
else (
|
||||
|
||||
let do_metrics = emit_metrics ~force:timeout () in
|
||||
let do_traces = emit_traces ~force:timeout () in
|
||||
if not do_metrics && not do_traces then (
|
||||
(* wait *)
|
||||
let@ () = with_mutex_ m in
|
||||
Condition.wait cond m;
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue