Method requestBlockInfo

consensus/vbft/node_sync.go:467–497

(startBlkNum uint32)

}

func (self *PeerSyncer) requestBlockInfo(startBlkNum uint32) ([]*BlockInfo_, error) {
	msg := self.server.constructBlockInfoFetchMsg(startBlkNum)
	self.server.msgSendC <- &SendMsgEvent{
		ToPeer: self.peerIdx,
		Msg:    msg,
	}

	t := time.NewTimer(makeProposalTimeout * 2)
	defer t.Stop()

	select {
	case msg := <-self.msgC:
		if msg == nil {
			return nil, fmt.Errorf("nil blockinfo fetch rsp msg received")
		}
		switch msg.Type() {
		case BlockInfoFetchRespMessage:
			pMsg, ok := msg.(*BlockInfoFetchRespMsg)
			if !ok {
				// log error
			}
			return pMsg.Blocks, nil
		}
	case <-t.C:
		return nil, fmt.Errorf("timeout fetch blockInfo %d from peer %d", startBlkNum, self.peerIdx)
	case <-self.server.quitC:
		return nil, fmt.Errorf("peer syncer %d - %d quit, failed fetching BlockInfo %d",
			self.server.Index, self.peerIdx, startBlkNum)
	}
	return nil, nil
}

func (self *PeerSyncer) fetchedBlock(blkNum uint32, block *Block) error {
	self.lock.Lock()