stages

Documentation

Index

• func ReplacementStages(ctx context.Context, hd *headerdownload.HeaderDownload, ...) stagedsync.StageBuilders
• func ReplacementUnwindOrder() stagedsync.UnwindOrder
• func StageLoop(ctx context.Context, db ethdb.Database, hd *headerdownload.HeaderDownload, ...) error

Functions

func ReplacementStages

func ReplacementStages(ctx context.Context,
	hd *headerdownload.HeaderDownload,
	bd *bodydownload.BodyDownload,
	headerReqSend func(context.Context, []*headerdownload.HeaderRequest),
	bodyReqSend func(context.Context, *bodydownload.BodyRequest) []byte,
	penalise func(context.Context, []byte),
	updateHead func(context.Context, uint64, common.Hash, *big.Int),
	wakeUpChan chan struct{},
	timeout int,
) stagedsync.StageBuilders

func ReplacementUnwindOrder

func ReplacementUnwindOrder() stagedsync.UnwindOrder

func StageLoop

func StageLoop(
	ctx context.Context,
	db ethdb.Database,
	hd *headerdownload.HeaderDownload,
	bd *bodydownload.BodyDownload,
	headerReqSend func(context.Context, []*headerdownload.HeaderRequest),
	bodyReqSend func(context.Context, *bodydownload.BodyRequest) []byte,
	penalise func(context.Context, []byte),
	updateHead func(context.Context, uint64, common.Hash, *big.Int),
	wakeUpChan chan struct{},
	timeout int,
) error

StageLoop runs the continuous loop of staged sync