synchronizer

Dec 17, 2018

Changes in this version

type DownloadController

+ DownloadLoop func(mFunc MissionFunc)

+ FreePeerLoop func(fpFunc FreePeerFunc)

+ ReStart func()

type DownloadControllerImpl

+ func (dc *DownloadControllerImpl) DownloadLoop(mFunc MissionFunc)

+ func (dc *DownloadControllerImpl) FreePeerLoop(fpFunc FreePeerFunc)

+ func (dc *DownloadControllerImpl) ReStart()

+ type FreePeerFunc = func(hash string, p interface{}) (missionCompleted bool)

+ type MissionFunc = func(hash string, p interface{}, peerID interface{}) (missionAccept bool, missionCompleted bool)

Sep 30, 2018

Changes in this version

+ const Done

+ const Free

+ const Head

+ const Tail

+ const Wait

+ const Work

+ type DownloadController interface

+ CreateMission func(hash string, p interface{}, peerID p2p.PeerID)

+ FreePeer func(hash string, peerID p2p.PeerID)

+ MissionComplete func(hash string)

+ MissionTimeout func(hash string, peerID p2p.PeerID)

+ Reset func()

+ Start func()

+ Stop func()

+ type DownloadControllerImpl struct

+ func NewDownloadController(callback callbackfunc) (*DownloadControllerImpl, error)

+ func (dc *DownloadControllerImpl) CreateMission(hash string, p interface{}, peerID p2p.PeerID)

+ func (dc *DownloadControllerImpl) FreePeer(hash string, peerID p2p.PeerID)

+ func (dc *DownloadControllerImpl) MissionComplete(hash string)

+ func (dc *DownloadControllerImpl) MissionTimeout(hash string, peerID p2p.PeerID)

+ func (dc *DownloadControllerImpl) Reset()

+ func (dc *DownloadControllerImpl) Start()

+ func (dc *DownloadControllerImpl) Stop()

+ type SyncImpl struct

+ func NewSynchronizer(basevariable global.BaseVariable, blkcache blockcache.BlockCache, ...) (*SyncImpl, error)

+ func (sy *SyncImpl) CheckSyncProcess()

+ func (sy *SyncImpl) Start() error

+ func (sy *SyncImpl) Stop()

+ type Synchronizer interface

+ CheckGenBlock func(hash []byte) bool

+ CheckSync func() bool

+ CheckSyncProcess func()

+ Start func() error

+ Stop func()