mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-20 02:42:27 +00:00
Add a metric to record txs in a block
This commit is contained in:
parent
0252f85816
commit
f7d09c2f27
1 changed files with 3 additions and 0 deletions
|
|
@ -116,6 +116,8 @@ var (
|
||||||
l2CommitTraceTimer = metrics.NewRegisteredTimer("miner/commit/trace", nil)
|
l2CommitTraceTimer = metrics.NewRegisteredTimer("miner/commit/trace", nil)
|
||||||
l2CommitCCCTimer = metrics.NewRegisteredTimer("miner/commit/ccc", nil)
|
l2CommitCCCTimer = metrics.NewRegisteredTimer("miner/commit/ccc", nil)
|
||||||
l2ResultTimer = metrics.NewRegisteredTimer("miner/result/all", nil)
|
l2ResultTimer = metrics.NewRegisteredTimer("miner/result/all", nil)
|
||||||
|
|
||||||
|
l2TaskCommitTxMeter = metrics.NewRegisteredMeter("miner/task/commit_txs", nil)
|
||||||
)
|
)
|
||||||
|
|
||||||
// environment is the worker's current environment and holds all of the current state information.
|
// environment is the worker's current environment and holds all of the current state information.
|
||||||
|
|
@ -691,6 +693,7 @@ func (w *worker) taskLoop() {
|
||||||
delete(w.pendingTasks, sealHash)
|
delete(w.pendingTasks, sealHash)
|
||||||
w.pendingMu.Unlock()
|
w.pendingMu.Unlock()
|
||||||
}
|
}
|
||||||
|
l2TaskCommitTxMeter.Mark(int64(len(task.block.Transactions())))
|
||||||
case <-w.exitCh:
|
case <-w.exitCh:
|
||||||
interrupt()
|
interrupt()
|
||||||
return
|
return
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue