Skip to content

Commit

Permalink
Caplin: disabled parallel exec of consensus and exec (#13597)
Browse files Browse the repository at this point in the history
buggy but do not know why
  • Loading branch information
Giulio2002 authored Jan 30, 2025
1 parent 5fd0aba commit 16988c2
Showing 1 changed file with 11 additions and 12 deletions.
23 changes: 11 additions & 12 deletions cl/phase1/network/services/block_service.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,6 @@ import (
"github.com/erigontech/erigon/cl/phase1/forkchoice"
"github.com/erigontech/erigon/cl/transition/impl/eth2"
"github.com/erigontech/erigon/cl/utils/eth_clock"
"golang.org/x/sync/errgroup"
)

var (
Expand Down Expand Up @@ -203,19 +202,19 @@ func (b *blockService) scheduleBlockForLaterProcessing(block *cltypes.SignedBeac

// processAndStoreBlock processes and stores a block
func (b *blockService) processAndStoreBlock(ctx context.Context, block *cltypes.SignedBeaconBlock) error {
group, _ := errgroup.WithContext(ctx)
// group, _ := errgroup.WithContext(ctx)

group.Go(func() error {
return b.forkchoiceStore.ProcessBlockExecution(ctx, block)
})
group.Go(func() error {
return b.forkchoiceStore.ProcessBlockConsensus(ctx, block)
})
// group.Go(func() error {
// return b.forkchoiceStore.ProcessBlockExecution(ctx, block)
// })
// group.Go(func() error {
// return b.forkchoiceStore.ProcessBlockConsensus(ctx, block)
// })

err := group.Wait()
if err != nil {
return err
}
// err := group.Wait()
// if err != nil {
// return err
// }

if err := b.db.Update(ctx, func(tx kv.RwTx) error {
return beacon_indicies.WriteBeaconBlockAndIndicies(ctx, tx, block, false)
Expand Down

0 comments on commit 16988c2

Please sign in to comment.