Method newBlockProposal

consensus/vbft/block_pool.go:134–163

add proposalMsg to CandidateInfo

(msg *blockProposalMsg)

// add proposalMsg to CandidateInfo
//
func (pool *BlockPool) newBlockProposal(msg *blockProposalMsg) error {
	pool.lock.Lock()
	defer pool.lock.Unlock()

	blkNum := msg.GetBlockNum()
	candidate := pool.getCandidateInfoLocked(blkNum)

	// check dup-proposal from same proposer
	for _, p := range candidate.Proposals {
		if p.Block.getProposer() == msg.Block.getProposer() {
			if bytes.Compare(p.Block.Block.Header.SigData[0], msg.Block.Block.Header.SigData[0]) == 0 {
				return nil
			}
			return errDupProposal
		}
	}

	// add msg to proposals
	candidate.Proposals = append(candidate.Proposals, msg)

	// add endorse-sig
	proposer := msg.Block.getProposer()
	eSig := &CandidateEndorseSigInfo{
		EndorsedProposer: proposer,
		Signature:        msg.Block.Block.Header.SigData[0],
		ForEmpty:         false,
	}
	pool.addBlockEndorsementLocked(msg.GetBlockNum(), proposer, eSig, false)
	return nil
}

func (pool *BlockPool) getBlockProposals(blkNum uint32) []*blockProposalMsg {
	pool.lock.RLock()