diff --git a/src/tx_dependency.rs b/src/tx_dependency.rs index ab394ea..256c91d 100644 --- a/src/tx_dependency.rs +++ b/src/tx_dependency.rs @@ -8,7 +8,7 @@ use std::{ pub(crate) type DependentTxsVec = SmallVec<[TxId; 1]>; use ahash::{AHashMap as HashMap, AHashSet as HashSet}; -use metrics::{counter, gauge, histogram}; +use metrics::{counter, histogram}; use tracing::info; const RAW_TRANSFER_WEIGHT: usize = 1; @@ -213,25 +213,6 @@ impl TxDependency { self.num_finality_txs = num_finality_txs; } - fn draw_dependent_graph(&self) { - let num_finality_txs = self.num_finality_txs; - for (index, dep) in self.tx_dependency.iter().enumerate() { - let txid = index + num_finality_txs; - let round = self.round.map(|r| format!("round{}", r)).unwrap_or(String::from("none")); - gauge!("node_status", - "id" => format!("tx{}", txid), "status" => "healthy", - "round" => round.clone(), "block_height" => format!("{}", self.block_height)) - .set(1.0); - let dep: BTreeSet = dep.clone().into_iter().collect(); - for dep_id in dep { - gauge!("edge_flow", - "source" => format!("tx{}", txid), "target" => format!("tx{}", dep_id), - "round" => round.clone(), "block_height" => format!("{}", self.block_height)) - .set(1.0); - } - } - } - fn skew_analyze(&self, weighted_group: &BTreeMap>) { if !(*DEBUG_BOTTLENECK) { return; @@ -258,7 +239,6 @@ impl TxDependency { if num_txs < 64 || num_remaining < num_txs / 3 || subgraph.is_empty() { return; } - self.draw_dependent_graph(); // ChainLength -> ChainNumber let mut chains = BTreeMap::new(); @@ -300,7 +280,9 @@ impl TxDependency { "fork" }; counter!("grevm.large_graph", "type" => chain_type, "tip" => tip.clone()).increment(1); - info!("Block({}) has large subgraph, type={}", self.block_height, chain_type); + if self.round.is_none() { + info!("Block({}) has large subgraph, type={}", self.block_height, chain_type); + } } } }