add metrics for bottleneck of txpool: 1. tx packet size from p2p network

andyzhang2023 · Nov 15, 2024 · 6977830 · 6977830
1 parent c2ab741
commit 6977830
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/eth/handler_eth.go b/eth/handler_eth.go
@@ -44,6 +44,7 @@ var (
 var enqueueTx = make(chan func(), TxQueueSize)
 var parallelCounter int32 = 0
 var parallelCounterGuage = metrics.NewRegisteredGauge("p2p/enqueue/parallel", nil)
+var txPackSizeGuage = metrics.NewRegisteredGauge("p2p/enqueue/tx/pack/size", nil)
 
 func init() {
 	log.Info("P2P euqneue parallel thread number", "threadNum", TxQueueSize)
@@ -145,6 +146,9 @@ func asyncEnqueueTx(peer *eth.Peer, txs []*types.Transaction, fetcher *fetcher.T
 		return err
 	}
 	enqueueTx <- func() {
+		if metrics.EnabledExpensive {
+			txPackSizeGuage.Update(int64(len(txs)))
+		}
 		if err := fetcher.Enqueue(peer.ID(), txs, directed); err != nil {
 			peer.Log().Warn("Failed to enqueue transaction", "err", err)
 		}