fix2

Galxe · Dec 3, 2024 · 7c2a9e9 · 7c2a9e9
1 parent 5b502bb
commit 7c2a9e9
Showing 1 changed file with 4 additions and 22 deletions.
diff --git 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<TxId> = 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<usize, Vec<DependentTxsVec>>) {
         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);
+            }
         }
     }
 }