bootstrap

Documentation

Index

• type Bootstrapper
  • func New(config Config, onFinished func(ctx context.Context, lastReqID uint32) error) (*Bootstrapper, 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() *snow.ConsensusContext
  • func (b *Bootstrapper) Disconnected(ctx context.Context, nodeID ids.NodeID) error
  • func (b *Bootstrapper) ForceAccepted(ctx context.Context, acceptedContainerIDs []ids.ID) error
  • func (b *Bootstrapper) GetAncestorsFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32) error
  • func (b *Bootstrapper) GetVM() common.VM
  • func (*Bootstrapper) Gossip(context.Context) error
  • func (b *Bootstrapper) HealthCheck(ctx context.Context) (interface{}, error)
  • func (b *Bootstrapper) Notify(_ context.Context, msg common.Message) error
  • func (b *Bootstrapper) Shutdown(ctx context.Context) error
  • func (b *Bootstrapper) Start(ctx context.Context, startReqID uint32) error
  • func (b *Bootstrapper) Timeout(ctx context.Context) error
• type Config

Types

type Bootstrapper

type Bootstrapper struct {
	Config

	// list of NoOpsHandler for messages dropped by bootstrapper
	common.StateSummaryFrontierHandler
	common.AcceptedStateSummaryHandler
	common.PutHandler
	common.QueryHandler
	common.ChitsHandler
	common.AppHandler

	common.Bootstrapper
	common.Fetcher
	// 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

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

func (*Bootstrapper) Ancestors

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

Ancestors handles the receipt of multiple containers. Should be received in response to a GetAncestors message to [nodeID] with request ID [requestID]

func (*Bootstrapper) Clear

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

func (*Bootstrapper) Connected

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

func (*Bootstrapper) Context

func (b *Bootstrapper) Context() *snow.ConsensusContext

func (*Bootstrapper) Disconnected

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

func (*Bootstrapper) ForceAccepted

func (b *Bootstrapper) ForceAccepted(ctx context.Context, acceptedContainerIDs []ids.ID) error

func (*Bootstrapper) GetAncestorsFailed

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

func (*Bootstrapper) GetVM

func (b *Bootstrapper) GetVM() common.VM

func (*Bootstrapper) Gossip

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

func (*Bootstrapper) HealthCheck

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

func (*Bootstrapper) Notify

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

func (*Bootstrapper) Shutdown

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

func (*Bootstrapper) Start

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

func (*Bootstrapper) Timeout

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

type Config

type Config struct {
	common.Config
	common.AllGetsServer

	// Blocked tracks operations that are blocked on blocks
	//
	// It should be guaranteed that `MissingIDs` should contain all IDs
	// referenced by the `MissingDependencies` that have not already been added
	// to the queue.
	Blocked *queue.JobsWithMissing

	VM block.ChainVM

	Bootstrapped func()
}