From 3d69e4cd882cbf0e22408e821877c70b7340aa7d Mon Sep 17 00:00:00 2001 From: "KIm, JinSan" Date: Wed, 28 Oct 2020 15:11:58 +0900 Subject: [PATCH] fix: reset recheckTimeMs (#133) --- mempool/clist_mempool.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/mempool/clist_mempool.go b/mempool/clist_mempool.go index 28337e2a3..9bd3e8432 100644 --- a/mempool/clist_mempool.go +++ b/mempool/clist_mempool.go @@ -570,16 +570,12 @@ func (mem *CListMempool) Update( // Either recheck non-committed txs to see if they became invalid // or just notify there're some txs left. + recheckStartTime := time.Now().UnixNano() if mem.Size() > 0 { if mem.config.Recheck { mem.logger.Info("Recheck txs", "numtxs", mem.Size(), "height", height) - recheckStartTime := time.Now().UnixNano() mem.recheckTxs() - recheckEndTime := time.Now().UnixNano() - - recheckTimeMs := float64(recheckEndTime-recheckStartTime) / 1000000 - mem.metrics.RecheckingTime.Set(recheckTimeMs) // At this point, mem.txs are being rechecked. // mem.recheckCursor re-scans mem.txs and possibly removes some txs. @@ -588,6 +584,10 @@ func (mem *CListMempool) Update( mem.notifyTxsAvailable() } } + recheckEndTime := time.Now().UnixNano() + + recheckTimeMs := float64(recheckEndTime-recheckStartTime) / 1000000 + mem.metrics.RecheckingTime.Set(recheckTimeMs) // Update metrics mem.metrics.Size.Set(float64(mem.Size()))