Function ProcessBlockConfirmMessage

src/p2p/chainmessage.cpp:816–856

}

bool ProcessBlockConfirmMessage(CNode *pFrom, CDataStream &vRecv) {

    if(SysCfg().IsReindex()|| GetTime()-chainActive.Tip()->GetBlockTime()>600){
        LogPrint(BCLog::NET, "local tip's height is too low,drop the confirm message ");
        return false;
    }

    CPBFTMessageMan<CBlockConfirmMessage>& msgMan = pbftContext.confirmMessageMan;
    CBlockConfirmMessage message;
    vRecv >> message;

    LogPrint(BCLog::NET, "received Block confirmedMessage: blockHeight=%d, blockHash=%s, minerid =%s, signature=%s \n",
             message.height, message.blockHash.GetHex(), message.miner.ToString(), HexStr<vector<unsigned char>>(message.vSignature));

    pFrom->AddBlockConfirmMessageKnown(message);

    if(msgMan.IsKnown(message)){
        LogPrint(BCLog::NET, "duplicate confirm message,miner_id=%s, blockhash=%s \n",message.miner.ToString(), message.blockHash.GetHex());
        return false;
    }

    if(!CheckPBFTMessage(PBFTMsgType::CONFIRM_BLOCK,message)){
        LogPrint(BCLog::NET, "confirm message check failed,miner_id=%s, blockhash=%s \n",message.miner.ToString(), message.blockHash.GetHex());
        return false;
    }

    msgMan.AddMessageKnown(message);
    int messageCount = msgMan.SaveMessageByBlock(message.blockHash, message);

    bool updateFinalitySuccess = pbftMan.UpdateLocalFinBlock(message,  messageCount);


    if(CheckPBFTMessageSigner(message))
        RelayBlockConfirmMessage(message);

    if(updateFinalitySuccess){
        BroadcastBlockFinality(pbftMan.GetLocalFinIndex());
    }

    return true;
}


bool ProcessBlockFinalityMessage(CNode *pFrom, CDataStream &vRecv) {