monitors

Author: ibalajiarun

consensus/src/epoch_manager.rs

@@ -1759,8 +1759,9 @@ impl<P: OnChainConfigProvider> EpochManager<P> {
                         p.timestamp_usecs(),
                     );
                     observe_block(p.timestamp_usecs(), "block_data_prefetch");
+                    let ts = p.timestamp_usecs();
+                    defer!(observe_block(ts, "block_forwarded_to"));
                 }
-
                 Self::forward_event_to(buffered_proposal_tx, peer_id, opt_proposal_event)
                     .context("proposal precheck sender")
             },

consensus/src/round_manager.rs

@@ -2039,7 +2039,7 @@ impl RoundManager {
         info!(epoch = self.epoch_state.epoch, "RoundManager started");
         let mut close_rx = close_rx.into_stream();
         loop {
-            tokio::select! {
+            monitor!("round_manager_loop", tokio::select! {
                 biased;
                 close_req = close_rx.select_next_some() => {
                     if let Ok(ack_sender) = close_req {
@@ -2163,7 +2163,7 @@ impl RoundManager {
                         }
                     }
                 },
-            }
+            })
         }
         info!(epoch = self.epoch_state.epoch, "RoundManager stopped");
     }