forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-15 16:33:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

core: fix data race on the BLOCKHASH cache in parallel block execution (#35441)

Browse source
This commit is contained in:
0xSHKWON 2026-08-04 09:41:08 +09:00 committed by GitHub
parent 7a1b11564c
commit 83f0795a60
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
core/state_processor_parallel.go
View file

@ -163,7 +163,7 @@ func (p *StateProcessor) processParallel(ctx context.Context, block *types.Block
// own ephemeral state instance, whose reads are served from the block-level // own ephemeral state instance, whose reads are served from the block-level
// access list overlaid on the parent state. // access list overlaid on the parent state.
txStart := time.Now() txStart := time.Now()
results, err := p.executeTransactionsParallel(block, parentRoot, db, base, lookup, context, signer, jumpDestCache, cfg) results, err := p.executeTransactionsParallel(block, parentRoot, db, base, lookup, signer, jumpDestCache, cfg)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -249,7 +249,7 @@ func newAccessListState(db state.Database, parentRoot common.Hash, base state.Re
// executeTransactionsParallel applies all transactions to independent, // executeTransactionsParallel applies all transactions to independent,
// access-list-backed state instances using a pool of workers, and returns // access-list-backed state instances using a pool of workers, and returns
// the per-transaction results in block order. // the per-transaction results in block order.
func (p *StateProcessor) executeTransactionsParallel(block *types.Block, parentRoot common.Hash, db state.Database, base state.Reader, lookup *bal.Lookup, context vm.BlockContext, signer types.Signer, jumpDestCache vm.JumpDestCache, cfg vm.Config) ([]txExecResult, error) { func (p *StateProcessor) executeTransactionsParallel(block *types.Block, parentRoot common.Hash, db state.Database, base state.Reader, lookup *bal.Lookup, signer types.Signer, jumpDestCache vm.JumpDestCache, cfg vm.Config) ([]txExecResult, error) {
var ( var (
config = p.chainConfig() config = p.chainConfig()
header = block.Header() header = block.Header()
@ -268,6 +268,7 @@ func (p *StateProcessor) executeTransactionsParallel(block *types.Block, parentR
) )
for w := 0; w < workers; w++ { for w := 0; w < workers; w++ {
group.Go(func() error { group.Go(func() error {
context := NewEVMBlockContext(header, p.chain, nil)
evm := vm.NewEVM(context, nil, config, cfg) evm := vm.NewEVM(context, nil, config, cfg)
if jumpDestCache != nil { if jumpDestCache != nil {
evm.SetJumpDestCache(jumpDestCache) evm.SetJumpDestCache(jumpDestCache)