Skip to content

Commit e7255df

Browse files
committed
fix2
1 parent 5b502bb commit e7255df

File tree

1 file changed

+3
-21
lines changed

1 file changed

+3
-21
lines changed

src/tx_dependency.rs

+3-21
Original file line numberDiff line numberDiff line change
@@ -213,25 +213,6 @@ impl TxDependency {
213213
self.num_finality_txs = num_finality_txs;
214214
}
215215

216-
fn draw_dependent_graph(&self) {
217-
let num_finality_txs = self.num_finality_txs;
218-
for (index, dep) in self.tx_dependency.iter().enumerate() {
219-
let txid = index + num_finality_txs;
220-
let round = self.round.map(|r| format!("round{}", r)).unwrap_or(String::from("none"));
221-
gauge!("node_status",
222-
"id" => format!("tx{}", txid), "status" => "healthy",
223-
"round" => round.clone(), "block_height" => format!("{}", self.block_height))
224-
.set(1.0);
225-
let dep: BTreeSet<TxId> = dep.clone().into_iter().collect();
226-
for dep_id in dep {
227-
gauge!("edge_flow",
228-
"source" => format!("tx{}", txid), "target" => format!("tx{}", dep_id),
229-
"round" => round.clone(), "block_height" => format!("{}", self.block_height))
230-
.set(1.0);
231-
}
232-
}
233-
}
234-
235216
fn skew_analyze(&self, weighted_group: &BTreeMap<usize, Vec<DependentTxsVec>>) {
236217
if !(*DEBUG_BOTTLENECK) {
237218
return;
@@ -258,7 +239,6 @@ impl TxDependency {
258239
if num_txs < 64 || num_remaining < num_txs / 3 || subgraph.is_empty() {
259240
return;
260241
}
261-
self.draw_dependent_graph();
262242

263243
// ChainLength -> ChainNumber
264244
let mut chains = BTreeMap::new();
@@ -300,7 +280,9 @@ impl TxDependency {
300280
"fork"
301281
};
302282
counter!("grevm.large_graph", "type" => chain_type, "tip" => tip.clone()).increment(1);
303-
info!("Block({}) has large subgraph, type={}", self.block_height, chain_type);
283+
if self.round.is_none() {
284+
info!("Block({}) has large subgraph, type={}", self.block_height, chain_type);
285+
}
304286
}
305287
}
306288
}

0 commit comments

Comments
 (0)