Function ProcessBlockMessage

src/p2p/chainmessage.cpp:697–727

}

void ProcessBlockMessage(CNode *pFrom, CDataStream &vRecv) {
    CBlock block;
    vRecv >> block;

    LogPrint(BCLog::NET, "recv block! time_ms=%lld, hash=%s, peer=%s\n", GetTimeMillis(),
        block.GetHash().ToString(), pFrom->addr.ToString());
    // block.Print();

    CInv inv(MSG_BLOCK, block.GetHash());
    pFrom->AddInventoryKnown(inv);

    {
        // Remember who we got this block from.
        LOCK(cs_mapNodeState);
        mapBlockSource[inv.hash] = pFrom->GetId();
        MarkBlockAsReceived(inv.hash, pFrom->GetId());
    }

    LOCK(cs_main);
    CValidationState state;

    std::pair<int32_t ,uint256> globalfinblock = std::make_pair(0,uint256());
    pCdMan->pBlockCache->ReadGlobalFinBlock(globalfinblock);
    if (block.GetHeight() < (uint32_t)globalfinblock.first) {
        LogPrint(BCLog::NET,"[%d] this inbound block is irrreversible (%d)\n",
                            block.GetHeight(), globalfinblock.first);
    } else {
        ProcessBlock(state, pFrom, &block);
    }

}

void ProcessMempoolMessage(CNode *pFrom, CDataStream &vRecv) {
    LOCK2(cs_main, pFrom->cs_filter);