Documentation
¶
Overview ¶
Package downloader contains the manual full chain synchronisation.
Index ¶
- Variables
- type Block
- type DoneEvent
- type Downloader
- func (d *Downloader) Boundaries() (uint64, uint64)
- func (d *Downloader) DeliverBlocks61(id string, blocks []*types.Block) (err error)
- func (d *Downloader) DeliverBodies(id string, transactions [][]*types.Transaction, uncles [][]*types.Header) (err error)
- func (d *Downloader) DeliverHashes61(id string, hashes []common.Hash) (err error)
- func (d *Downloader) DeliverHeaders(id string, headers []*types.Header) (err error)
- func (d *Downloader) Has(hash common.Hash) bool
- func (d *Downloader) RegisterPeer(id string, version int, head common.Hash, getRelHashes relativeHashFetcherFn, ...) error
- func (d *Downloader) Synchronise(id string, head common.Hash, td *big.Int)
- func (d *Downloader) Synchronising() bool
- func (d *Downloader) Terminate()
- func (d *Downloader) UnregisterPeer(id string) error
- type FailedEvent
- type StartEvent
Constants ¶
This section is empty.
Variables ¶
var ( MaxHashFetch = 512 // Amount of hashes to be fetched per retrieval request MaxBlockFetch = 128 // Amount of blocks to be fetched per retrieval request MaxHeaderFetch = 192 // Amount of block headers to be fetched per retrieval request MaxBodyFetch = 128 // Amount of block bodies to be fetched per retrieval request MaxStateFetch = 384 // Amount of node state values to allow fetching per request MaxReceiptsFetch = 384 // Amount of transaction receipts to allow fetching per request )
Functions ¶
This section is empty.
Types ¶
type Downloader ¶
type Downloader struct {
// contains filtered or unexported fields
}
func New ¶
func New(mux *event.TypeMux, hasBlock hashCheckFn, getBlock blockRetrievalFn, headBlock headRetrievalFn, getTd tdRetrievalFn, insertChain chainInsertFn, dropPeer peerDropFn) *Downloader
New creates a new downloader to fetch hashes and blocks from remote peers.
func (*Downloader) Boundaries ¶ added in v1.2.2
func (d *Downloader) Boundaries() (uint64, uint64)
Boundaries retrieves the synchronisation boundaries, specifically the origin block where synchronisation started at (may have failed/suspended) and the latest known block which the synchonisation targets.
func (*Downloader) DeliverBlocks61 ¶ added in v1.2.2
func (d *Downloader) DeliverBlocks61(id string, blocks []*types.Block) (err error)
DeliverBlocks61 injects a new batch of blocks received from a remote node. This is usually invoked through the BlocksMsg by the protocol handler.
func (*Downloader) DeliverBodies ¶ added in v1.2.2
func (d *Downloader) DeliverBodies(id string, transactions [][]*types.Transaction, uncles [][]*types.Header) (err error)
DeliverBodies injects a new batch of block bodies received from a remote node.
func (*Downloader) DeliverHashes61 ¶ added in v1.2.2
func (d *Downloader) DeliverHashes61(id string, hashes []common.Hash) (err error)
DeliverHashes61 injects a new batch of hashes received from a remote node into the download schedule. This is usually invoked through the BlockHashesMsg by the protocol handler.
func (*Downloader) DeliverHeaders ¶ added in v1.2.2
func (d *Downloader) DeliverHeaders(id string, headers []*types.Header) (err error)
DeliverHeaders injects a new batch of blck headers received from a remote node into the download schedule.
func (*Downloader) Has ¶
func (d *Downloader) Has(hash common.Hash) bool
Has checks if the downloader knows about a particular hash, meaning that its either already downloaded of pending retrieval.
func (*Downloader) RegisterPeer ¶
func (d *Downloader) RegisterPeer(id string, version int, head common.Hash, getRelHashes relativeHashFetcherFn, getAbsHashes absoluteHashFetcherFn, getBlocks blockFetcherFn, getRelHeaders relativeHeaderFetcherFn, getAbsHeaders absoluteHeaderFetcherFn, getBlockBodies blockBodyFetcherFn) error
RegisterPeer injects a new download peer into the set of block source to be used for fetching hashes and blocks from.
func (*Downloader) Synchronise ¶
Synchronise tries to sync up our local block chain with a remote peer, both adding various sanity checks as well as wrapping it with various log entries.
func (*Downloader) Synchronising ¶ added in v0.9.21
func (d *Downloader) Synchronising() bool
Synchronising returns whether the downloader is currently retrieving blocks.
func (*Downloader) Terminate ¶ added in v0.9.32
func (d *Downloader) Terminate()
Terminate interrupts the downloader, canceling all pending operations.
func (*Downloader) UnregisterPeer ¶
func (d *Downloader) UnregisterPeer(id string) error
UnregisterPeer remove a peer from the known list, preventing any action from the specified peer.
type FailedEvent ¶ added in v0.9.21
type FailedEvent struct{ Err error }
type StartEvent ¶ added in v0.9.21
type StartEvent struct{}
Source Files