Method CheckTxInMemPool

src/tx/txmempool.cpp:91–133

}

bool CTxMemPool::CheckTxInMemPool(const uint256 &txid, const CTxMemPoolEntry &memPoolEntry, CValidationState &state, int32_t index,
                                  bool bRehearsalExecute) {
    auto bm = MAKE_BENCHMARK("execute tx in mempool");
    CBlockIndex *pTip =  chainActive.Tip();
    if (pTip == nullptr)
        throw runtime_error("CheckTxInMemPool:: ChainActive.Tip() is null");

    HeightType newHeight = pTip->height + 1;
    // not within valid height
    static int validHeight = SysCfg().GetTxCacheHeight();
    auto &tx = *memPoolEntry.GetTransaction();
    if (!tx.IsValidHeight(newHeight, validHeight)) {
        LogPrint(BCLog::INFO, "valid_height(%d) of txid %s is invalid! new_height=%d\n", tx.valid_height, txid.GetHex(), newHeight);
        return state.Invalid(false, REJECT_INVALID, "tx-invalid-height");
    }

    // already confirmed in block
    if (cw->txCache.HasTx(txid)) {
        LogPrint(BCLog::INFO, "txid %s confirmed in block\n", txid.GetHex());
        return state.Invalid(false, REJECT_INVALID, "tx-duplicate-confirmed");
    }

    auto spCW = std::make_shared<CCacheWrapper>(cw.get());

    if (bRehearsalExecute) { //always true so far
        const auto &bpRegid = GetBlockBpRegid(*chainActive.TipBlock());
        uint32_t fuelRate  = GetElementForBurn(pTip);
        uint32_t blockTime = pTip->GetBlockTime();
        uint32_t prevBlockTime = pTip->pprev != nullptr ? pTip->pprev->GetBlockTime() : pTip->GetBlockTime();
        CTxExecuteContext context(newHeight, index, fuelRate, blockTime, prevBlockTime, bpRegid, spCW.get(), &state,
                                TxExecuteContextType::VALIDATE_MEMPOOL);

        if (!tx.ExecuteFullTx(context)) { //rehearsal only within cache env
            pCdMan->pLogCache->SetExecuteFail(newHeight, tx.GetHash(),
                                              state.GetRejectCode(), state.GetRejectReason());
            return false;
        }
    }

    spCW->Flush();

    return true;
}

void CTxMemPool::SetMemPoolCache() {
    cw.reset(new CCacheWrapper(pCdMan));