forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-06-08 07:58:40 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

core/state: instrument BAL state-transition read times

Browse source
This commit is contained in:
CPerezz 2026-04-30 12:21:24 +02:00
parent 6730ab31e5
commit bcdc309f0b
No known key found for this signature in database
GPG key ID: 62045F34B97177DD
1 changed files with 16 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
core/state/bal_state_transition.go
View file

@ -51,6 +51,11 @@ type BALStateTransition struct {
codeUpdated int64 codeUpdated int64
codeUpdateBytes int64 codeUpdateBytes int64
// Read-time accumulators for state-root recomputation reads. Atomic
// because s.reader.Account/Storage is called from per-address goroutines.
accountReadNS atomic.Int64
storageReadNS atomic.Int64
stateUpdate *stateUpdate stateUpdate *stateUpdate
metrics BALStateTransitionMetrics metrics BALStateTransitionMetrics
@ -60,6 +65,8 @@ type BALStateTransition struct {
} }
func (s *BALStateTransition) Metrics() *BALStateTransitionMetrics { func (s *BALStateTransition) Metrics() *BALStateTransitionMetrics {
s.metrics.AccountReadTime = time.Duration(s.accountReadNS.Load())
s.metrics.StorageReadTime = time.Duration(s.storageReadNS.Load())
return &s.metrics return &s.metrics
} }
@ -91,6 +98,11 @@ type BALStateTransitionMetrics struct {
SnapshotCommits time.Duration SnapshotCommits time.Duration
TrieDBCommits time.Duration TrieDBCommits time.Duration
TotalCommitTime time.Duration TotalCommitTime time.Duration
// State-root recomputation read times. Sum of CPU time across the per-
// address goroutines that call s.reader.Account/Storage during commit.
AccountReadTime time.Duration
StorageReadTime time.Duration
} }
func NewBALStateTransition(block *types.Block, prefetchReader Reader, db Database, parentRoot common.Hash) (*BALStateTransition, error) { func NewBALStateTransition(block *types.Block, prefetchReader Reader, db Database, parentRoot common.Hash) (*BALStateTransition, error) {
@ -220,7 +232,9 @@ func (s *BALStateTransition) commitAccount(addr common.Address) (*accountUpdate,
for key, value := range s.diffs[addr].StorageWrites { for key, value := range s.diffs[addr].StorageWrites {
hash := crypto.Keccak256Hash(key[:]) hash := crypto.Keccak256Hash(key[:])
op.storages[hash] = encode(value) op.storages[hash] = encode(value)
storageReadStart := time.Now()
storage, err := s.reader.Storage(addr, key) storage, err := s.reader.Storage(addr, key)
s.storageReadNS.Add(time.Since(storageReadStart).Nanoseconds())
if err != nil { if err != nil {
return nil, nil, err return nil, nil, err
} }
@ -416,7 +430,9 @@ func (s *BALStateTransition) IntermediateRoot(_ bool) common.Hash {
defer wg.Done() defer wg.Done()
// 1 (c): update each mutated account, producing the post-block state object by applying the state mutations to the prestate (retrieved in 1a). // 1 (c): update each mutated account, producing the post-block state object by applying the state mutations to the prestate (retrieved in 1a).
accountReadStart := time.Now()
acct, err := s.reader.Account(address) acct, err := s.reader.Account(address)
s.accountReadNS.Add(time.Since(accountReadStart).Nanoseconds())
if err != nil { if err != nil {
s.setError(err) s.setError(err)
return return