From ebbbac1f56c3f45f483f567b67d62abec66cf6c2 Mon Sep 17 00:00:00 2001 From: ucwong Date: Sat, 24 Jan 2026 10:57:50 +0800 Subject: [PATCH] reset gauge --- core/txpool/txpool.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/core/txpool/txpool.go b/core/txpool/txpool.go index 89f880bd13..d4bc5c7d89 100644 --- a/core/txpool/txpool.go +++ b/core/txpool/txpool.go @@ -128,9 +128,9 @@ var ( // that this number is pretty low, since txpool reorgs happen very frequently. dropBetweenReorgHistogram = metrics.NewRegisteredHistogram("txpool/dropbetweenreorg", nil, metrics.NewExpDecaySample(1028, 0.015)) - pendingGauge = metrics.NewRegisteredCounter("txpool/pending", nil) - queuedGauge = metrics.NewRegisteredCounter("txpool/queued", nil) - localGauge = metrics.NewRegisteredCounter("txpool/local", nil) + pendingGauge = metrics.NewRegisteredGauge("txpool/pending", nil) + queuedGauge = metrics.NewRegisteredGauge("txpool/queued", nil) + localGauge = metrics.NewRegisteredGauge("txpool/local", nil) slotsGauge = metrics.NewRegisteredGauge("txpool/slots", nil) @@ -1370,6 +1370,10 @@ func (pool *TxPool) reset(oldHead, newHead *types.Header) { pool.currentState = statedb pool.pendingNonces = newNoncer(statedb) + // Reset gauges + pendingGauge.Update(0) + queuedGauge.Update(0) + slotsGauge.Update(0) pendingAddrsGauge.Update(0) queuedAddrsGauge.Update(0)