Struct BlockSyncMgr

p2pserver/block_sync.go:227–239

BlockSyncMgr is the manager class to deal with block sync

//BlockSyncMgr is the manager class to deal with block sync
type BlockSyncMgr struct {
	flightBlocks   map[common.Uint256][]*SyncFlightInfo //Map BlockHash => []SyncFlightInfo, using for manager all of those block flights
	flightHeaders  map[uint32]*SyncFlightInfo           //Map HeaderHeight => SyncFlightInfo, using for manager all of those header flights
	blocksCache    *BlockCache                          //Map BlockHash => BlockInfo, using for cache the blocks receive from net, and waiting for commit to ledger
	server         *P2PServer                           //Pointer to the local node
	syncBlockLock  bool                                 //Help to avoid send block sync request duplicate
	syncHeaderLock bool                                 //Help to avoid send header sync request duplicate
	saveBlockLock  bool                                 //Help to avoid saving block concurrently
	exitCh         chan interface{}                     //ExitCh to receive exit signal
	ledger         *ledger.Ledger                       //ledger
	lock           sync.RWMutex                         //lock
	nodeWeights    map[uint64]*NodeWeight               //Map NodeID => NodeStatus, using for getNextNode
}

//NewBlockSyncMgr return a BlockSyncMgr instance
func NewBlockSyncMgr(server *P2PServer) *BlockSyncMgr {