|
|
|
@ -2292,6 +2292,9 @@ void BlockchainLMDB::batch_commit()
|
|
|
|
|
throw0(DB_ERROR("batch transaction not in progress"));
|
|
|
|
|
if (m_write_batch_txn == nullptr)
|
|
|
|
|
throw0(DB_ERROR("batch transaction not in progress"));
|
|
|
|
|
if (m_writer != boost::this_thread::get_id())
|
|
|
|
|
return; // batch txn owned by other thread
|
|
|
|
|
|
|
|
|
|
check_open();
|
|
|
|
|
|
|
|
|
|
LOG_PRINT_L3("batch transaction: committing...");
|
|
|
|
@ -2316,6 +2319,8 @@ void BlockchainLMDB::batch_stop()
|
|
|
|
|
throw0(DB_ERROR("batch transaction not in progress"));
|
|
|
|
|
if (m_write_batch_txn == nullptr)
|
|
|
|
|
throw0(DB_ERROR("batch transaction not in progress"));
|
|
|
|
|
if (m_writer != boost::this_thread::get_id())
|
|
|
|
|
return; // batch txn owned by other thread
|
|
|
|
|
check_open();
|
|
|
|
|
LOG_PRINT_L3("batch transaction: committing...");
|
|
|
|
|
TIME_MEASURE_START(time1);
|
|
|
|
@ -2338,6 +2343,8 @@ void BlockchainLMDB::batch_abort()
|
|
|
|
|
throw0(DB_ERROR("batch transactions not enabled"));
|
|
|
|
|
if (! m_batch_active)
|
|
|
|
|
throw0(DB_ERROR("batch transaction not in progress"));
|
|
|
|
|
if (m_writer != boost::this_thread::get_id())
|
|
|
|
|
return; // batch txn owned by other thread
|
|
|
|
|
check_open();
|
|
|
|
|
// for destruction of batch transaction
|
|
|
|
|
m_write_txn = nullptr;
|
|
|
|
|