Method OnBlockReceive

p2pserver/block_sync.go:590–616

OnBlockReceive receive block from net

(fromID uint64, blockSize uint32, block *types.Block,
	merkleRoot common.Uint256)

// OnBlockReceive receive block from net
func (this *BlockSyncMgr) OnBlockReceive(fromID uint64, blockSize uint32, block *types.Block,
	merkleRoot common.Uint256) {
	height := block.Header.Height
	blockHash := block.Hash()
	log.Tracef("[p2p]OnBlockReceive Height:%d", height)
	flightInfo := this.getFlightBlock(blockHash, fromID)
	if flightInfo != nil {
		t := (time.Now().UnixNano() - flightInfo.GetStartTime().UnixNano()) / int64(time.Millisecond)
		s := float32(blockSize) / float32(t) * 1000.0 / 1024.0
		this.addNewSpeed(fromID, s)
	}

	this.delFlightBlock(blockHash)
	curHeaderHeight := this.ledger.GetCurrentHeaderHeight()
	nextHeader := curHeaderHeight + 1
	if height > nextHeader {
		return
	}
	curBlockHeight := this.ledger.GetCurrentBlockHeight()
	if height <= curBlockHeight {
		return
	}

	this.addBlockCache(fromID, block, merkleRoot)
	go this.saveBlock()
	this.syncBlock()
}

//OnAddNode to node list when a new node added
func (this *BlockSyncMgr) OnAddNode(nodeId uint64) {