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

otel: internal helper

Browse source
This commit is contained in:
Simon Cruanes 2023-06-09 19:08:21 -04:00
parent dba8528aeb
commit 4e15bedfee
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/opentelemetry.ml
View file

@ -526,7 +526,6 @@ module Scope = struct
(**/**) (**/**)
(* define this locally *)
let _global_scope : t Thread_local.t = Thread_local.create () let _global_scope : t Thread_local.t = Thread_local.create ()
(**/**) (**/**)
@ -536,6 +535,11 @@ module Scope = struct
match scope with match scope with
| Some _ -> scope | Some _ -> scope
| None -> Thread_local.get _global_scope | None -> Thread_local.get _global_scope
(** [with_scope sc f] calls [f()] in a context where [sc] is the
(thread)-local scope, then reverts to the previous local scope, if any. *)
let[@inline] with_scope (sc : t) (f : unit -> 'a) : 'a =
Thread_local.with_ _global_scope sc (fun _ -> f ())
end end
open struct open struct
@ -753,7 +757,7 @@ module Trace = struct
let span_id = Span_id.create () in let span_id = Span_id.create () in
let scope = { trace_id; span_id; events = []; attrs } in let scope = { trace_id; span_id; events = []; attrs } in
(* set global scope in this thread *) (* set global scope in this thread *)
Thread_local.with_ Scope._global_scope scope @@ fun _sc -> Scope.with_scope scope @@ fun () ->
(* called once we're done, to emit a span *) (* called once we're done, to emit a span *)
let finally res = let finally res =
let status = let status =