Track timing of consensus stages

node/bft/Cargo.toml

@@ -93,6 +93,16 @@ workspace = true
 [dependencies.rayon]
 workspace = true
 
+[dependencies.serde]
+workspace = true
+features = [ "derive" ]
+
+[dependencies.serde_json]
+workspace = true
+
+[dependencies.once_cell]
+version = "1.0"
+
 [dependencies.sha2]
 version = "0.10"
 default-features = false

node/bft/src/bft.rs

@@ -480,6 +480,9 @@ impl<N: Network> BFT<N> {
         // Insert the certificate into the DAG.
         self.dag.write().insert(certificate);
 
+        // Record the certificate added event
+        crate::helpers::record_event(certificate_round, crate::helpers::ConsensusStage::CertificateAdded, None);
+
         // Get the previous round number.
         let commit_round = certificate_round.saturating_sub(1);
 

node/bft/src/helpers/mod.rs

@@ -51,6 +51,9 @@ pub use telemetry::*;
 pub mod timestamp;
 pub use timestamp::*;
 
+pub mod timing;
+pub use timing::*;
+
 /// Formats an ID into a truncated identifier (for logging purposes).
 pub fn fmt_id(id: impl ToString) -> String {
     let id = id.to_string();