bootstrap

type Bootstrapper ¶

type Bootstrapper struct {
	Config

	TimeoutRegistrar core.TimeoutRegistrar
	// list of NoOpsHandler for messages dropped by bootstrapper
	core.StateSummaryFrontierHandler
	core.AcceptedStateSummaryHandler
	core.PutHandler
	core.QueryHandler
	core.ChitsHandler
	core.AppHandler
	// contains filtered or unexported fields
}

bootstrapper repeatedly performs the bootstrapping protocol.

1. Wait until a sufficient amount of stake is connected.
2. Sample a small number of nodes to get the last accepted block ID
3. Verify against the full network that the last accepted block ID received in step 2 is an accepted block.
4. Sync the full ancestry of the last accepted block.
5. Execute all the fetched blocks that haven't already been executed.
6. Restart the bootstrapping protocol until the number of blocks being accepted during a bootstrapping round stops decreasing.

Note: Because of step 6, the bootstrapping protocol will generally be performed multiple times.

Invariant: The VM is not guaranteed to be initialized until Start has been called, so it must be guaranteed the VM is not used until after Start.

func New(config Config, onFinished func(ctx context.Context, lastReqID uint32) error) (*Bootstrapper, error)

func (b *Bootstrapper) Accepted(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerIDs set.Set[ids.ID]) error

func (b *Bootstrapper) AcceptedFrontier(ctx context.Context, nodeID ids.NodeID, requestID uint32, containerID ids.ID) error

func (b *Bootstrapper) Ancestors(ctx context.Context, nodeID ids.NodeID, requestID uint32, blks [][]byte) error

func (b *Bootstrapper) Clear(context.Context) error

func (b *Bootstrapper) Connected(ctx context.Context, nodeID ids.NodeID, nodeVersion *version.Application) error

func (b *Bootstrapper) Context() *consensus.Context

func (b *Bootstrapper) Disconnected(ctx context.Context, nodeID ids.NodeID) error

func (b *Bootstrapper) GetAcceptedFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32) error

func (b *Bootstrapper) GetAcceptedFrontierFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32) error

func (b *Bootstrapper) GetAncestorsFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32) error

func (*Bootstrapper) Gossip(context.Context) error

func (b *Bootstrapper) HealthCheck(ctx context.Context) (interface{}, error)

func (b *Bootstrapper) Notify(_ context.Context, msg core.Message) error

func (b *Bootstrapper) Shutdown(ctx context.Context) error

func (b *Bootstrapper) Start(ctx context.Context, startReqID uint32) error

func (b *Bootstrapper) Timeout() error

type Config ¶

type Config struct {
	core.AllGetsServer

	Ctx     *consensus.Context
	Beacons validators.Manager

	SampleK          int
	StartupTracker   tracker.Startup
	Sender           core.Sender
	BootstrapTracker core.BootstrapTracker

	// PeerTracker manages the set of nodes that we fetch the next block from.
	PeerTracker *p2p.PeerTracker

	// This node will only consider the first [AncestorsMaxContainersReceived]
	// containers in an ancestors message it receives.
	AncestorsMaxContainersReceived int

	// Database used to track the fetched, but not yet executed, blocks during
	// bootstrapping.
	DB db.Database

	VM block.ChainVM

	// NonVerifyingParse parses blocks without verifying them.
	NonVerifyingParse block.ParseFunc

	Bootstrapped func()

	core.Haltable
}