forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-19 18:32:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

core/state: remove update concurrency for Verkle tries

Browse source
This commit is contained in:
Péter Szilágyi 2024-05-07 09:53:49 +03:00
parent 6d3c6a1963
commit e9b599c6a1
2 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
core/state/statedb.go
View file

@ -847,6 +847,14 @@ func (s *StateDB) IntermediateRoot(deleteEmptyObjects bool) common.Hash {
start = time.Now() start = time.Now()
workers errgroup.Group workers errgroup.Group
) )
if s.db.TrieDB().IsVerkle() {
// Whilst MPT storage tries are independent, Verkle has one single trie
// for all the accounts and all the storage slots merged together. The
// former can thus be simply parallelized, but updating the latter will
// need concurrency support within the trie itself. That's a TODO for a
// later time.
workers.SetLimit(1)
}
for addr, op := range s.mutations { for addr, op := range s.mutations {
if op.applied || op.isDelete() { if op.applied || op.isDelete() {
continue continue

4
core/state/trie_prefetcher.go
View file

@ -32,10 +32,6 @@ var (
// errTerminated is returned if a fetcher is attempted to be operated after it // errTerminated is returned if a fetcher is attempted to be operated after it
// has already terminated. // has already terminated.
errTerminated = errors.New("fetcher is already terminated") errTerminated = errors.New("fetcher is already terminated")
// errNotTerminated is returned if a fetchers data is attempted to be retrieved
// before it terminates.
errNotTerminated = errors.New("fetcher is not yet terminated")
) )
// triePrefetcher is an active prefetcher, which receives accounts or storage // triePrefetcher is an active prefetcher, which receives accounts or storage