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

core: fail fast on transaction error in parallel block execution (#35465)

Browse source
This commit is contained in:
0xSHKWON 2026-08-06 11:21:22 +09:00 committed by GitHub
parent a235d28192
commit 8e77ddbaa0
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
core/state_processor_parallel.go
View file

@ -283,10 +283,8 @@ func (p *StateProcessor) executeTransactionsParallel(block *types.Block, parentR
if workers > len(txs) { if workers > len(txs) {
workers = len(txs) workers = len(txs)
} }
var ( var cursor atomic.Int64
cursor atomic.Int64 group, gctx := errgroup.WithContext(context.Background())
group errgroup.Group
)
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) context := NewEVMBlockContext(header, p.chain, nil)
@ -300,6 +298,11 @@ func (p *StateProcessor) executeTransactionsParallel(block *types.Block, parentR
defer evm.Release() defer evm.Release()
for { for {
select {
case <-gctx.Done():
return gctx.Err()
default:
}
i := int(cursor.Add(1)) - 1 i := int(cursor.Add(1)) - 1
if i >= len(txs) { if i >= len(txs) {
return nil return nil