Function ProcessBlockFinalityMessage

src/p2p/chainmessage.cpp:859–896

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


    if(SysCfg().IsReindex()|| GetTime()-chainActive.Tip()->GetBlockTime()>600)
        return false;

    CPBFTMessageMan<CBlockFinalityMessage>& msgMan = pbftContext.finalityMessageMan;
    CBlockFinalityMessage message;
    vRecv >> message;

    LogPrint(BCLog::NET, "received Block FinalityMessage: block=%s, miner=%s, signature=%s \n",
             message.GetBlockId(), message.miner.ToString(), HexStr(message.vSignature));

    pFrom->AddBlockFinalityMessageKnown(message);

    if(msgMan.IsKnown(message)){
        LogPrint(BCLog::NET, "duplicate finality message, miner=%s, block=%s \n",
                 message.miner.ToString(), message.GetBlockId());
        return false;
    }

    if(!CheckPBFTMessage(PBFTMsgType::FINALITY_BLOCK, message)){
        LogPrint(BCLog::NET, "finality block message check failed, miner=%s, block=%s \n",
                 message.miner.ToString(), message.GetBlockId());
        return false;
    }

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

    if(CheckPBFTMessageSigner(message)){
        RelayBlockFinalityMessage(message);
    }


    return true;
}
void ProcessRejectMessage(CNode *pFrom, CDataStream &vRecv) {
    if (SysCfg().IsDebug()) {
        string message;