15 #include <validation.h>
32 uint64_t transaction_output_count;
36 CAmount total_unspendable_amount;
37 CAmount total_prevout_spent_amount;
38 CAmount total_new_outputs_ex_coinbase_amount;
40 CAmount total_unspendables_genesis_block;
41 CAmount total_unspendables_bip30;
42 CAmount total_unspendables_scripts;
43 CAmount total_unspendables_unclaimed_rewards;
53 READWRITE(obj.total_prevout_spent_amount);
54 READWRITE(obj.total_new_outputs_ex_coinbase_amount);
56 READWRITE(obj.total_unspendables_genesis_block);
58 READWRITE(obj.total_unspendables_scripts);
59 READWRITE(obj.total_unspendables_unclaimed_rewards);
66 explicit DBHeightKey(
int height_in) : height(height_in) {}
68 template <
typename Stream>
75 template <
typename Stream>
80 throw std::ios_base::failure(
"Invalid format for coinstatsindex DB height key");
89 explicit DBHashKey(
const uint256& hash_in) : block_hash(hash_in) {}
96 throw std::ios_base::failure(
"Invalid format for coinstatsindex DB hash key");
113 m_db = std::make_unique<CoinStatsIndex::DB>(path /
"db", n_cache_size, f_memory, f_wipe);
131 std::pair<uint256, DBVal> read_out;
132 if (!
m_db->Read(DBHeightKey(block.
height - 1), read_out)) {
137 if (read_out.first != expected_block_hash) {
138 LogPrintf(
"WARNING: previous block header belongs to unexpected block %s; expected %s\n",
139 read_out.first.ToString(), expected_block_hash.ToString());
141 if (!
m_db->Read(DBHashKey(expected_block_hash), read_out)) {
142 return error(
"%s: previous block header not found; expected %s",
143 __func__, expected_block_hash.ToString());
149 for (
size_t i = 0; i < block.
data->
vtx.size(); ++i) {
150 const auto& tx{block.
data->
vtx.at(i)};
159 for (uint32_t j = 0; j < tx->vout.size(); ++j) {
160 const CTxOut& out{tx->vout[j]};
161 Coin coin{out, block.
height, tx->IsCoinBase()};
165 if (coin.out.scriptPubKey.IsUnspendable()) {
173 if (tx->IsCoinBase()) {
185 if (!tx->IsCoinBase()) {
186 const auto& tx_undo{block_undo.
vtxundo.at(i - 1)};
188 for (
size_t j = 0; j < tx_undo.vprevout.size(); ++j) {
189 Coin coin{tx_undo.vprevout[j]};
190 COutPoint outpoint{tx->vin[j].prevout.
hash, tx->vin[j].prevout.n};
216 std::pair<uint256, DBVal> value;
217 value.first = block.
hash;
233 value.second.muhash = out;
237 return m_db->Write(DBHeightKey(block.
height), value);
241 const std::string& index_name,
242 int start_height,
int stop_height)
244 DBHeightKey key{start_height};
247 for (
int height = start_height; height <= stop_height; ++height) {
248 if (!db_it.
GetKey(key) || key.height != height) {
249 return error(
"%s: unexpected key in %s: expected (%c, %d)",
253 std::pair<uint256, DBVal> value;
255 return error(
"%s: unable to read value in %s at key (%c, %d)",
259 batch.
Write(DBHashKey(value.first), std::move(value.second));
269 std::unique_ptr<CDBIterator> db_it(
m_db->NewIterator());
278 if (!
m_db->WriteBatch(batch))
return false;
290 return error(
"%s: Failed to read block %s from disk",
291 __func__, iter_tip->GetBlockHash().ToString());
296 iter_tip = iter_tip->GetAncestor(iter_tip->nHeight - 1);
297 }
while (new_tip_index != iter_tip);
308 std::pair<uint256, DBVal> read_out;
309 if (!db.
Read(DBHeightKey(block.
height), read_out)) {
312 if (read_out.first == block.
hash) {
313 result = std::move(read_out.second);
319 return db.
Read(DBHashKey(block.
hash), result);
325 stats.index_used =
true;
332 stats.hashSerialized = entry.muhash;
333 stats.nTransactionOutputs = entry.transaction_output_count;
334 stats.nBogoSize = entry.bogo_size;
335 stats.total_amount = entry.total_amount;
336 stats.total_subsidy = entry.total_subsidy;
337 stats.total_unspendable_amount = entry.total_unspendable_amount;
338 stats.total_prevout_spent_amount = entry.total_prevout_spent_amount;
339 stats.total_new_outputs_ex_coinbase_amount = entry.total_new_outputs_ex_coinbase_amount;
340 stats.total_coinbase_amount = entry.total_coinbase_amount;
341 stats.total_unspendables_genesis_block = entry.total_unspendables_genesis_block;
342 stats.total_unspendables_bip30 = entry.total_unspendables_bip30;
343 stats.total_unspendables_scripts = entry.total_unspendables_scripts;
344 stats.total_unspendables_unclaimed_rewards = entry.total_unspendables_unclaimed_rewards;
356 return error(
"%s: Cannot read current %s state; index may be corrupted",
364 return error(
"%s: Cannot read current %s state; index may be corrupted",
370 if (entry.muhash != out) {
371 return error(
"%s: Cannot read current %s state; index may be corrupted",
404 std::pair<uint256, DBVal> read_out;
415 if (!
m_db->Read(DBHeightKey(pindex->
nHeight - 1), read_out)) {
420 if (read_out.first != expected_block_hash) {
421 LogPrintf(
"WARNING: previous block header belongs to unexpected block %s; expected %s\n",
422 read_out.first.ToString(), expected_block_hash.ToString());
424 if (!
m_db->Read(DBHashKey(expected_block_hash), read_out)) {
425 return error(
"%s: previous block header not found; expected %s",
426 __func__, expected_block_hash.ToString());
432 for (
size_t i = 0; i < block.
vtx.size(); ++i) {
433 const auto& tx{block.
vtx.at(i)};
435 for (uint32_t j = 0; j < tx->vout.size(); ++j) {
436 const CTxOut& out{tx->vout[j]};
441 if (coin.out.scriptPubKey.IsUnspendable()) {
449 if (tx->IsCoinBase()) {
461 if (!tx->IsCoinBase()) {
462 const auto& tx_undo{block_undo.
vtxundo.at(i - 1)};
464 for (
size_t j = 0; j < tx_undo.vprevout.size(); ++j) {
465 Coin coin{tx_undo.vprevout[j]};
466 COutPoint outpoint{tx->vin[j].prevout.
hash, tx->vin[j].prevout.n};
486 Assert(read_out.second.muhash == out);
int64_t CAmount
Amount in satoshis (Can be negative)
const CChainParams & Params()
Return the currently selected parameters.
#define Assert(val)
Identity function.
const fs::path & GetDataDirNet() const
Get data directory path with appended network identifier.
Base class for indices of blockchain data.
const std::string & GetName() const LIFETIMEBOUND
Get the name of the index for display in logs.
Chainstate * m_chainstate
std::vector< CTransactionRef > vtx
The block chain is a tree shaped structure starting with the genesis block at the root,...
CBlockIndex * pprev
pointer to the index of the predecessor of this block
uint256 GetBlockHash() const
int nHeight
height of the entry in the chain. The genesis block has height 0
Undo information for a CBlock.
std::vector< CTxUndo > vtxundo
const Consensus::Params & GetConsensus() const
Batch of changes queued to be written to a CDBWrapper.
void Write(const K &key, const V &value)
bool Read(const K &key, V &value) const
An outpoint - a combination of a transaction hash and an index n into its vout.
An output of a transaction.
node::BlockManager & m_blockman
Reference to a BlockManager instance which itself is shared across all Chainstate instances.
CAmount m_total_unspendables_genesis_block
CAmount m_total_unspendable_amount
CAmount m_total_new_outputs_ex_coinbase_amount
bool CustomRewind(const interfaces::BlockKey ¤t_tip, const interfaces::BlockKey &new_tip) override
Rewind index to an earlier chain tip during a chain reorg.
CoinStatsIndex(std::unique_ptr< interfaces::Chain > chain, size_t n_cache_size, bool f_memory=false, bool f_wipe=false)
CAmount m_total_unspendables_scripts
uint64_t m_transaction_output_count
bool CustomAppend(const interfaces::BlockInfo &block) override
Write update index entries for a newly connected block.
CAmount m_total_prevout_spent_amount
bool ReverseBlock(const CBlock &block, const CBlockIndex *pindex)
std::optional< kernel::CCoinsStats > LookUpStats(const CBlockIndex &block_index) const
std::unique_ptr< BaseIndex::DB > m_db
bool CustomCommit(CDBBatch &batch) override
Virtual method called internally by Commit that can be overridden to atomically commit more index sta...
bool CustomInit(const std::optional< interfaces::BlockKey > &block) override
Initialize internal state from the database and block index.
CAmount m_total_coinbase_amount
CAmount m_total_unspendables_bip30
CAmount m_total_unspendables_unclaimed_rewards
void Finalize(uint256 &out) noexcept
MuHash3072 & Remove(Span< const unsigned char > in) noexcept
MuHash3072 & Insert(Span< const unsigned char > in) noexcept
Path class wrapper to block calls to the fs::path(std::string) implicit constructor and the fs::path:...
CBlockIndex * LookupBlockIndex(const uint256 &hash) EXCLUSIVE_LOCKS_REQUIRED(cs_main)
static constexpr uint8_t DB_MUHASH
static bool LookUpOne(const CDBWrapper &db, const interfaces::BlockKey &block, DBVal &result)
std::unique_ptr< CoinStatsIndex > g_coin_stats_index
The global UTXO set hash object.
static bool CopyHeightIndexToHashIndex(CDBIterator &db_it, CDBBatch &batch, const std::string &index_name, int start_height, int stop_height)
static constexpr uint8_t DB_BLOCK_HASH
static constexpr uint8_t DB_BLOCK_HEIGHT
RecursiveMutex cs_main
Mutex to guard access to validation specific variables, such as reading or changing the chainstate.
static bool create_directories(const std::filesystem::path &p)
Create directory (and if necessary its parents), unless the leaf directory already exists or is a sym...
DataStream TxOutSer(const COutPoint &outpoint, const Coin &coin)
uint64_t GetBogoSize(const CScript &script_pub_key)
bool ReadBlockFromDisk(CBlock &block, const FlatFilePos &pos, const Consensus::Params &consensusParams)
Functions for disk access for blocks.
bool UndoReadFromDisk(CBlockUndo &blockundo, const CBlockIndex *pindex)
uint8_t ser_readdata8(Stream &s)
void ser_writedata32be(Stream &s, uint32_t obj)
#define SERIALIZE_METHODS(cls, obj)
Implement the Serialize and Unserialize methods by delegating to a single templated static method tha...
void Unserialize(Stream &, char)=delete
void ser_writedata8(Stream &s, uint8_t obj)
uint32_t ser_readdata32be(Stream &s)
void Serialize(Stream &, char)=delete
constexpr auto MakeUCharSpan(V &&v) -> decltype(UCharSpanCast(Span{std::forward< V >(v)}))
Like the Span constructor, but for (const) unsigned char member types only.
Block data sent with blockConnected, blockDisconnected notifications.
const uint256 * prev_hash
Hash/height pair to help track and identify blocks.
#define WITH_LOCK(cs, code)
Run code while locking a mutex.
bool error(const char *fmt, const Args &... args)
CAmount GetBlockSubsidy(int nHeight, const Consensus::Params &consensusParams)
bool IsBIP30Unspendable(const CBlockIndex &block_index)
Identifies blocks which coinbase output was subsequently overwritten in the UTXO set (see BIP30)