block_sync

May 19, 2020

Changes in this version

+ const SYNC_BLOCK_REQUEST_TIMEOUT

+ const SYNC_HEADER_REQUEST_TIMEOUT

+ const SYNC_MAX_BLOCK_CACHE_SIZE

+ const SYNC_MAX_ERROR_RESP_TIMES

+ const SYNC_MAX_FLIGHT_BLOCK_SIZE

+ const SYNC_MAX_FLIGHT_HEADER_SIZE

+ const SYNC_MAX_HEADER_FORWARD_SIZE

+ const SYNC_MAX_HEIGHT_OFFSET

+ const SYNC_NEXT_BLOCKS_HEIGHT

+ const SYNC_NEXT_BLOCK_TIMES

+ const SYNC_NODE_RECORD_SPEED_CNT

+ const SYNC_NODE_RECORD_TIME_CNT

+ const SYNC_NODE_SPEED_INIT

+ type BlockCache struct

+ func NewBlockCache() *BlockCache

+ type BlockInfo struct

+ type BlockSyncMgr struct

+ func NewBlockSyncMgr(server p2p.P2P, ld *ledger.Ledger) *BlockSyncMgr

+ func (this *BlockSyncMgr) OnAddNode(nodeId p2pComm.PeerId)

+ func (this *BlockSyncMgr) OnBlockReceive(fromID p2pComm.PeerId, blockSize uint32, block *types.Block, ...)

+ func (this *BlockSyncMgr) OnDelNode(nodeId p2pComm.PeerId)

+ func (this *BlockSyncMgr) OnHeaderReceive(fromID p2pComm.PeerId, headers []*types.Header)

+ func (this *BlockSyncMgr) Start()

+ func (this *BlockSyncMgr) Stop()

+ type NodeWeight struct

+ func NewNodeWeight(id p2pComm.PeerId) *NodeWeight

+ func (this *NodeWeight) AddErrorRespCnt()

+ func (this *NodeWeight) AddTimeoutCnt()

+ func (this *NodeWeight) AppendNewReqtime()

+ func (this *NodeWeight) AppendNewSpeed(s float32)

+ func (this *NodeWeight) GetErrorRespCnt() int

+ func (this *NodeWeight) Weight() float32

+ type NodeWeights []*NodeWeight

+ func (nws NodeWeights) Len() int

+ func (nws NodeWeights) Less(i, j int) bool

+ func (nws NodeWeights) Swap(i, j int)

+ type SyncFlightInfo struct

+ Height uint32

+ func NewSyncFlightInfo(height uint32, nodeId p2pComm.PeerId) *SyncFlightInfo

+ func (this *SyncFlightInfo) GetFailedTimes(nodeId p2pComm.PeerId) int

+ func (this *SyncFlightInfo) GetNodeId() p2pComm.PeerId

+ func (this *SyncFlightInfo) GetStartTime() time.Time

+ func (this *SyncFlightInfo) GetTotalFailedTimes() int

+ func (this *SyncFlightInfo) MarkFailedNode()

+ func (this *SyncFlightInfo) ResetStartTime()

+ func (this *SyncFlightInfo) SetNodeId(nodeId p2pComm.PeerId)