mirror of
https://github.com/ledgerwatch/erigon.git
synced 2026-02-06 14:41:44 +00:00
c6724526c0
Fixes problems found during bor-mainnet sync tests: - sync.Run was missing a for loop for initial sync convergences - temporarily disabling ForkChoiceUpdate execution since we are yet to solve and add missing state sync events and spans - no need to flush storage inside block downloader (better async performance) - logging improvements
37 lines
1.1 KiB
Go
37 lines
1.1 KiB
Go
package sync
|
|
|
|
import (
|
|
"context"
|
|
|
|
executionclient "github.com/ledgerwatch/erigon/cl/phase1/execution_client"
|
|
"github.com/ledgerwatch/erigon/core/types"
|
|
)
|
|
|
|
type ExecutionClient interface {
|
|
InsertBlocks(ctx context.Context, blocks []*types.Block) error
|
|
UpdateForkChoice(ctx context.Context, tip *types.Header, finalizedHeader *types.Header) error
|
|
CurrentHeader(ctx context.Context) (*types.Header, error)
|
|
}
|
|
|
|
type executionClient struct {
|
|
engine executionclient.ExecutionEngine
|
|
}
|
|
|
|
func NewExecutionClient(engine executionclient.ExecutionEngine) ExecutionClient {
|
|
return &executionClient{engine}
|
|
}
|
|
|
|
func (e *executionClient) InsertBlocks(ctx context.Context, blocks []*types.Block) error {
|
|
return e.engine.InsertBlocks(ctx, blocks, true)
|
|
}
|
|
|
|
func (e *executionClient) UpdateForkChoice(_ context.Context, _ *types.Header, _ *types.Header) error {
|
|
// TODO - not ready for execution - missing state sync event and span data - uncomment once ready
|
|
//return e.engine.ForkChoiceUpdate(ctx, finalizedHeader.Hash(), tip.Hash())
|
|
return nil
|
|
}
|
|
|
|
func (e *executionClient) CurrentHeader(ctx context.Context) (*types.Header, error) {
|
|
return e.engine.CurrentHeader(ctx)
|
|
}
|