Metrics:duplicate txs

Qitmeer · Nov 4, 2023 · 9c866d8 · 9c866d8
1 parent 5005758
commit 9c866d8
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 0 deletions.
diff --git a/core/blockchain/metrics.go b/core/blockchain/metrics.go
@@ -7,4 +7,6 @@ import (
 var (
 	blockProcessTimer           = metrics.NewRegisteredTimer("blockchain/process", nil)
 	blockConnectedNotifications = metrics.NewRegisteredTimer("blockchain/process/connectnotifications", nil)
+
+	duplicateTxsGauge = metrics.NewRegisteredGauge("blockchain/duplicatetxs", nil)
 )
diff --git a/core/blockchain/process.go b/core/blockchain/process.go
@@ -727,6 +727,7 @@ func (b *BlockChain) updateBlockState(ib meerdag.IBlock, block *types.Serialized
 		return fmt.Errorf("No prev block:%d %s", ib.GetID(), ib.GetHash().String())
 	}
 	bs.Update(block, prev.GetState().(*state.BlockState), b.meerChain.GetCurHeader())
+	duplicateTxsGauge.Update(int64(bs.GetDuplicateTxsSize()))
 	b.BlockDAG().AddToCommit(ib)
 	return nil
 }

diff --git a/core/state/blockstate.go b/core/state/blockstate.go
@@ -101,6 +101,10 @@ func (b *BlockState) GetDuplicateTxs() []int {
 	return b.duplicateTxs
 }
 
+func (b *BlockState) GetDuplicateTxsSize() int {
+	return len(b.duplicateTxs)
+}
+
 func (b *BlockState) SetEVM(header *etypes.Header) {
 	b.evmNumber = header.Number.Uint64()
 	b.evmHash = header.Hash()