mirror of
https://github.com/bitcoin/bitcoin.git
synced 2025-01-25 18:53:23 -03:00
Compare commits
4 commits
cbf131adce
...
f47b1ee344
Author | SHA1 | Date | |
---|---|---|---|
|
f47b1ee344 | ||
|
66aa6a47bd | ||
|
7c123c08dd | ||
|
8963bc860f |
4 changed files with 48 additions and 20 deletions
|
@ -421,6 +421,7 @@ void BlockAssembler::addPackageTxs(int& nPackagesSelected, int& nDescendantsUpda
|
||||||
}
|
}
|
||||||
|
|
||||||
++nPackagesSelected;
|
++nPackagesSelected;
|
||||||
|
pblocktemplate->m_package_feerates.emplace_back(packageFees, static_cast<int32_t>(packageSize));
|
||||||
|
|
||||||
// Update transactions that depend on each of these
|
// Update transactions that depend on each of these
|
||||||
nDescendantsUpdated += UpdatePackagesForAdded(mempool, ancestors, mapModifiedTx);
|
nDescendantsUpdated += UpdatePackagesForAdded(mempool, ancestors, mapModifiedTx);
|
||||||
|
|
|
@ -10,6 +10,7 @@
|
||||||
#include <policy/policy.h>
|
#include <policy/policy.h>
|
||||||
#include <primitives/block.h>
|
#include <primitives/block.h>
|
||||||
#include <txmempool.h>
|
#include <txmempool.h>
|
||||||
|
#include <util/feefrac.h>
|
||||||
|
|
||||||
#include <memory>
|
#include <memory>
|
||||||
#include <optional>
|
#include <optional>
|
||||||
|
@ -39,6 +40,9 @@ struct CBlockTemplate
|
||||||
std::vector<CAmount> vTxFees;
|
std::vector<CAmount> vTxFees;
|
||||||
std::vector<int64_t> vTxSigOpsCost;
|
std::vector<int64_t> vTxSigOpsCost;
|
||||||
std::vector<unsigned char> vchCoinbaseCommitment;
|
std::vector<unsigned char> vchCoinbaseCommitment;
|
||||||
|
/* A vector of package fee rates, ordered by the sequence in which
|
||||||
|
* packages are selected for inclusion in the block template.*/
|
||||||
|
std::vector<FeeFrac> m_package_feerates;
|
||||||
};
|
};
|
||||||
|
|
||||||
// Container for tracking updates to ancestor feerate as we include (parent)
|
// Container for tracking updates to ancestor feerate as we include (parent)
|
||||||
|
|
|
@ -16,6 +16,7 @@
|
||||||
#include <txmempool.h>
|
#include <txmempool.h>
|
||||||
#include <uint256.h>
|
#include <uint256.h>
|
||||||
#include <util/check.h>
|
#include <util/check.h>
|
||||||
|
#include <util/feefrac.h>
|
||||||
#include <util/strencodings.h>
|
#include <util/strencodings.h>
|
||||||
#include <util/time.h>
|
#include <util/time.h>
|
||||||
#include <util/translation.h>
|
#include <util/translation.h>
|
||||||
|
@ -25,6 +26,7 @@
|
||||||
#include <test/util/setup_common.h>
|
#include <test/util/setup_common.h>
|
||||||
|
|
||||||
#include <memory>
|
#include <memory>
|
||||||
|
#include <vector>
|
||||||
|
|
||||||
#include <boost/test/unit_test.hpp>
|
#include <boost/test/unit_test.hpp>
|
||||||
|
|
||||||
|
@ -123,19 +125,22 @@ void MinerTestingSetup::TestPackageSelection(const CScript& scriptPubKey, const
|
||||||
tx.vout[0].nValue = 5000000000LL - 1000;
|
tx.vout[0].nValue = 5000000000LL - 1000;
|
||||||
// This tx has a low fee: 1000 satoshis
|
// This tx has a low fee: 1000 satoshis
|
||||||
Txid hashParentTx = tx.GetHash(); // save this txid for later use
|
Txid hashParentTx = tx.GetHash(); // save this txid for later use
|
||||||
AddToMempool(tx_mempool, entry.Fee(1000).Time(Now<NodeSeconds>()).SpendsCoinbase(true).FromTx(tx));
|
const auto parent_tx{entry.Fee(1000).Time(Now<NodeSeconds>()).SpendsCoinbase(true).FromTx(tx)};
|
||||||
|
AddToMempool(tx_mempool, parent_tx);
|
||||||
|
|
||||||
// This tx has a medium fee: 10000 satoshis
|
// This tx has a medium fee: 10000 satoshis
|
||||||
tx.vin[0].prevout.hash = txFirst[1]->GetHash();
|
tx.vin[0].prevout.hash = txFirst[1]->GetHash();
|
||||||
tx.vout[0].nValue = 5000000000LL - 10000;
|
tx.vout[0].nValue = 5000000000LL - 10000;
|
||||||
Txid hashMediumFeeTx = tx.GetHash();
|
Txid hashMediumFeeTx = tx.GetHash();
|
||||||
AddToMempool(tx_mempool, entry.Fee(10000).Time(Now<NodeSeconds>()).SpendsCoinbase(true).FromTx(tx));
|
const auto medium_fee_tx{entry.Fee(10000).Time(Now<NodeSeconds>()).SpendsCoinbase(true).FromTx(tx)};
|
||||||
|
AddToMempool(tx_mempool, medium_fee_tx);
|
||||||
|
|
||||||
// This tx has a high fee, but depends on the first transaction
|
// This tx has a high fee, but depends on the first transaction
|
||||||
tx.vin[0].prevout.hash = hashParentTx;
|
tx.vin[0].prevout.hash = hashParentTx;
|
||||||
tx.vout[0].nValue = 5000000000LL - 1000 - 50000; // 50k satoshi fee
|
tx.vout[0].nValue = 5000000000LL - 1000 - 50000; // 50k satoshi fee
|
||||||
Txid hashHighFeeTx = tx.GetHash();
|
Txid hashHighFeeTx = tx.GetHash();
|
||||||
AddToMempool(tx_mempool, entry.Fee(50000).Time(Now<NodeSeconds>()).SpendsCoinbase(false).FromTx(tx));
|
const auto high_fee_tx{entry.Fee(50000).Time(Now<NodeSeconds>()).SpendsCoinbase(false).FromTx(tx)};
|
||||||
|
AddToMempool(tx_mempool, high_fee_tx);
|
||||||
|
|
||||||
std::unique_ptr<BlockTemplate> block_template = mining->createNewBlock(options);
|
std::unique_ptr<BlockTemplate> block_template = mining->createNewBlock(options);
|
||||||
BOOST_REQUIRE(block_template);
|
BOOST_REQUIRE(block_template);
|
||||||
|
@ -145,6 +150,21 @@ void MinerTestingSetup::TestPackageSelection(const CScript& scriptPubKey, const
|
||||||
BOOST_CHECK(block.vtx[2]->GetHash() == hashHighFeeTx);
|
BOOST_CHECK(block.vtx[2]->GetHash() == hashHighFeeTx);
|
||||||
BOOST_CHECK(block.vtx[3]->GetHash() == hashMediumFeeTx);
|
BOOST_CHECK(block.vtx[3]->GetHash() == hashMediumFeeTx);
|
||||||
|
|
||||||
|
// Test the inclusion of package feerates in the block template and ensure they are sequential.
|
||||||
|
const auto block_package_feerates = BlockAssembler{m_node.chainman->ActiveChainstate(), &tx_mempool, options}.CreateNewBlock()->m_package_feerates;
|
||||||
|
BOOST_CHECK(block_package_feerates.size() == 2);
|
||||||
|
|
||||||
|
// parent_tx and high_fee_tx are added to the block as a package.
|
||||||
|
const auto combined_txs_fee = parent_tx.GetFee() + high_fee_tx.GetFee();
|
||||||
|
const auto combined_txs_size = parent_tx.GetTxSize() + high_fee_tx.GetTxSize();
|
||||||
|
FeeFrac package_feefrac{combined_txs_fee, combined_txs_size};
|
||||||
|
// The package should be added first.
|
||||||
|
BOOST_CHECK(block_package_feerates[0] == package_feefrac);
|
||||||
|
|
||||||
|
// The medium_fee_tx should be added next.
|
||||||
|
FeeFrac medium_tx_feefrac{medium_fee_tx.GetFee(), medium_fee_tx.GetTxSize()};
|
||||||
|
BOOST_CHECK(block_package_feerates[1] == medium_tx_feefrac);
|
||||||
|
|
||||||
// Test that a package below the block min tx fee doesn't get included
|
// Test that a package below the block min tx fee doesn't get included
|
||||||
tx.vin[0].prevout.hash = hashHighFeeTx;
|
tx.vin[0].prevout.hash = hashHighFeeTx;
|
||||||
tx.vout[0].nValue = 5000000000LL - 1000 - 50000; // 0 fee
|
tx.vout[0].nValue = 5000000000LL - 1000 - 50000; // 0 fee
|
||||||
|
|
|
@ -149,8 +149,7 @@ BasicTestingSetup::BasicTestingSetup(const ChainType chainType, TestOpts opts)
|
||||||
// same time, add a random element to the path. Keep it small enough to
|
// same time, add a random element to the path. Keep it small enough to
|
||||||
// avoid a MAX_PATH violation on Windows.
|
// avoid a MAX_PATH violation on Windows.
|
||||||
const auto rand{HexStr(g_rng_temp_path.randbytes(10))};
|
const auto rand{HexStr(g_rng_temp_path.randbytes(10))};
|
||||||
m_path_root = fs::temp_directory_path() / TEST_DIR_PATH_ELEMENT / test_name / rand;
|
m_path_lock = fs::temp_directory_path() / TEST_DIR_PATH_ELEMENT / test_name / rand;
|
||||||
TryCreateDirectories(m_path_root);
|
|
||||||
} else {
|
} else {
|
||||||
// Custom data directory
|
// Custom data directory
|
||||||
m_has_custom_datadir = true;
|
m_has_custom_datadir = true;
|
||||||
|
@ -159,21 +158,24 @@ BasicTestingSetup::BasicTestingSetup(const ChainType chainType, TestOpts opts)
|
||||||
|
|
||||||
root_dir = fs::absolute(root_dir);
|
root_dir = fs::absolute(root_dir);
|
||||||
m_path_lock = root_dir / TEST_DIR_PATH_ELEMENT / fs::PathFromString(test_name);
|
m_path_lock = root_dir / TEST_DIR_PATH_ELEMENT / fs::PathFromString(test_name);
|
||||||
m_path_root = m_path_lock / "datadir";
|
}
|
||||||
|
|
||||||
// Try to obtain the lock; if unsuccessful don't disturb the existing test.
|
m_path_root = m_path_lock / "datadir";
|
||||||
TryCreateDirectories(m_path_lock);
|
// Try to obtain the lock; if unsuccessful don't disturb the existing test.
|
||||||
if (util::LockDirectory(m_path_lock, ".lock", /*probe_only=*/false) != util::LockResult::Success) {
|
TryCreateDirectories(m_path_lock);
|
||||||
ExitFailure("Cannot obtain a lock on test data lock directory " + fs::PathToString(m_path_lock) + '\n' + "The test executable is probably already running.");
|
if (util::LockDirectory(m_path_lock, ".lock", /*probe_only=*/false) != util::LockResult::Success) {
|
||||||
}
|
ExitFailure("Cannot obtain a lock on test data lock directory " + fs::PathToString(m_path_lock) + '\n' + "The test directory and .lock file already exist.");
|
||||||
|
}
|
||||||
|
|
||||||
// Always start with a fresh data directory; this doesn't delete the .lock file located one level above.
|
// Always start with a fresh data directory; this doesn't delete the .lock file located one level above.
|
||||||
fs::remove_all(m_path_root);
|
fs::remove_all(m_path_root);
|
||||||
if (!TryCreateDirectories(m_path_root)) ExitFailure("Cannot create test data directory");
|
if (!TryCreateDirectories(m_path_root)) ExitFailure("Cannot create test data directory");
|
||||||
|
|
||||||
|
if (m_has_custom_datadir) {
|
||||||
// Print the test directory name if custom.
|
// Print the test directory name if custom.
|
||||||
std::cout << "Test directory (will not be deleted): " << m_path_root << std::endl;
|
std::cout << "Test directory (will not be deleted): " << m_path_root << std::endl;
|
||||||
}
|
}
|
||||||
|
|
||||||
m_args.ForceSetArg("-datadir", fs::PathToString(m_path_root));
|
m_args.ForceSetArg("-datadir", fs::PathToString(m_path_root));
|
||||||
gArgs.ForceSetArg("-datadir", fs::PathToString(m_path_root));
|
gArgs.ForceSetArg("-datadir", fs::PathToString(m_path_root));
|
||||||
|
|
||||||
|
@ -201,12 +203,13 @@ BasicTestingSetup::~BasicTestingSetup()
|
||||||
m_node.kernel.reset();
|
m_node.kernel.reset();
|
||||||
SetMockTime(0s); // Reset mocktime for following tests
|
SetMockTime(0s); // Reset mocktime for following tests
|
||||||
LogInstance().DisconnectTestLogger();
|
LogInstance().DisconnectTestLogger();
|
||||||
if (m_has_custom_datadir) {
|
|
||||||
// Only remove the lock file, preserve the data directory.
|
UnlockDirectory(m_path_lock, ".lock");
|
||||||
UnlockDirectory(m_path_lock, ".lock");
|
fs::remove(m_path_lock / ".lock");
|
||||||
fs::remove(m_path_lock / ".lock");
|
|
||||||
} else {
|
// Only delete dir if not a custom datadir
|
||||||
fs::remove_all(m_path_root);
|
if (!m_has_custom_datadir) {
|
||||||
|
fs::remove_all(m_path_lock);
|
||||||
}
|
}
|
||||||
gArgs.ClearArgs();
|
gArgs.ClearArgs();
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Reference in a new issue