Method GetCommitMsgs

consensus/vbft/msg_pool.go:185–198

(blocknum uint32)

}

func (pool *MsgPool) GetCommitMsgs(blocknum uint32) []ConsensusMsg {
	pool.lock.RLock()
	defer pool.lock.RUnlock()

	roundMsgs, ok := pool.rounds[blocknum]
	if !ok {
		return nil
	}
	msg, ok := roundMsgs.msgs[BlockCommitMessage]
	if !ok {
		return nil
	}
	return msg
}

func (pool *MsgPool) GetBlockSubmitMsgNums(blocknum uint32) []ConsensusMsg {
	pool.lock.RLock()