Method OnHeaderReceive

p2pserver/block_sync.go:534–587

OnHeaderReceive receive header from net

(fromID uint64, headers []*types.Header)

//OnHeaderReceive receive header from net
func (this *BlockSyncMgr) OnHeaderReceive(fromID uint64, headers []*types.Header) {
	if len(headers) == 0 {
		return
	}
	log.Infof("Header receive height:%d - %d", headers[0].Height, headers[len(headers)-1].Height)
	height := headers[0].Height
	curHeaderHeight := this.ledger.GetCurrentHeaderHeight()

	//Means another gorountinue is adding header
	if height <= curHeaderHeight {
		return
	}
	if !this.isHeaderOnFlight(height) {
		return
	}
	err := this.ledger.AddHeaders(headers)
	this.delFlightHeader(height)
	if err != nil {
		this.addErrorRespCnt(fromID)
		n := this.getNodeWeight(fromID)
		if n != nil && n.GetErrorRespCnt() >= SYNC_MAX_ERROR_RESP_TIMES {
			this.delNode(fromID)
		}
		log.Warnf("[p2p]OnHeaderReceive AddHeaders error:%s", err)
		return
	}
	sort.Slice(headers, func(i, j int) bool {
		return headers[i].Height < headers[j].Height
	})
	curHeaderHeight = this.ledger.GetCurrentHeaderHeight()
	curBlockHeight := this.ledger.GetCurrentBlockHeight()
	for _, header := range headers {
		//handle empty block
		if header.TransactionsRoot == common.UINT256_EMPTY {
			log.Trace("[p2p]OnHeaderReceive empty block Height:%d", header.Height)
			height := header.Height
			blockHash := header.Hash()
			this.delFlightBlock(blockHash)
			nextHeader := curHeaderHeight + 1
			if height > nextHeader {
				break
			}
			if height <= curBlockHeight {
				continue
			}
			block := &types.Block{
				Header: header,
			}
			this.addBlockCache(fromID, block, common.UINT256_EMPTY)
		}
	}
	go this.saveBlock()
	this.syncHeader()
}

// OnBlockReceive receive block from net
func (this *BlockSyncMgr) OnBlockReceive(fromID uint64, blockSize uint32, block *types.Block,