[qs] monitor! create batch store

aptos-labs · Dec 4, 2024 · 3290472 · 3290472
1 parent 6187585
commit 3290472
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/consensus/src/quorum_store/batch_store.rs b/consensus/src/quorum_store/batch_store.rs
@@ -229,6 +229,7 @@ impl BatchStore {
                     .expect("Storage limit exceeded upon BatchReader construction");
             }
         }
+
         info!(
             "QS: Batch store bootstrap expired keys len {}",
             expired_keys.len()

diff --git a/consensus/src/quorum_store/quorum_store_builder.rs b/consensus/src/quorum_store/quorum_store_builder.rs
@@ -5,6 +5,7 @@ use super::quorum_store_db::QuorumStoreStorage;
 use crate::{
     consensus_observer::publisher::consensus_publisher::ConsensusPublisher,
     error::error_kind,
+    monitor,
     network::{IncomingBatchRetrievalRequest, NetworkSender},
     network_interface::ConsensusMsg,
     payload_manager::{DirectMempoolPayloadManager, QuorumStorePayloadManager, TPayloadManager},
@@ -436,7 +437,7 @@ impl InnerBuilder {
         Arc<dyn TPayloadManager>,
         Option<aptos_channel::Sender<AccountAddress, (Author, VerifiedEvent)>>,
     ) {
-        let batch_reader = self.create_batch_store();
+        let batch_reader = monitor!("qs_create_batch_store", self.create_batch_store());
 
         (
             Arc::from(QuorumStorePayloadManager::new(
-Original file line number
+Diff line change
@@ Expand Up / @@ -229,6 +229,7 @@ impl BatchStore { @@
                         .expect("Storage limit exceeded upon BatchReader construction");
                 }
             }
             info!(
                 "QS: Batch store bootstrap expired keys len {}",
                 expired_keys.len()
@@ Expand Down @@