add reannounce metric for txpool (#43)

Co-authored-by: andyzhang2023 <andyzhang2023@gmail.com>
bnb-chain · Jan 5, 2024 · 7a5b85e · 7a5b85e
1 parent 1f69107
commit 7a5b85e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/core/txpool/txpool.go b/core/txpool/txpool.go
@@ -111,6 +111,8 @@ var (
 )
 
 var (
+	staledMeter = metrics.NewRegisteredMeter("txpool/staled/count", nil) // staled transactions
+
 	// Metrics for the pending pool
 	pendingDiscardMeter   = metrics.NewRegisteredMeter("txpool/pending/discard", nil)
 	pendingReplaceMeter   = metrics.NewRegisteredMeter("txpool/pending/replace", nil)
@@ -452,6 +454,7 @@ func (pool *TxPool) loop() {
 				return txs
 			}()
 			pool.mu.RUnlock()
+			staledMeter.Mark(int64(len(reannoTxs)))
 			if len(reannoTxs) > 0 {
 				pool.reannoTxFeed.Send(core.ReannoTxsEvent{reannoTxs})
 			}