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

perf: when we get multiple messages, check batches only once

Browse source
This commit is contained in:
Simon Cruanes 2023-12-20 14:01:24 -05:00
parent 47f7f1d110
commit 5005c3aa9b
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 21 additions and 24 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

45
src/client-ocurl/opentelemetry_client_ocurl.ml
View file

@ -266,39 +266,36 @@ end = struct
(* read multiple events at once *) (* read multiple events at once *)
B_queue.pop_all self.q local_q; B_queue.pop_all self.q local_q;
let now = Mtime_clock.now () in (* are we asked to flush all events? *)
let must_flush_all = ref false in
(* how to process a single event *) (* how to process a single event *)
let process_ev (ev : Event.t) : unit = let process_ev (ev : Event.t) : unit =
match ev with match ev with
| Event.E_metric m -> | Event.E_metric m -> Batch.push batches.metrics m
Batch.push batches.metrics m; | Event.E_trace tr -> Batch.push batches.traces tr
if should_send_batch_ ~config ~now batches.metrics then | Event.E_logs logs -> Batch.push batches.logs logs
send_metrics () | Event.E_tick -> ()
| Event.E_trace tr -> | Event.E_flush_all -> must_flush_all := true
Batch.push batches.traces tr;
if should_send_batch_ ~config ~now batches.traces then
send_traces ()
| Event.E_logs logs ->
Batch.push batches.logs logs;
if should_send_batch_ ~config ~now batches.logs then send_logs ()
| Event.E_tick ->
(* check for batches whose timeout expired *)
if should_send_batch_ ~config ~now batches.metrics then
send_metrics ();
if should_send_batch_ ~config ~now batches.logs then send_logs ();
if should_send_batch_ ~config ~now batches.traces then
send_traces ()
| Event.E_flush_all ->
if Batch.len batches.metrics > 0 then send_metrics ();
if Batch.len batches.logs > 0 then send_logs ();
if Batch.len batches.traces > 0 then send_traces ()
in in
while not (Queue.is_empty local_q) do while not (Queue.is_empty local_q) do
let ev = Queue.pop local_q in let ev = Queue.pop local_q in
process_ev ev process_ev ev
done done;
if !must_flush_all then (
if Batch.len batches.metrics > 0 then send_metrics ();
if Batch.len batches.logs > 0 then send_logs ();
if Batch.len batches.traces > 0 then send_traces ()
) else (
let now = Mtime_clock.now () in
if should_send_batch_ ~config ~now batches.metrics then
send_metrics ();
if should_send_batch_ ~config ~now batches.traces then send_traces ();
if should_send_batch_ ~config ~now batches.logs then send_logs ()
)
done done
with B_queue.Closed -> () with B_queue.Closed -> ()