Más instrumentación

src/lib/mina_lib/mina_lib.ml

@@ -1956,9 +1956,10 @@ let create ?wallets (config : Config.t) =
                   ; ( "Port"
                     , `Int (Host_and_port.port archive_process_port.value) )
                   ] ;
-              Archive_client.run ~logger:config.logger
-                ~frontier_broadcast_pipe:frontier_broadcast_pipe_r
-                archive_process_port) ;
+              O1trace.time_execution "in_archive_client" (fun () ->
+                  Archive_client.run ~logger:config.logger
+                    ~frontier_broadcast_pipe:frontier_broadcast_pipe_r
+                    archive_process_port)) ;
           let precomputed_block_writer =
             ref
               ( Option.map config.precomputed_blocks_path ~f:(fun path ->

src/lib/mina_metrics/prometheus_metrics/mina_metrics.ml

@@ -136,14 +136,11 @@ module Runtime = struct
   let gc_allocated_bytes = ref (Gc.allocated_bytes ())
 
   let rec gc_stat () =
-    Async.Deferred.(
-      upon
-        (after (Time_ns.Span.of_min !gc_stat_interval_mins))
-        (fun () ->
-          current_gc := Gc.stat () ;
-          current_jemalloc := Jemalloc.get_memory_stats () ;
-          gc_allocated_bytes := Gc.allocated_bytes () ;
-          gc_stat ()))
+    let%bind () = after (Time_ns.Span.of_min !gc_stat_interval_mins) in
+    current_gc := Gc.stat () ;
+    current_jemalloc := Jemalloc.get_memory_stats () ;
+    gc_allocated_bytes := Gc.allocated_bytes () ;
+    gc_stat ()
 
   let simple_metric ~metric_type ~help name fn =
     let name = Printf.sprintf "%s_%s_%s" namespace subsystem name in
@@ -1527,9 +1524,11 @@ let generic_server ?forward_uri ~port ~logger ~registry () =
 type t = (Async.Socket.Address.Inet.t, int) Cohttp_async.Server.t
 
 let server ?forward_uri ~port ~logger () =
-  Runtime.gc_stat () ;
-  generic_server ?forward_uri ~port ~logger ~registry:CollectorRegistry.default
-    ()
+  don't_wait_for
+    (O1trace.time_execution "collecting_gc_metrics" Runtime.gc_stat) ;
+  O1trace.time_execution "serving_metrics"
+    (generic_server ?forward_uri ~port ~logger
+       ~registry:CollectorRegistry.default)
 
 module Archive = struct
   type t =

src/lib/transition_router/transition_router.ml

@@ -522,9 +522,11 @@ let run ~logger ~trust_system ~verifier ~network ~is_seed ~is_demo_mode
               ~pipe_name:name ~logger)
           ()
       in
-      Initial_validator.run ~logger ~trust_system ~verifier
-        ~transition_reader:network_transition_reader ~valid_transition_writer
-        ~initialization_finish_signal ~precomputed_values ;
+      O1trace.time_execution "in_initial_validator" (fun () ->
+          Initial_validator.run ~logger ~trust_system ~verifier
+            ~transition_reader:network_transition_reader
+            ~valid_transition_writer ~initialization_finish_signal
+            ~precomputed_values) ;
       let persistent_frontier =
         Transition_frontier.Persistent_frontier.create ~logger ~verifier
           ~time_controller ~directory:persistent_frontier_location