mirror of
https://git.wownero.com/wownero/wownero.git
synced 2024-08-15 01:03:23 +00:00
core: do not commit half constructed batch db txn
This commit is contained in:
parent
5fbfa8a656
commit
4b51f9a34f
5 changed files with 51 additions and 14 deletions
|
@ -753,6 +753,21 @@ public:
|
||||||
*/
|
*/
|
||||||
virtual void batch_stop() = 0;
|
virtual void batch_stop() = 0;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief aborts a batch transaction
|
||||||
|
*
|
||||||
|
* If the subclass implements batching, this function should abort the
|
||||||
|
* batch it is currently on.
|
||||||
|
*
|
||||||
|
* If no batch is in-progress, this function should throw a DB_ERROR.
|
||||||
|
* This exception may change in the future if it is deemed necessary to
|
||||||
|
* have a more granular exception type for this scenario.
|
||||||
|
*
|
||||||
|
* If any of this cannot be done, the subclass should throw the corresponding
|
||||||
|
* subclass of DB_EXCEPTION
|
||||||
|
*/
|
||||||
|
virtual void batch_abort() = 0;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @brief sets whether or not to batch transactions
|
* @brief sets whether or not to batch transactions
|
||||||
*
|
*
|
||||||
|
|
|
@ -54,6 +54,7 @@ public:
|
||||||
virtual void unlock() override { }
|
virtual void unlock() override { }
|
||||||
virtual bool batch_start(uint64_t batch_num_blocks=0, uint64_t batch_bytes=0) override { return true; }
|
virtual bool batch_start(uint64_t batch_num_blocks=0, uint64_t batch_bytes=0) override { return true; }
|
||||||
virtual void batch_stop() override {}
|
virtual void batch_stop() override {}
|
||||||
|
virtual void batch_abort() override {}
|
||||||
virtual void set_batch_transactions(bool) override {}
|
virtual void set_batch_transactions(bool) override {}
|
||||||
virtual void block_wtxn_start() override {}
|
virtual void block_wtxn_start() override {}
|
||||||
virtual void block_wtxn_stop() override {}
|
virtual void block_wtxn_stop() override {}
|
||||||
|
|
|
@ -182,7 +182,8 @@ Blockchain::Blockchain(tx_memory_pool& tx_pool) :
|
||||||
m_long_term_block_weights_cache_rolling_median(CRYPTONOTE_LONG_TERM_BLOCK_WEIGHT_WINDOW_SIZE),
|
m_long_term_block_weights_cache_rolling_median(CRYPTONOTE_LONG_TERM_BLOCK_WEIGHT_WINDOW_SIZE),
|
||||||
m_difficulty_for_next_block_top_hash(crypto::null_hash),
|
m_difficulty_for_next_block_top_hash(crypto::null_hash),
|
||||||
m_difficulty_for_next_block(1),
|
m_difficulty_for_next_block(1),
|
||||||
m_btc_valid(false)
|
m_btc_valid(false),
|
||||||
|
m_batch_success(true)
|
||||||
{
|
{
|
||||||
LOG_PRINT_L3("Blockchain::" << __func__);
|
LOG_PRINT_L3("Blockchain::" << __func__);
|
||||||
}
|
}
|
||||||
|
@ -619,14 +620,7 @@ void Blockchain::pop_blocks(uint64_t nblocks)
|
||||||
CRITICAL_REGION_LOCAL(m_tx_pool);
|
CRITICAL_REGION_LOCAL(m_tx_pool);
|
||||||
CRITICAL_REGION_LOCAL1(m_blockchain_lock);
|
CRITICAL_REGION_LOCAL1(m_blockchain_lock);
|
||||||
|
|
||||||
while (!m_db->batch_start())
|
bool stop_batch = m_db->batch_start();
|
||||||
{
|
|
||||||
m_blockchain_lock.unlock();
|
|
||||||
m_tx_pool.unlock();
|
|
||||||
epee::misc_utils::sleep_no_w(1000);
|
|
||||||
m_tx_pool.lock();
|
|
||||||
m_blockchain_lock.lock();
|
|
||||||
}
|
|
||||||
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
|
@ -637,10 +631,14 @@ void Blockchain::pop_blocks(uint64_t nblocks)
|
||||||
}
|
}
|
||||||
catch (const std::exception& e)
|
catch (const std::exception& e)
|
||||||
{
|
{
|
||||||
LOG_ERROR("Error when popping blocks, only " << i << " blocks are popped: " << e.what());
|
LOG_ERROR("Error when popping blocks after processing " << i << " blocks: " << e.what());
|
||||||
|
if (stop_batch)
|
||||||
|
m_db->batch_abort();
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
m_db->batch_stop();
|
if (stop_batch)
|
||||||
|
m_db->batch_stop();
|
||||||
}
|
}
|
||||||
//------------------------------------------------------------------
|
//------------------------------------------------------------------
|
||||||
// This function tells BlockchainDB to remove the top block from the
|
// This function tells BlockchainDB to remove the top block from the
|
||||||
|
@ -3844,6 +3842,7 @@ leave:
|
||||||
catch (const KEY_IMAGE_EXISTS& e)
|
catch (const KEY_IMAGE_EXISTS& e)
|
||||||
{
|
{
|
||||||
LOG_ERROR("Error adding block with hash: " << id << " to blockchain, what = " << e.what());
|
LOG_ERROR("Error adding block with hash: " << id << " to blockchain, what = " << e.what());
|
||||||
|
m_batch_success = false;
|
||||||
bvc.m_verifivation_failed = true;
|
bvc.m_verifivation_failed = true;
|
||||||
return_tx_to_pool(txs);
|
return_tx_to_pool(txs);
|
||||||
return false;
|
return false;
|
||||||
|
@ -3852,6 +3851,7 @@ leave:
|
||||||
{
|
{
|
||||||
//TODO: figure out the best way to deal with this failure
|
//TODO: figure out the best way to deal with this failure
|
||||||
LOG_ERROR("Error adding block with hash: " << id << " to blockchain, what = " << e.what());
|
LOG_ERROR("Error adding block with hash: " << id << " to blockchain, what = " << e.what());
|
||||||
|
m_batch_success = false;
|
||||||
bvc.m_verifivation_failed = true;
|
bvc.m_verifivation_failed = true;
|
||||||
return_tx_to_pool(txs);
|
return_tx_to_pool(txs);
|
||||||
return false;
|
return false;
|
||||||
|
@ -4161,7 +4161,10 @@ bool Blockchain::cleanup_handle_incoming_blocks(bool force_sync)
|
||||||
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
m_db->batch_stop();
|
if (m_batch_success)
|
||||||
|
m_db->batch_stop();
|
||||||
|
else
|
||||||
|
m_db->batch_abort();
|
||||||
success = true;
|
success = true;
|
||||||
}
|
}
|
||||||
catch (const std::exception &e)
|
catch (const std::exception &e)
|
||||||
|
@ -4385,6 +4388,7 @@ bool Blockchain::prepare_handle_incoming_blocks(const std::vector<block_complete
|
||||||
m_tx_pool.lock();
|
m_tx_pool.lock();
|
||||||
m_blockchain_lock.lock();
|
m_blockchain_lock.lock();
|
||||||
}
|
}
|
||||||
|
m_batch_success = true;
|
||||||
|
|
||||||
const uint64_t height = m_db->height();
|
const uint64_t height = m_db->height();
|
||||||
if ((height + blocks_entry.size()) < m_blocks_hash_check.size())
|
if ((height + blocks_entry.size()) < m_blocks_hash_check.size())
|
||||||
|
|
|
@ -1102,6 +1102,9 @@ namespace cryptonote
|
||||||
uint64_t m_btc_expected_reward;
|
uint64_t m_btc_expected_reward;
|
||||||
bool m_btc_valid;
|
bool m_btc_valid;
|
||||||
|
|
||||||
|
|
||||||
|
bool m_batch_success;
|
||||||
|
|
||||||
std::shared_ptr<tools::Notify> m_block_notify;
|
std::shared_ptr<tools::Notify> m_block_notify;
|
||||||
std::shared_ptr<tools::Notify> m_reorg_notify;
|
std::shared_ptr<tools::Notify> m_reorg_notify;
|
||||||
|
|
||||||
|
|
|
@ -95,13 +95,17 @@ namespace cryptonote
|
||||||
// the whole prepare/handle/cleanup incoming block sequence.
|
// the whole prepare/handle/cleanup incoming block sequence.
|
||||||
class LockedTXN {
|
class LockedTXN {
|
||||||
public:
|
public:
|
||||||
LockedTXN(Blockchain &b): m_blockchain(b), m_batch(false) {
|
LockedTXN(Blockchain &b): m_blockchain(b), m_batch(false), m_active(false) {
|
||||||
m_batch = m_blockchain.get_db().batch_start();
|
m_batch = m_blockchain.get_db().batch_start();
|
||||||
|
m_active = true;
|
||||||
}
|
}
|
||||||
~LockedTXN() { try { if (m_batch) { m_blockchain.get_db().batch_stop(); } } catch (const std::exception &e) { MWARNING("LockedTXN dtor filtering exception: " << e.what()); } }
|
void commit() { try { if (m_batch && m_active) { m_blockchain.get_db().batch_stop(); m_active = false; } } catch (const std::exception &e) { MWARNING("LockedTXN::commit filtering exception: " << e.what()); } }
|
||||||
|
void abort() { try { if (m_batch && m_active) { m_blockchain.get_db().batch_abort(); m_active = false; } } catch (const std::exception &e) { MWARNING("LockedTXN::abort filtering exception: " << e.what()); } }
|
||||||
|
~LockedTXN() { abort(); }
|
||||||
private:
|
private:
|
||||||
Blockchain &m_blockchain;
|
Blockchain &m_blockchain;
|
||||||
bool m_batch;
|
bool m_batch;
|
||||||
|
bool m_active;
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
//---------------------------------------------------------------------------------
|
//---------------------------------------------------------------------------------
|
||||||
|
@ -255,6 +259,7 @@ namespace cryptonote
|
||||||
if (!insert_key_images(tx, id, kept_by_block))
|
if (!insert_key_images(tx, id, kept_by_block))
|
||||||
return false;
|
return false;
|
||||||
m_txs_by_fee_and_receive_time.emplace(std::pair<double, std::time_t>(fee / (double)tx_weight, receive_time), id);
|
m_txs_by_fee_and_receive_time.emplace(std::pair<double, std::time_t>(fee / (double)tx_weight, receive_time), id);
|
||||||
|
lock.commit();
|
||||||
}
|
}
|
||||||
catch (const std::exception &e)
|
catch (const std::exception &e)
|
||||||
{
|
{
|
||||||
|
@ -299,6 +304,7 @@ namespace cryptonote
|
||||||
if (!insert_key_images(tx, id, kept_by_block))
|
if (!insert_key_images(tx, id, kept_by_block))
|
||||||
return false;
|
return false;
|
||||||
m_txs_by_fee_and_receive_time.emplace(std::pair<double, std::time_t>(fee / (double)tx_weight, receive_time), id);
|
m_txs_by_fee_and_receive_time.emplace(std::pair<double, std::time_t>(fee / (double)tx_weight, receive_time), id);
|
||||||
|
lock.commit();
|
||||||
}
|
}
|
||||||
catch (const std::exception &e)
|
catch (const std::exception &e)
|
||||||
{
|
{
|
||||||
|
@ -398,6 +404,7 @@ namespace cryptonote
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
lock.commit();
|
||||||
if (changed)
|
if (changed)
|
||||||
++m_cookie;
|
++m_cookie;
|
||||||
if (m_txpool_weight > bytes)
|
if (m_txpool_weight > bytes)
|
||||||
|
@ -494,6 +501,7 @@ namespace cryptonote
|
||||||
m_blockchain.remove_txpool_tx(id);
|
m_blockchain.remove_txpool_tx(id);
|
||||||
m_txpool_weight -= tx_weight;
|
m_txpool_weight -= tx_weight;
|
||||||
remove_transaction_keyimages(tx, id);
|
remove_transaction_keyimages(tx, id);
|
||||||
|
lock.commit();
|
||||||
}
|
}
|
||||||
catch (const std::exception &e)
|
catch (const std::exception &e)
|
||||||
{
|
{
|
||||||
|
@ -578,6 +586,7 @@ namespace cryptonote
|
||||||
// ignore error
|
// ignore error
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
lock.commit();
|
||||||
++m_cookie;
|
++m_cookie;
|
||||||
}
|
}
|
||||||
return true;
|
return true;
|
||||||
|
@ -641,6 +650,7 @@ namespace cryptonote
|
||||||
// continue
|
// continue
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
lock.commit();
|
||||||
}
|
}
|
||||||
//---------------------------------------------------------------------------------
|
//---------------------------------------------------------------------------------
|
||||||
size_t tx_memory_pool::get_transactions_count(bool include_unrelayed_txes) const
|
size_t tx_memory_pool::get_transactions_count(bool include_unrelayed_txes) const
|
||||||
|
@ -1119,6 +1129,7 @@ namespace cryptonote
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
lock.commit();
|
||||||
if (changed)
|
if (changed)
|
||||||
++m_cookie;
|
++m_cookie;
|
||||||
}
|
}
|
||||||
|
@ -1271,6 +1282,7 @@ namespace cryptonote
|
||||||
append_key_images(k_images, tx);
|
append_key_images(k_images, tx);
|
||||||
LOG_PRINT_L2(" added, new block weight " << total_weight << "/" << max_total_weight << ", coinbase " << print_money(best_coinbase));
|
LOG_PRINT_L2(" added, new block weight " << total_weight << "/" << max_total_weight << ", coinbase " << print_money(best_coinbase));
|
||||||
}
|
}
|
||||||
|
lock.commit();
|
||||||
|
|
||||||
expected_reward = best_coinbase;
|
expected_reward = best_coinbase;
|
||||||
LOG_PRINT_L2("Block template filled with " << bl.tx_hashes.size() << " txes, weight "
|
LOG_PRINT_L2("Block template filled with " << bl.tx_hashes.size() << " txes, weight "
|
||||||
|
@ -1336,6 +1348,7 @@ namespace cryptonote
|
||||||
// continue
|
// continue
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
lock.commit();
|
||||||
}
|
}
|
||||||
if (n_removed > 0)
|
if (n_removed > 0)
|
||||||
++m_cookie;
|
++m_cookie;
|
||||||
|
@ -1395,6 +1408,7 @@ namespace cryptonote
|
||||||
// ignore error
|
// ignore error
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
lock.commit();
|
||||||
}
|
}
|
||||||
|
|
||||||
m_cookie = 0;
|
m_cookie = 0;
|
||||||
|
|
Loading…
Reference in a new issue