Inside Bitcoin

1// Copyright (c) 2023-present The Bitcoin Core developers
2// Distributed under the MIT software license, see the accompanying
3// file COPYING or https://www.opensource.org/licenses/mit-license.php.
4
5#include <addresstype.h>
6#include <bench/bench.h>
7#include <blockfilter.h>
8#include <chain.h>
9#include <index/base.h>
10#include <index/blockfilterindex.h>
11#include <interfaces/chain.h>
12#include <primitives/block.h>
13#include <primitives/transaction.h>
14#include <pubkey.h>
15#include <script/script.h>
16#include <sync.h>
17#include <test/util/setup_common.h>
18#include <test/util/time.h>
19#include <uint256.h>
20#include <util/check.h>
21#include <util/strencodings.h>
22#include <util/time.h>
23#include <validation.h>
24
25#include <array>
26#include <memory>
27#include <span>
28#include <vector>
29
30using namespace util::hex_literals;
31
32// Very simple block filter index sync benchmark, only using coinbase outputs.
33static void BlockFilterIndexSync(benchmark::Bench& bench)
34{
35    const auto test_setup = MakeNoLogFileContext<TestChain100Setup>();
36
37    // Create more blocks
38    int CHAIN_SIZE = 600;
39    CPubKey pubkey{"02ed26169896db86ced4cbb7b3ecef9859b5952825adbeab998fb5b307e54949c9"_hex_u8};
40    CScript script = GetScriptForDestination(WitnessV0KeyHash(pubkey));
41    std::vector<CMutableTransaction> noTxns;
42    for (int i = 0; i < CHAIN_SIZE - 100; i++) {
43        test_setup->CreateAndProcessBlock(noTxns, script);
44        test_setup->m_clock += 1s;
45    }
46    assert(WITH_LOCK(::cs_main, return test_setup->m_node.chainman->ActiveHeight() == CHAIN_SIZE));
47
48    bench.minEpochIterations(5).run([&] {
49        BlockFilterIndex filter_index(interfaces::MakeChain(test_setup->m_node), BlockFilterType::BASIC,
50                                      /*n_cache_size=*/0, /*f_memory=*/false, /*f_wipe=*/true);
51        assert(filter_index.Init());
52        assert(!filter_index.BlockUntilSyncedToCurrentChain());
53        filter_index.Sync();
54
55        IndexSummary summary = filter_index.GetSummary();
56        assert(summary.synced);
57        assert(summary.best_block_hash == WITH_LOCK(::cs_main, return test_setup->m_node.chainman->ActiveTip()->GetBlockHash()));
58
59        // Shutdown sequence (c.f. Shutdown() in init.cpp)
60        filter_index.Stop();
61    });
62}
63
64BENCHMARK(BlockFilterIndexSync);
65