Branch data Line data Source code
1 : : // Copyright (c) 2017-2022 The Bitcoin Core developers 2 : : // Distributed under the MIT software license, see the accompanying 3 : : // file COPYING or http://www.opensource.org/licenses/mit-license.php. 4 : : 5 : : #include <addresstype.h> 6 : : #include <chainparams.h> 7 : : #include <index/txindex.h> 8 : : #include <interfaces/chain.h> 9 : : #include <test/util/index.h> 10 : : #include <test/util/setup_common.h> 11 : : #include <validation.h> 12 : : 13 : : #include <boost/test/unit_test.hpp> 14 : : 15 : 0 : BOOST_AUTO_TEST_SUITE(txindex_tests) 16 : : 17 : 0 : BOOST_FIXTURE_TEST_CASE(txindex_initial_sync, TestChain100Setup) 18 : 0 : { 19 : 0 : TxIndex txindex(interfaces::MakeChain(m_node), 1 << 20, true); 20 : 0 : BOOST_REQUIRE(txindex.Init()); 21 : : 22 : 0 : CTransactionRef tx_disk; 23 : 0 : uint256 block_hash; 24 : : 25 : : // Transaction should not be found in the index before it is started. 26 : 0 : for (const auto& txn : m_coinbase_txns) { 27 : 0 : BOOST_CHECK(!txindex.FindTx(txn->GetHash(), block_hash, tx_disk)); 28 : : } 29 : : 30 : : // BlockUntilSyncedToCurrentChain should return false before txindex is started. 31 : 0 : BOOST_CHECK(!txindex.BlockUntilSyncedToCurrentChain()); 32 : : 33 : 0 : BOOST_REQUIRE(txindex.StartBackgroundSync()); 34 : : 35 : : // Allow tx index to catch up with the block index. 36 : 0 : IndexWaitSynced(txindex); 37 : : 38 : : // Check that txindex excludes genesis block transactions. 39 : 0 : const CBlock& genesis_block = Params().GenesisBlock(); 40 : 0 : for (const auto& txn : genesis_block.vtx) { 41 : 0 : BOOST_CHECK(!txindex.FindTx(txn->GetHash(), block_hash, tx_disk)); 42 : : } 43 : : 44 : : // Check that txindex has all txs that were in the chain before it started. 45 : 0 : for (const auto& txn : m_coinbase_txns) { 46 : 0 : if (!txindex.FindTx(txn->GetHash(), block_hash, tx_disk)) { 47 : 0 : BOOST_ERROR("FindTx failed"); 48 : 0 : } else if (tx_disk->GetHash() != txn->GetHash()) { 49 : 0 : BOOST_ERROR("Read incorrect tx"); 50 : 0 : } 51 : : } 52 : : 53 : : // Check that new transactions in new blocks make it into the index. 54 : 0 : for (int i = 0; i < 10; i++) { 55 : 0 : CScript coinbase_script_pub_key = GetScriptForDestination(PKHash(coinbaseKey.GetPubKey())); 56 : 0 : std::vector<CMutableTransaction> no_txns; 57 : 0 : const CBlock& block = CreateAndProcessBlock(no_txns, coinbase_script_pub_key); 58 : 0 : const CTransaction& txn = *block.vtx[0]; 59 : : 60 : 0 : BOOST_CHECK(txindex.BlockUntilSyncedToCurrentChain()); 61 : 0 : if (!txindex.FindTx(txn.GetHash(), block_hash, tx_disk)) { 62 : 0 : BOOST_ERROR("FindTx failed"); 63 : 0 : } else if (tx_disk->GetHash() != txn.GetHash()) { 64 : 0 : BOOST_ERROR("Read incorrect tx"); 65 : 0 : } 66 : 0 : } 67 : : 68 : : // It is not safe to stop and destroy the index until it finishes handling 69 : : // the last BlockConnected notification. The BlockUntilSyncedToCurrentChain() 70 : : // call above is sufficient to ensure this, but the 71 : : // SyncWithValidationInterfaceQueue() call below is also needed to ensure 72 : : // TSAN always sees the test thread waiting for the notification thread, and 73 : : // avoid potential false positive reports. 74 : 0 : SyncWithValidationInterfaceQueue(); 75 : : 76 : : // shutdown sequence (c.f. Shutdown() in init.cpp) 77 : 0 : txindex.Stop(); 78 : 0 : } 79 : : 80 : 0 : BOOST_AUTO_TEST_SUITE_END()