Function Finish

src/test/fuzz/tx_pool.cpp:119–166

}

void Finish(FuzzedDataProvider& fuzzed_data_provider, MockedTxPool& tx_pool, Chainstate& chainstate)
{
    WITH_LOCK(::cs_main, tx_pool.check(chainstate.CoinsTip(), chainstate.m_chain.Height() + 1));
    {
        BlockCreateOptions options{
            .block_min_fee_rate = CFeeRate{ConsumeMoney(fuzzed_data_provider, /*max=*/COIN)},
            .block_max_weight = fuzzed_data_provider.ConsumeIntegralInRange<uint64_t>(DEFAULT_BLOCK_RESERVED_WEIGHT, MAX_BLOCK_WEIGHT),
        };
        auto assembler = BlockAssembler{chainstate, &tx_pool, options};
        auto block_template = assembler.CreateNewBlock();
        Assert(block_template->block.vtx.size() >= 1);

        // Try updating the mempool for this block, as though it were mined.
        LOCK2(::cs_main, tx_pool.cs);
        tx_pool.removeForBlock(block_template->block.vtx, chainstate.m_chain.Height() + 1);

        // Now try to add those transactions back, as though a reorg happened.
        std::vector<Txid> hashes_to_update;
        for (const auto& tx : block_template->block.vtx) {
            const auto res = AcceptToMemoryPool(chainstate, tx, GetTime(), true, /*test_accept=*/false);
            if (res.m_result_type == MempoolAcceptResult::ResultType::VALID) {
                hashes_to_update.push_back(tx->GetHash());
            } else {
                tx_pool.removeRecursive(*tx, MemPoolRemovalReason::REORG);
            }
        }
        tx_pool.UpdateTransactionsFromBlock(hashes_to_update);
    }
    const auto info_all = tx_pool.infoAll();
    if (!info_all.empty()) {
        const auto& tx_to_remove = *PickValue(fuzzed_data_provider, info_all).tx;
        WITH_LOCK(tx_pool.cs, tx_pool.removeRecursive(tx_to_remove, MemPoolRemovalReason::BLOCK /* dummy */));
        assert(tx_pool.size() < info_all.size());
    }

    if (fuzzed_data_provider.ConsumeBool()) {
        // Try eviction
        LOCK2(::cs_main, tx_pool.cs);
        tx_pool.TrimToSize(fuzzed_data_provider.ConsumeIntegralInRange<size_t>(0U, tx_pool.DynamicMemoryUsage() * 2));
    }
    if (fuzzed_data_provider.ConsumeBool()) {
        // Try expiry
        LOCK2(::cs_main, tx_pool.cs);
        tx_pool.Expire(GetMockTime() - std::chrono::seconds(fuzzed_data_provider.ConsumeIntegral<uint32_t>()));
    }
    WITH_LOCK(::cs_main, tx_pool.check(chainstate.CoinsTip(), chainstate.m_chain.Height() + 1));
    g_setup->m_node.validation_signals->SyncWithValidationInterfaceQueue();
}

void MockTime(FuzzedDataProvider& fuzzed_data_provider, const Chainstate& chainstate)
{