stages

Documentation

Index

• func MiningStep(ctx context.Context, kv kv.RwDB, mining *stagedsync.Sync, tmpDir string, ...) (err error)
• func NewDefaultStages(ctx context.Context, db kv.RwDB, snapDb kv.RwDB, p2pCfg p2p.Config, ...) []*stagedsync.Stage
• func NewInMemoryExecution(ctx context.Context, db kv.RwDB, cfg *ethconfig.Config, ...) *stagedsync.Sync
• func NewPipelineStages(ctx context.Context, db kv.RwDB, cfg *ethconfig.Config, p2pCfg p2p.Config, ...) []*stagedsync.Stage
• func StageLoop(ctx context.Context, db kv.RwDB, sync *stagedsync.Sync, ...)
• func StageLoopIteration(ctx context.Context, db kv.RwDB, txc wrap.TxContainer, sync *stagedsync.Sync, ...) (err error)
• func StateStep(ctx context.Context, chainReader consensus.ChainReader, ...) (err error)
• type Hook
  • func NewHook(ctx context.Context, db kv.RoDB, notifications *shards.Notifications, ...) *Hook
  • func (h *Hook) AfterRun(tx kv.Tx, finishProgressBefore uint64) error
  • func (h *Hook) BeforeRun(tx kv.Tx, inSync bool) error

Functions

func MiningStep

func MiningStep(ctx context.Context, kv kv.RwDB, mining *stagedsync.Sync, tmpDir string, logger log.Logger) (err error)

func NewDefaultStages

func NewDefaultStages(ctx context.Context,
	db kv.RwDB,
	snapDb kv.RwDB,
	p2pCfg p2p.Config,
	cfg *ethconfig.Config,
	controlServer *sentry_multi_client.MultiClient,
	notifications *shards.Notifications,
	snapDownloader proto_downloader.DownloaderClient,
	blockReader services.FullBlockReader,
	blockRetire services.BlockRetire,
	agg *state.Aggregator,
	silkworm *silkworm.Silkworm,
	forkValidator *engine_helpers.ForkValidator,
	heimdallClient heimdall.HeimdallClient,
	recents *lru.ARCCache[libcommon.Hash, *bor.Snapshot],
	signatures *lru.ARCCache[libcommon.Hash, libcommon.Address],
	logger log.Logger,
) []*stagedsync.Stage

func NewInMemoryExecution

func NewInMemoryExecution(ctx context.Context, db kv.RwDB, cfg *ethconfig.Config, controlServer *sentry_multi_client.MultiClient,
	dirs datadir.Dirs, notifications *shards.Notifications, blockReader services.FullBlockReader, blockWriter *blockio.BlockWriter, agg *state.Aggregator,
	silkworm *silkworm.Silkworm, logger log.Logger) *stagedsync.Sync

func NewPipelineStages

func NewPipelineStages(ctx context.Context,
	db kv.RwDB,
	cfg *ethconfig.Config,
	p2pCfg p2p.Config,
	controlServer *sentry_multi_client.MultiClient,
	notifications *shards.Notifications,
	snapDownloader proto_downloader.DownloaderClient,
	blockReader services.FullBlockReader,
	blockRetire services.BlockRetire,
	agg *state.Aggregator,
	silkworm *silkworm.Silkworm,
	forkValidator *engine_helpers.ForkValidator,
	logger log.Logger,
	checkStateRoot bool,
) []*stagedsync.Stage

func StageLoop

func StageLoop(ctx context.Context,
	db kv.RwDB,
	sync *stagedsync.Sync,
	hd *headerdownload.HeaderDownload,
	waitForDone chan struct{},
	loopMinTime time.Duration,
	logger log.Logger,
	blockReader services.FullBlockReader,
	hook *Hook,
	forcePartialCommit bool,
)

StageLoop runs the continuous loop of staged sync

func StageLoopIteration

func StageLoopIteration(ctx context.Context, db kv.RwDB, txc wrap.TxContainer, sync *stagedsync.Sync, initialCycle bool, logger log.Logger, blockReader services.FullBlockReader, hook *Hook, forcePartialCommit bool) (err error)

func StateStep

func StateStep(ctx context.Context, chainReader consensus.ChainReader, engine consensus.Engine, txc wrap.TxContainer, stateSync *stagedsync.Sync, header *types.Header, body *types.RawBody, unwindPoint uint64, headersChain []*types.Header, bodiesChain []*types.RawBody, histV3 bool) (err error)

Types

type Hook

type Hook struct {
	// contains filtered or unexported fields
}

func NewHook

func NewHook(ctx context.Context, db kv.RoDB, notifications *shards.Notifications, sync *stagedsync.Sync, blockReader services.FullBlockReader, chainConfig *chain.Config, logger log.Logger, updateHead func(ctx context.Context)) *Hook

func (*Hook) AfterRun

func (h *Hook) AfterRun(tx kv.Tx, finishProgressBefore uint64) error

func (*Hook) BeforeRun

func (h *Hook) BeforeRun(tx kv.Tx, inSync bool) error