Skip to content
Snippets Groups Projects
Commit 43d6b2ee authored by Mariusz Trela's avatar Mariusz Trela
Browse files

The variable `ONE_THREAD_WRITERS_NUMBER` takes into account a new SQL table (`applied_hardforks`).

A fix in `hive.disable_fk_of_irreversible` SQL function.
parent 9cb65db8
No related branches found
No related tags found
6 merge requests!627merge in fix for get_current_block_age,!626Fix get_current_block_age function to avoid healthcheck fails,!622merge develop to master,!599merge ( with merge commit) develop to master,!597Merge develop to master for release,!212The variable `ONE_THREAD_WRITERS_NUMBER` takes into account a new SQL table (`_applied_hardforks`).
Pipeline #59525 passed
......@@ -189,7 +189,6 @@ BEGIN
PERFORM hive.save_and_drop_indexes_foreign_keys( 'hive', 'applied_hardforks' );
PERFORM hive.save_and_drop_indexes_foreign_keys( 'hive', 'accounts' );
PERFORM hive.save_and_drop_indexes_foreign_keys( 'hive', 'account_operations' );
PERFORM hive.save_and_drop_indexes_foreign_keys( 'hive', 'applied_hardforks' );
END;
$BODY$
......
......@@ -33,7 +33,7 @@ namespace hive{ namespace plugins{ namespace sql_serializer {
};
transactions_controller = transaction_controllers::build_own_transaction_controller( db_url, "Livesync dumper" );
constexpr auto ONE_THREAD_WRITERS_NUMBER = 3;
constexpr auto ONE_THREAD_WRITERS_NUMBER = 4;
auto NUMBER_OF_PROCESSORS_THREADS = ONE_THREAD_WRITERS_NUMBER + operations_threads + transactions_threads + account_operation_threads;
auto execute_push_block = [this](block_num_rendezvous_trigger::BLOCK_NUM _block_num ){
if ( !_block.empty() ) {
......
......@@ -12,7 +12,7 @@ namespace hive{ namespace plugins{ namespace sql_serializer {
ilog( "Starting reindexing dump to database with ${o} operations and ${t} transactions threads", ("o", operations_threads )("t", transactions_threads) );
_transactions_controller = transaction_controllers::build_own_transaction_controller( db_url, "reindex dumper" );
_end_massive_sync_processor = std::make_unique< end_massive_sync_processor >( db_url );
constexpr auto ONE_THREAD_WRITERS_NUMBER = 3; // a thread for dumping blocks + a thread dumping multisignatures + a thread for accounts
constexpr auto ONE_THREAD_WRITERS_NUMBER = 4; // a thread for dumping blocks + a thread dumping multisignatures + a thread for accounts
auto NUMBER_OF_PROCESSORS_THREADS = ONE_THREAD_WRITERS_NUMBER + operations_threads + transactions_threads + account_operation_threads;
auto execute_end_massive_sync_callback = [this](block_num_rendezvous_trigger::BLOCK_NUM _block_num ){
if ( !_block_num ) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment