Function ProcessTxMessage

src/p2p/chainmessage.cpp:464–510

}

bool ProcessTxMessage(CNode *pFrom, string strCommand, CDataStream &vRecv) {
    std::shared_ptr<CBaseTx> pBaseTx;
    try {
        vRecv >> pBaseTx;
    } catch(const runtime_error &e) {
        // TODO: record the misebehaving or ban the peer node.
        return ERRORMSG("Unknown transaction type from peer %s, ignore! %s", pFrom->addr.ToString(), e.what());
    }

    if (pBaseTx->IsRelayForbidden()) {
        return ERRORMSG("Forbid transaction=%s from network from peer %s, txid=%s, raw: %s", pBaseTx->GetTxTypeName(),
                pFrom->addr.ToString(), pBaseTx->GetHash().ToString(), HexStr(vRecv.begin(), vRecv.end()));
    }

    CInv inv(MSG_TX, pBaseTx->GetHash());
    pFrom->AddInventoryKnown(inv);

    if(IsInitialBlockDownload()){
        RelayTransaction(pBaseTx.get(), inv.hash);
        return true;
    }

    LOCK(cs_main);
    CValidationState state;
    if (AcceptToMemoryPool(mempool, state, pBaseTx.get(), true)) {
        RelayTransaction(pBaseTx.get(), inv.hash);
        mapAlreadyAskedFor.erase(inv);

        LogPrint(BCLog::NET, "[%d]~ %s %s : accepted %s (poolsz %u)\n", pBaseTx->valid_height, pFrom->addr.ToString(),
                 pFrom->cleanSubVer, pBaseTx->GetHash().ToString(), mempool.memPoolTxs.size());
    }

    int32_t nDoS = 0;
    if (state.IsInvalid(nDoS)) {
        LogPrint(BCLog::NET, "[%d]~ %s from %s %s not accepted into mempool: %s\n",
                pBaseTx->GetHash().ToString(), pBaseTx->valid_height,
                pFrom->addr.ToString(), pFrom->cleanSubVer, state.GetRejectReason());

        pFrom->PushMessage(NetMsgType::REJECT, strCommand, state.GetRejectCode(), state.GetRejectReason(), inv.hash);
        // if (nDoS > 0) {
        //     LogPrint(BCLog::INFO, "Misebehaving, add to tx hash %s mempool error, Misbehavior add %d",
        //     pBaseTx->GetHash().GetHex(), nDoS); Misbehaving(pFrom->GetId(), nDoS);
        // }
    }

    return true;
}

bool ProcessGetHeadersMessage(CNode *pFrom, CDataStream &vRecv) {
    CBlockLocator locator;