From fdf271960aaedb21e839e2338e57db8ab9525021 Mon Sep 17 00:00:00 2001
From: Po <chenjunfeng@ethstorage.io>
Date: Thu, 15 May 2025 07:48:07 +0200
Subject: [PATCH] add metrics

---
 cmd/geth/chaincmd.go       | 50 ++++++++++++++++++++++++++++++++++++++
 core/blockchain.go         |  1 +
 metrics/resetting_timer.go |  5 ++++
 3 files changed, 56 insertions(+)

diff --git a/cmd/geth/chaincmd.go b/cmd/geth/chaincmd.go
index a947f35f2f..077dfb72ae 100644
--- a/cmd/geth/chaincmd.go
+++ b/cmd/geth/chaincmd.go
@@ -41,6 +41,7 @@ import (
 	"github.com/ethereum/go-ethereum/internal/era"
 	"github.com/ethereum/go-ethereum/internal/flags"
 	"github.com/ethereum/go-ethereum/log"
+	"github.com/ethereum/go-ethereum/metrics"
 	"github.com/ethereum/go-ethereum/params"
 	"github.com/urfave/cli/v2"
 )
@@ -349,6 +350,7 @@ func importChain(ctx *cli.Context) error {
 
 	// Output pre-compaction stats mostly to see the import trashing
 	showDBStats(db)
+	showMetrics()
 
 	// Print the memory statistics used by the importing
 	mem := new(runtime.MemStats)
@@ -375,6 +377,54 @@ func importChain(ctx *cli.Context) error {
 	return importErr
 }
 
+func showMetrics() {
+	accountReadTimer := metrics.GetOrRegisterResettingTimer("chain/account/reads", nil)
+	accountHashTimer := metrics.GetOrRegisterResettingTimer("chain/account/hashes", nil)
+	accountUpdateTimer := metrics.GetOrRegisterResettingTimer("chain/account/updates", nil)
+	accountCommitTimer := metrics.GetOrRegisterResettingTimer("chain/account/commits", nil)
+
+	storageReadTimer := metrics.GetOrRegisterResettingTimer("chain/storage/reads", nil)
+	storageUpdateTimer := metrics.GetOrRegisterResettingTimer("chain/storage/updates", nil)
+	storageCommitTimer := metrics.GetOrRegisterResettingTimer("chain/storage/commits", nil)
+
+	accountReadSingleTimer := metrics.GetOrRegisterResettingTimer("chain/account/single/reads", nil)
+	storageReadSingleTimer := metrics.GetOrRegisterResettingTimer("chain/storage/single/reads", nil)
+
+	snapshotCommitTimer := metrics.GetOrRegisterResettingTimer("chain/snapshot/commits", nil)
+	triedbCommitTimer := metrics.GetOrRegisterResettingTimer("chain/triedb/commits", nil)
+
+	blockInsertTimer := metrics.GetOrRegisterResettingTimer("chain/inserts", nil)
+	blockValidationTimer := metrics.GetOrRegisterResettingTimer("chain/validation", nil)
+	blockCrossValidationTimer := metrics.GetOrRegisterResettingTimer("chain/crossvalidation", nil)
+	blockExecutionTimer := metrics.GetOrRegisterResettingTimer("chain/execution", nil)
+	blockWriteTimer := metrics.GetOrRegisterResettingTimer("chain/write", nil)
+
+	// not important
+	fmt.Println("accountReadSingleTimer", accountReadSingleTimer.Total())
+	fmt.Println("storageReadSingleTimer", storageReadSingleTimer.Total())
+	fmt.Println("blockCrossValidationTimer", blockCrossValidationTimer.Total())
+
+	// execution
+	fmt.Println("accountReadTimer", accountReadTimer.Total())
+	fmt.Println("storageReadTimer", storageReadTimer.Total())
+	fmt.Println("blockExecutionTimer", blockExecutionTimer.Total())
+
+	// validation
+	fmt.Println("trieAccountUpdateTimer", accountUpdateTimer.Total())
+	fmt.Println("trieStorageUpdateTimer", storageUpdateTimer.Total())
+	fmt.Println("trieHashTimer", accountHashTimer.Total())
+	fmt.Println("blockValidationTimer", blockValidationTimer.Total()) // only for computation
+
+	// commit
+	fmt.Println("account/storageCommitTimer", max(accountCommitTimer.Total(), storageCommitTimer.Total()))
+	fmt.Println("snapshotCommitTimer", snapshotCommitTimer.Total())
+	fmt.Println("triedbCommitTimer", triedbCommitTimer.Total())
+	fmt.Println("blockWriteTimer", blockWriteTimer.Total())
+
+	// total
+	fmt.Println("blockInsertTimer", blockInsertTimer.Total())
+}
+
 func exportChain(ctx *cli.Context) error {
 	if ctx.Args().Len() < 1 {
 		utils.Fatalf("This command requires an argument.")
diff --git a/core/blockchain.go b/core/blockchain.go
index 302ab14cf0..57c74e09a2 100644
--- a/core/blockchain.go
+++ b/core/blockchain.go
@@ -1905,6 +1905,7 @@ func (bc *BlockChain) processBlock(parentRoot common.Hash, block *types.Block, s
 			return nil, err
 		}
 	} else {
+		fmt.Println("prefetch enabled===========================")
 		// If prefetching is enabled, run that against the current state to pre-cache
 		// transactions and probabilistically some of the account/storage trie nodes.
 		//
diff --git a/metrics/resetting_timer.go b/metrics/resetting_timer.go
index 66458bdb91..2ff42c02ae 100644
--- a/metrics/resetting_timer.go
+++ b/metrics/resetting_timer.go
@@ -1,6 +1,7 @@
 package metrics
 
 import (
+	"fmt"
 	"sync"
 	"time"
 )
@@ -76,6 +77,10 @@ func (t *ResettingTimer) UpdateSince(ts time.Time) {
 	t.Update(time.Since(ts))
 }
 
+func (t *ResettingTimer) Total() string {
+	return fmt.Sprintf("%.1f", time.Duration(t.sum).Seconds())
+}
+
 // ResettingTimerSnapshot is a point-in-time copy of another ResettingTimer.
 type ResettingTimerSnapshot struct {
 	values              []int64