downloader

Jul 4, 2021

Changes in this version

type BlockChain

+ Snapshots func() *snapshot.Tree

type Downloader

+ SnapSyncer *snap.Syncer

+ func (d *Downloader) DeliverSnapPacket(peer *snap.Peer, packet snap.Packet) error

type LightChain

+ SetHead func(uint64) error

type SyncMode

+ const SnapSync

Feb 4, 2020

Changes in this version

type BlockChain

+ HasBlock func(common.Hash, uint64) bool

+ HasFastBlock func(common.Hash, uint64) bool

type DoneEvent

+ Latest *types.Header

type LightChain

+ GetTd func(common.Hash, uint64) *big.Int

Oct 17, 2017

Changes in this version

+ type BlockChain interface

+ CurrentBlock func() *types.Block

+ CurrentFastBlock func() *types.Block

+ FastSyncCommitHead func(common.Hash) error

+ GetBlockByHash func(common.Hash) *types.Block

+ HasBlockAndState func(common.Hash) bool

+ InsertChain func(types.Blocks) (int, error)

+ InsertReceiptChain func(types.Blocks, []types.Receipts) (int, error)

type Downloader

+ func (d *Downloader) RegisterLightPeer(id string, version int, peer LightPeer) error

+ type FakePeer struct

+ func NewFakePeer(id string, db ethdb.Database, hc *core.HeaderChain, dl *Downloader) *FakePeer

+ func (p *FakePeer) Head() (common.Hash, *big.Int)

+ func (p *FakePeer) RequestBodies(hashes []common.Hash) error

+ func (p *FakePeer) RequestHeadersByHash(hash common.Hash, amount int, skip int, reverse bool) error

+ func (p *FakePeer) RequestHeadersByNumber(number uint64, amount int, skip int, reverse bool) error

+ func (p *FakePeer) RequestNodeData(hashes []common.Hash) error

+ func (p *FakePeer) RequestReceipts(hashes []common.Hash) error

+ type LightChain interface

+ CurrentHeader func() *types.Header

+ GetHeaderByHash func(common.Hash) *types.Header

+ GetTdByHash func(common.Hash) *big.Int

+ HasHeader func(h common.Hash, number uint64) bool

+ InsertHeaderChain func([]*types.Header, int) (int, error)

+ Rollback func([]common.Hash)

+ type LightPeer interface

+ Head func() (common.Hash, *big.Int)

+ RequestHeadersByHash func(common.Hash, int, int, bool) error

+ RequestHeadersByNumber func(uint64, int, int, bool) error

+ type Peer interface

+ RequestBodies func([]common.Hash) error

+ RequestNodeData func([]common.Hash) error

+ RequestReceipts func([]common.Hash) error

Jun 4, 2017

Changes in this version

+ var MaxBodyFetch = 128

+ var MaxForkAncestry = 3 * params.EpochDuration

+ var MaxHeaderFetch = 192

+ var MaxReceiptFetch = 256

+ var MaxSkeletonSize = 128

+ var MaxStateFetch = 384

type Downloader

+ func (d *Downloader) DeliverBodies(id string, transactions [][]*types.Transaction, uncles [][]*types.Header) (err error)

+ func (d *Downloader) DeliverHeaders(id string, headers []*types.Header) (err error)

+ func (d *Downloader) DeliverNodeData(id string, data [][]byte) (err error)

+ func (d *Downloader) DeliverReceipts(id string, receipts [][]*types.Receipt) (err error)

+ func (d *Downloader) Progress() ethereum.SyncProgress

+ type PublicDownloaderAPI struct

+ func NewPublicDownloaderAPI(d *Downloader, m *event.TypeMux) *PublicDownloaderAPI

+ func (api *PublicDownloaderAPI) SubscribeSyncStatus(status chan interface{}) *SyncStatusSubscription

+ func (api *PublicDownloaderAPI) Syncing(ctx context.Context) (*rpc.Subscription, error)

+ type SyncMode int

+ const FastSync

+ const FullSync

+ const LightSync

+ func (mode *SyncMode) UnmarshalText(text []byte) error

+ func (mode SyncMode) IsValid() bool

+ func (mode SyncMode) MarshalText() ([]byte, error)

+ func (mode SyncMode) String() string

+ type SyncStatusSubscription struct

+ func (s *SyncStatusSubscription) Unsubscribe()

+ type SyncingResult struct

+ Status ethereum.SyncProgress

+ Syncing bool

Jun 23, 2015

Changes in this version

type Downloader

+ func (d *Downloader) Terminate()

Jun 9, 2015

Changes in this version

+ var ErrEmptyHashSet = errors.New("empty hash set by peer")

May 26, 2015

Changes in this version

+ type Block struct

+ OriginPeer string

+ RawBlock *types.Block

May 21, 2015

Changes in this version

+ const MaxBlockFetch

+ const MaxHashFetch

+ const MinHashFetch

+ var ErrStallingPeer = errors.New("peer is stalling")

May 15, 2015

Changes in this version

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

+ var ErrCrossCheckFailed = errors.New("block cross-check failed")

+ var ErrInvalidChain = errors.New("retrieved hash chain is invalid")

+ type DoneEvent struct

type Downloader

+ func (d *Downloader) DeliverBlocks(id string, blocks []*types.Block) error

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

+ func (d *Downloader) Synchronising() bool

+ type FailedEvent struct

+ Err error

+ type StartEvent struct

May 12, 2015

Changes in this version

+ var ErrPendingQueue = errors.New("pending items in queue")

type Downloader

+ func (d *Downloader) Cancel() bool

May 8, 2015

Changes in this version

+ var ErrBusy = errors.New("busy")

+ var ErrTimeout = errors.New("timeout")

+ type Downloader struct

+ 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) Has(hash common.Hash) 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)