Page MenuHomePhabricator
Differential D15807 Diff 46637 src/test/blockfilter_index_tests.cpp

Changeset View

Standalone View

View Options

src/test/blockfilter_index_tests.cpp

Show First 20 Lines • Show All 102 Lines • ▼ Show 20 Linesbool BuildChainTestingSetup::BuildChain(
chain.resize(length); chain.resize(length);
for (auto &block : chain) { for (auto &block : chain) {
block = std::make_shared<CBlock>( block = std::make_shared<CBlock>(
CreateBlock(pindex, no_txns, coinbase_script_pub_key)); CreateBlock(pindex, no_txns, coinbase_script_pub_key));
CBlockHeader header = block->GetBlockHeader(); CBlockHeader header = block->GetBlockHeader();
BlockValidationState state; BlockValidationState state;
if (!Assert(m_node.chainman) if (!Assert(m_node.chainman)
->ProcessNewBlockHeaders(GetConfig(), {header}, true, state, ->ProcessNewBlockHeaders({header}, true, state, &pindex)) {
&pindex)) {
return false; return false;
} }
} }
return true; return true;
} }
BOOST_FIXTURE_TEST_CASE(blockfilter_index_initial_sync, BOOST_FIXTURE_TEST_CASE(blockfilter_index_initial_sync,
▲ Show 20 Lines • Show All 71 Lines • ▼ Show 20 LinesBOOST_FIXTURE_TEST_CASE(blockfilter_index_initial_sync,
std::vector<std::shared_ptr<CBlock>> chainA, chainB; std::vector<std::shared_ptr<CBlock>> chainA, chainB;
BOOST_REQUIRE(BuildChain(tip, coinbase_script_pub_key_A, 10, chainA)); BOOST_REQUIRE(BuildChain(tip, coinbase_script_pub_key_A, 10, chainA));
BOOST_REQUIRE(BuildChain(tip, coinbase_script_pub_key_B, 10, chainB)); BOOST_REQUIRE(BuildChain(tip, coinbase_script_pub_key_B, 10, chainB));
// Check that new blocks on chain A get indexed. // Check that new blocks on chain A get indexed.
uint256 chainA_last_header = last_header; uint256 chainA_last_header = last_header;
for (size_t i = 0; i < 2; i++) { for (size_t i = 0; i < 2; i++) {
const auto &block = chainA[i]; const auto &block = chainA[i];
BOOST_REQUIRE( BOOST_REQUIRE(Assert(m_node.chainman)
Assert(m_node.chainman) ->ProcessNewBlock(block, true, true, nullptr));
->ProcessNewBlock(GetConfig(), block, true, true, nullptr));
} }
for (size_t i = 0; i < 2; i++) { for (size_t i = 0; i < 2; i++) {
const auto &block = chainA[i]; const auto &block = chainA[i];
const CBlockIndex *block_index; const CBlockIndex *block_index;
{ {
LOCK(cs_main); LOCK(cs_main);
block_index = block_index =
m_node.chainman->m_blockman.LookupBlockIndex(block->GetHash()); m_node.chainman->m_blockman.LookupBlockIndex(block->GetHash());
} }
BOOST_CHECK(filter_index.BlockUntilSyncedToCurrentChain()); BOOST_CHECK(filter_index.BlockUntilSyncedToCurrentChain());
CheckFilterLookups(filter_index, block_index, chainA_last_header); CheckFilterLookups(filter_index, block_index, chainA_last_header);
} }
// Reorg to chain B. // Reorg to chain B.
uint256 chainB_last_header = last_header; uint256 chainB_last_header = last_header;
for (size_t i = 0; i < 3; i++) { for (size_t i = 0; i < 3; i++) {
const auto &block = chainB[i]; const auto &block = chainB[i];
BOOST_REQUIRE( BOOST_REQUIRE(Assert(m_node.chainman)
Assert(m_node.chainman) ->ProcessNewBlock(block, true, true, nullptr));
->ProcessNewBlock(GetConfig(), block, true, true, nullptr));
} }
for (size_t i = 0; i < 3; i++) { for (size_t i = 0; i < 3; i++) {
const auto &block = chainB[i]; const auto &block = chainB[i];
const CBlockIndex *block_index; const CBlockIndex *block_index;
{ {
LOCK(cs_main); LOCK(cs_main);
block_index = block_index =
m_node.chainman->m_blockman.LookupBlockIndex(block->GetHash()); m_node.chainman->m_blockman.LookupBlockIndex(block->GetHash());
Show All 16 Lines for (size_t i = 0; i < 2; i++) {
BOOST_CHECK(filter_index.BlockUntilSyncedToCurrentChain()); BOOST_CHECK(filter_index.BlockUntilSyncedToCurrentChain());
CheckFilterLookups(filter_index, block_index, chainA_last_header); CheckFilterLookups(filter_index, block_index, chainA_last_header);
} }
// Reorg back to chain A. // Reorg back to chain A.
for (size_t i = 2; i < 4; i++) { for (size_t i = 2; i < 4; i++) {
const auto &block = chainA[i]; const auto &block = chainA[i];
BOOST_REQUIRE( BOOST_REQUIRE(Assert(m_node.chainman)
Assert(m_node.chainman) ->ProcessNewBlock(block, true, true, nullptr));
->ProcessNewBlock(GetConfig(), block, true, true, nullptr));
} }
// Check that chain A and B blocks can be retrieved. // Check that chain A and B blocks can be retrieved.
chainA_last_header = last_header; chainA_last_header = last_header;
chainB_last_header = last_header; chainB_last_header = last_header;
for (size_t i = 0; i < 3; i++) { for (size_t i = 0; i < 3; i++) {
const CBlockIndex *block_index; const CBlockIndex *block_index;
▲ Show 20 Lines • Show All 80 Lines • Show Last 20 Lines