mirror of
https://github.com/ocaml-tracing/ocaml-trace.git
synced 2026-03-07 18:37:56 -05:00
address warnings
This commit is contained in:
parent
bf76b1f8eb
commit
f714482fe4
6 changed files with 1 additions and 8 deletions
|
|
@ -1,5 +1,4 @@
|
||||||
module A = Trace_core.Internal_.Atomic_
|
module A = Trace_core.Internal_.Atomic_
|
||||||
module Sub = Trace_subscriber
|
|
||||||
|
|
||||||
let on_tracing_error =
|
let on_tracing_error =
|
||||||
ref (fun s -> Printf.eprintf "trace-fuchsia error: %s\n%!" s)
|
ref (fun s -> Printf.eprintf "trace-fuchsia error: %s\n%!" s)
|
||||||
|
|
|
||||||
|
|
@ -1,4 +1,3 @@
|
||||||
open Trace_core
|
|
||||||
module Trace_id = Trace_util.Trace_id64
|
module Trace_id = Trace_util.Trace_id64
|
||||||
|
|
||||||
type trace_id = Trace_id.t
|
type trace_id = Trace_id.t
|
||||||
|
|
|
||||||
|
|
@ -36,7 +36,6 @@ type t = {
|
||||||
pid: int;
|
pid: int;
|
||||||
buf_pool: Buf_pool.t;
|
buf_pool: Buf_pool.t;
|
||||||
exporter: Exporter.t;
|
exporter: Exporter.t;
|
||||||
span_id_gen: Trace_util.Span_id64.Gen.t;
|
|
||||||
trace_id_gen: Trace_util.Trace_id64.Gen.t;
|
trace_id_gen: Trace_util.Trace_id64.Gen.t;
|
||||||
}
|
}
|
||||||
(** Subscriber state *)
|
(** Subscriber state *)
|
||||||
|
|
@ -78,7 +77,6 @@ let create ?(buf_pool = Buf_pool.create ()) ~pid ~exporter () : t =
|
||||||
exporter;
|
exporter;
|
||||||
buf_pool;
|
buf_pool;
|
||||||
pid;
|
pid;
|
||||||
span_id_gen = Trace_util.Span_id64.Gen.create ();
|
|
||||||
trace_id_gen = Trace_util.Trace_id64.Gen.create ();
|
trace_id_gen = Trace_util.Trace_id64.Gen.create ();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -90,7 +88,6 @@ open struct
|
||||||
| Core_ext.Extension_span_flavor f :: _ -> f
|
| Core_ext.Extension_span_flavor f :: _ -> f
|
||||||
| _ :: tl -> flavor_of_params tl
|
| _ :: tl -> flavor_of_params tl
|
||||||
|
|
||||||
let new_span_id (self : st) = Trace_util.Span_id64.Gen.gen self.span_id_gen
|
|
||||||
let new_trace_id (self : st) = Trace_util.Trace_id64.Gen.gen self.trace_id_gen
|
let new_trace_id (self : st) = Trace_util.Trace_id64.Gen.gen self.trace_id_gen
|
||||||
let init _ = ()
|
let init _ = ()
|
||||||
let shutdown (self : st) = close self
|
let shutdown (self : st) = close self
|
||||||
|
|
@ -116,6 +113,7 @@ open struct
|
||||||
| P_some (Span_tef_async sp) -> sp.trace_id
|
| P_some (Span_tef_async sp) -> sp.trace_id
|
||||||
| _ -> new_trace_id self
|
| _ -> new_trace_id self
|
||||||
in
|
in
|
||||||
|
let data = add_fun_name_ __FUNCTION__ data in
|
||||||
|
|
||||||
(let@ buf = Trace_util.Rpool.with_ self.buf_pool in
|
(let@ buf = Trace_util.Rpool.with_ self.buf_pool in
|
||||||
Writer.emit_begin_async buf ~name ~pid ~tid ~trace_id ~ts:start_us
|
Writer.emit_begin_async buf ~name ~pid ~tid ~trace_id ~ts:start_us
|
||||||
|
|
|
||||||
|
|
@ -1,5 +1,4 @@
|
||||||
open Trace_core
|
open Trace_core
|
||||||
open Common_
|
|
||||||
|
|
||||||
module Buf_pool : sig
|
module Buf_pool : sig
|
||||||
type t
|
type t
|
||||||
|
|
|
||||||
|
|
@ -1,4 +1,3 @@
|
||||||
open Trace_core
|
|
||||||
module Trace_id = Trace_util.Trace_id64
|
module Trace_id = Trace_util.Trace_id64
|
||||||
|
|
||||||
type trace_id = Trace_id.t
|
type trace_id = Trace_id.t
|
||||||
|
|
|
||||||
|
|
@ -3,7 +3,6 @@
|
||||||
This is the part of the code that knows how to emit TEF-compliant JSON from
|
This is the part of the code that knows how to emit TEF-compliant JSON from
|
||||||
raw event data. *)
|
raw event data. *)
|
||||||
|
|
||||||
open Common_
|
|
||||||
open Types
|
open Types
|
||||||
|
|
||||||
val emit_duration_event :
|
val emit_duration_event :
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue