Add more instrumentation

Author: ndr-ds

Cargo.lock

@@ -35,6 +35,7 @@ use linera_views::{
     views::{ClonableView, CryptoHashView, RootView, View},
 };
 use serde::{Deserialize, Serialize};
+use tracing::instrument;
 
 use crate::{
     block::{Block, ConfirmedBlock},
@@ -309,6 +310,7 @@ pub struct ChainTipState {
 impl ChainTipState {
     /// Checks that the proposed block is suitable, i.e. at the expected height and with the
     /// expected parent.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub fn verify_block_chaining(&self, new_block: &ProposedBlock) -> Result<(), ChainError> {
         ensure!(
             new_block.height == self.next_block_height,
@@ -326,6 +328,7 @@ impl ChainTipState {
 
     /// Returns `true` if the validated block's height is below the tip height. Returns an error if
     /// it is higher than the tip.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub fn already_validated_block(&self, height: BlockHeight) -> Result<bool, ChainError> {
         ensure!(
             self.next_block_height >= height,
@@ -337,6 +340,7 @@ impl ChainTipState {
     }
 
     /// Checks if the measurement counters would be valid.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub fn update_counters(
         &mut self,
         transactions: &[Transaction],
@@ -391,6 +395,7 @@ where
         self.context().extra().chain_id()
     }
 
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn query_application(
         &mut self,
         local_time: Timestamp,
@@ -408,6 +413,7 @@ where
             .with_execution_context(ChainExecutionContext::Query)
     }
 
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn describe_application(
         &mut self,
         application_id: ApplicationId,
@@ -419,6 +425,7 @@ where
             .with_execution_context(ChainExecutionContext::DescribeApplication)
     }
 
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn mark_messages_as_received(
         &mut self,
         target: &ChainId,
@@ -459,6 +466,7 @@ where
 
     /// Returns true if there are no more outgoing messages in flight up to the given
     /// block height.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub fn all_messages_delivered_up_to(&self, height: BlockHeight) -> bool {
         tracing::debug!(
             "Messages left in {:.8}'s outbox: {:?}",
@@ -478,6 +486,7 @@ where
     }
 
     /// Invariant for the states of active chains.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn ensure_is_active(&mut self, local_time: Timestamp) -> Result<(), ChainError> {
         // Initialize ourselves.
         if self
@@ -506,6 +515,7 @@ where
 
     /// Verifies that this chain is up-to-date and all the messages executed ahead of time
     /// have been properly received by now.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn validate_incoming_bundles(&self) -> Result<(), ChainError> {
         let chain_id = self.chain_id();
         let pairs = self.inboxes.try_load_all_entries().await?;
@@ -526,6 +536,7 @@ where
         Ok(())
     }
 
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn next_block_height_to_receive(
         &self,
         origin: &ChainId,
@@ -540,13 +551,15 @@ where
     /// Returns the height of the highest block we have, plus one. Includes preprocessed blocks.
     ///
     /// The "+ 1" is so that it can be used in the same places as `next_block_height`.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn next_height_to_preprocess(&self) -> Result<BlockHeight, ChainError> {
         if let Some(height) = self.preprocessed_blocks.indices().await?.last() {
             return Ok(height.saturating_add(BlockHeight(1)));
         }
         Ok(self.tip_state.get().next_block_height)
     }
 
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn last_anticipated_block_height(
         &self,
         origin: &ChainId,
@@ -567,6 +580,7 @@ where
     /// round timeouts.
     ///
     /// Returns `true` if incoming `Subscribe` messages created new outbox entries.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn receive_message_bundle(
         &mut self,
         origin: &ChainId,
@@ -630,6 +644,7 @@ where
     }
 
     /// Updates the `received_log` trackers.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub fn update_received_certificate_trackers(
         &mut self,
         new_trackers: BTreeMap<ValidatorPublicKey, u64>,
@@ -649,6 +664,7 @@ where
         }
     }
 
+    #[instrument(target = "telemetry_only", skip_all)]
     pub fn current_committee(&self) -> Result<(Epoch, &Committee), ChainError> {
         self.execution_state
             .system
@@ -661,6 +677,7 @@ where
     }
 
     /// Removes the incoming message bundles in the block from the inboxes.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn remove_bundles_from_inboxes(
         &mut self,
         timestamp: Timestamp,
@@ -739,6 +756,7 @@ where
     }
 
     /// Returns the outboxes for the given targets, or an error if any of them are missing.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn load_outboxes(
         &self,
         targets: &[ChainId],
@@ -750,6 +768,7 @@ where
 
     /// Executes a block: first the incoming messages, then the main operation.
     /// Does not update chain state other than the execution state.
+    #[instrument(target = "telemetry_only", skip_all)]
     #[expect(clippy::too_many_arguments)]
     async fn execute_block_inner(
         chain: &mut ExecutionStateView<C>,
@@ -859,6 +878,7 @@ where
 
     /// Executes a block: first the incoming messages, then the main operation.
     /// Does not update chain state other than the execution state.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn execute_block(
         &mut self,
         block: &ProposedBlock,
@@ -919,6 +939,7 @@ where
     /// Applies an execution outcome to the chain, updating the outboxes, state hash and chain
     /// manager. This does not touch the execution state itself, which must be updated separately.
     /// Returns the set of event streams that were updated as a result of applying the block.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn apply_confirmed_block(
         &mut self,
         block: &ConfirmedBlock,
@@ -953,6 +974,7 @@ where
 
     /// Adds a block to `preprocessed_blocks`, and updates the outboxes where possible.
     /// Returns the set of streams that were updated as a result of preprocessing the block.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn preprocess_block(
         &mut self,
         block: &ConfirmedBlock,
@@ -979,6 +1001,7 @@ where
     }
 
     /// Verifies that the block is valid according to the chain's application permission settings.
+    #[instrument(target = "telemetry_only", skip_all)]
     fn check_app_permissions(
         app_permissions: &ApplicationPermissions,
         block: &ProposedBlock,
@@ -1021,6 +1044,7 @@ where
     }
 
     /// Returns the hashes of all blocks we have in the given range.
+    #[instrument(target = "telemetry_only", skip_all)]
     pub async fn block_hashes(
         &self,
         range: impl RangeBounds<BlockHeight>,
@@ -1066,6 +1090,7 @@ where
     /// Updates the outboxes with the messages sent in the block.
     ///
     /// Returns the set of all recipients.
+    #[instrument(target = "telemetry_only", skip_all)]
     async fn process_outgoing_messages(
         &mut self,
         block: &Block,
@@ -1157,6 +1182,7 @@ where
     /// Updates the event streams with events emitted by the block if they form a contiguous
     /// sequence (might not be the case when preprocessing a block).
     /// Returns the set of updated event streams.
+    #[instrument(target = "telemetry_only", skip_all)]
     async fn process_emitted_events(
         &mut self,
         block: &Block,