netsync

Dec 9, 2019

Changes in this version

+ const FastsyncRequestQuotaPerSecond

+ const GossipRequestQuotaPerSecond

+ const MaxBlocksPerRequest

+ const MaxNumPeersToSendRequests

+ const RefreshCounterLimit

+ const RequestToSendBodyReq

+ const RequestWaitingBodyResp

+ type Blocks struct

+ BlockArray []*core.Block

+ type HeaderHeap []*PendingBlock

+ func (h *HeaderHeap) Pop() interface{}

+ func (h *HeaderHeap) Push(x interface{})

+ func (h HeaderHeap) Len() int

+ func (h HeaderHeap) Less(i, j int) bool

+ func (h HeaderHeap) Swap(i, j int)

+ type Headers struct

+ HeaderArray []*core.BlockHeader

type RequestManager

+ func (rm *RequestManager) AddActivePeer(activePeerID string)

+ func (rm *RequestManager) AddHeader(header *core.BlockHeader, peerIDs []string)

+ func (rm *RequestManager) IsGossipBlock(hash common.Hash) bool

Apr 10, 2019

Changes in this version

+ const Expiration

+ func Fuzz(data []byte) int

type PendingBlock

+ func (pb *PendingBlock) HasExpired() bool

Mar 12, 2019

Changes in this version

+ const MaxInventoryRequestInterval

+ const MinInventoryRequestInterval

+ const RequestQuotaPerSecond

+ const RequestTimeout

+ const RequestToSendDataReq

+ const RequestWaitingDataResp

+ type MessageConsumer interface

+ AddMessage func(interface{})

+ type MessageIDEnum uint8

+ const MessageIDDataRequest

+ const MessageIDDataResponse

+ const MessageIDInvRequest

+ const MessageIDInvResponse

+ type PendingBlock struct

+ func NewPendingBlock(x common.Hash, peerIds []string) *PendingBlock

+ func (pb *PendingBlock) HasTimedOut() bool

+ func (pb *PendingBlock) UpdateTimestamp()

+ type RequestManager struct

+ func NewRequestManager(syncMgr *SyncManager) *RequestManager

+ func (rm *RequestManager) AddBlock(block *core.Block)

+ func (rm *RequestManager) AddHash(x common.Hash, peerIDs []string)

+ func (rm *RequestManager) Start(ctx context.Context)

+ func (rm *RequestManager) Stop()

+ func (rm *RequestManager) Wait()

+ type RequestState uint8

+ type SyncManager struct

+ func NewSyncManager(chain *blockchain.Chain, cons core.ConsensusEngine, network p2p.Network, ...) *SyncManager

+ func (sm *SyncManager) EncodeMessage(message interface{}) (common.Bytes, error)

+ func (sm *SyncManager) GetChannelIDs() []common.ChannelIDEnum

+ func (sm *SyncManager) HandleMessage(msg p2ptypes.Message) (err error)

+ func (sm *SyncManager) ParseMessage(peerID string, channelID common.ChannelIDEnum, rawMessageBytes common.Bytes) (p2ptypes.Message, error)

+ func (sm *SyncManager) PassdownMessage(msg interface{})

+ func (sm *SyncManager) Start(ctx context.Context)

+ func (sm *SyncManager) Stop()

+ func (sm *SyncManager) Wait()