Function ProcessMempoolMessage

src/p2p/chainmessage.cpp:729–751

}

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

    vector<uint256> vtxid;
    mempool.QueryHash(vtxid);
    vector<CInv> vInv;
    for (auto &hash : vtxid) {
        CInv inv(MSG_TX, hash);
        std::shared_ptr<CBaseTx> pBaseTx = mempool.Lookup(hash);
        if (pBaseTx.get())
            continue;  // another thread removed since queryHashes, maybe...

        if ((pFrom->pFilter && pFrom->pFilter->contains(hash)) ||  // other type transaction
            (!pFrom->pFilter))
            vInv.push_back(inv);

        if (vInv.size() == MAX_INV_SZ) {
            pFrom->PushMessage(NetMsgType::INV, vInv);
            vInv.clear();
        }
    }
    if (vInv.size() > 0) pFrom->PushMessage(NetMsgType::INV, vInv);
}

void ProcessAlertMessage(CNode *pFrom, CDataStream &vRecv) {
    CAlert alert;