downloader

Documentation

Index

• Variables
• type Downloader
  • func New(hasBlock hashCheckFn, getBlock getBlockFn) *Downloader
  • func (d *Downloader) AddHashes(id string, hashes []common.Hash) error
  • func (d *Downloader) DeliverChunk(id string, blocks []*types.Block)
  • func (d *Downloader) Done()
  • func (d *Downloader) Has(hash common.Hash) bool
  • func (d *Downloader) IsBusy() bool
  • func (d *Downloader) RegisterPeer(id string, hash common.Hash, getHashes hashFetcherFn, getBlocks blockFetcherFn) error
  • func (d *Downloader) Stats() (current int, max int)
  • func (d *Downloader) Synchronise(id string, hash common.Hash) error
  • func (d *Downloader) TakeBlocks() types.Blocks
  • func (d *Downloader) UnregisterPeer(id string)

Variables

var (
	ErrBadPeer = errors.New("action from bad peer ignored")
)

Types

type Downloader

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

func New

func New(hasBlock hashCheckFn, getBlock getBlockFn) *Downloader

func (*Downloader) AddHashes

func (d *Downloader) AddHashes(id string, hashes []common.Hash) error

func (*Downloader) DeliverChunk

func (d *Downloader) DeliverChunk(id string, blocks []*types.Block)

Deliver a chunk to the downloader. This is usually done through the BlocksMsg by the protocol handler.

func (*Downloader) Done

func (d *Downloader) Done()

Done lets the downloader know that whatever previous hashes were taken are processed. If the block count reaches zero and done is called we reset the queue for the next batch of incoming hashes and blocks.

func (*Downloader) Has

func (d *Downloader) Has(hash common.Hash) bool

func (*Downloader) IsBusy

func (d *Downloader) IsBusy() bool

func (*Downloader) RegisterPeer

func (d *Downloader) RegisterPeer(id string, hash common.Hash, getHashes hashFetcherFn, getBlocks blockFetcherFn) error

func (*Downloader) Stats

func (d *Downloader) Stats() (current int, max int)

func (*Downloader) Synchronise

func (d *Downloader) Synchronise(id string, hash common.Hash) error

SynchroniseWithPeer will select the peer and use it for synchronising. If an empty string is given it will use the best peer possible and synchronise if it's TD is higher than our own. If any of the checks fail an error will be returned. This method is synchronous

func (*Downloader) TakeBlocks

func (d *Downloader) TakeBlocks() types.Blocks

TakeBlocks takes blocks from the queue and yields them to the blockTaker handler it's possible it yields no blocks

func (*Downloader) UnregisterPeer

func (d *Downloader) UnregisterPeer(id string)

UnregisterPeer unregister's a peer. This will prevent any action from the specified peer.