BlockchainBDB: Check if hard fork subdbs need reset
See f7e337e625
for LMDB equivalent.
This commit is contained in:
parent
47f6cf8bea
commit
57e75fa33f
1 changed files with 50 additions and 1 deletions
|
@ -2210,7 +2210,56 @@ uint64_t BlockchainBDB::get_hard_fork_starting_height(uint8_t version) const
|
||||||
|
|
||||||
void BlockchainBDB::check_hard_fork_info()
|
void BlockchainBDB::check_hard_fork_info()
|
||||||
{
|
{
|
||||||
/* FIXME: Some other time */
|
LOG_PRINT_L3("BlockchainBDB::" << __func__);
|
||||||
|
check_open();
|
||||||
|
|
||||||
|
if (m_hf_versions == nullptr)
|
||||||
|
{
|
||||||
|
LOG_PRINT_L0("hf versions DB not open, so not checking");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
DB_BTREE_STAT* db_stat1, * db_stat2;
|
||||||
|
|
||||||
|
// DB_FAST_STAT can apparently cause an incorrect number of records
|
||||||
|
// to be returned. The flag should be set to 0 instead if this proves
|
||||||
|
// to be the case.
|
||||||
|
|
||||||
|
// Set txn to NULL and DB_FAST_STAT to zero (0) for reliability.
|
||||||
|
m_blocks->stat(NULL, &db_stat1, 0);
|
||||||
|
m_hf_versions->stat(NULL, &db_stat2, 0);
|
||||||
|
if (db_stat1->bt_nkeys != db_stat2->bt_nkeys)
|
||||||
|
{
|
||||||
|
LOG_PRINT_L0("num blocks " << db_stat1->bt_nkeys << " != " << "num hf_versions " << db_stat2->bt_nkeys << " - will clear the two hard fork DBs");
|
||||||
|
|
||||||
|
bdb_txn_safe txn;
|
||||||
|
bdb_txn_safe* txn_ptr = &txn;
|
||||||
|
if (m_write_txn)
|
||||||
|
txn_ptr = m_write_txn;
|
||||||
|
else
|
||||||
|
{
|
||||||
|
if (m_env->txn_begin(NULL, txn, 0))
|
||||||
|
throw0(DB_ERROR("Failed to create a transaction for the db"));
|
||||||
|
}
|
||||||
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
uint32_t count;
|
||||||
|
m_hf_starting_heights->truncate(*txn_ptr, &count, 0);
|
||||||
|
LOG_PRINT_L0("hf_starting_heights count: " << count);
|
||||||
|
m_hf_versions->truncate(*txn_ptr, &count, 0);
|
||||||
|
LOG_PRINT_L0("hf_versions count: " << count);
|
||||||
|
|
||||||
|
if (!m_write_txn)
|
||||||
|
txn.commit();
|
||||||
|
}
|
||||||
|
catch (const std::exception& e)
|
||||||
|
{
|
||||||
|
throw0(DB_ERROR(std::string("Failed to clear two hard fork DBs: ").append(e.what()).c_str()));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
delete db_stat1;
|
||||||
|
delete db_stat2;
|
||||||
}
|
}
|
||||||
|
|
||||||
void BlockchainBDB::drop_hard_fork_info()
|
void BlockchainBDB::drop_hard_fork_info()
|
||||||
|
|
Loading…
Reference in a new issue