Skip to content
Snippets Groups Projects

issue #223: correctly detect if reversible data have to be removed after hived restart

Closed issue #223: correctly detect if reversible data have to be removed after hived restart
Closed Marcin requested to merge mi_investigate_restart_with_app into develop
Compare and Show latest version
1 file
+ 2
0
Compare changes
  • Side-by-side
  • Inline
@@ -155,7 +155,7 @@ namespace hive{ namespace plugins{ namespace sql_serializer {
}
void livesync_data_dumper::on_switch_fork( uint32_t block_num ) {
_processing_thread.enqueue("SELECT hive.back_from_fork(" + std::to_string(block_num) + ")");
_processing_thread.enqueue("SELECT hive.back_from_fork(" + std::to_string(block_num) + ")");
}
void livesync_data_dumper::connect_irreversible_event() {
@@ -232,6 +232,8 @@ namespace hive{ namespace plugins{ namespace sql_serializer {
ilog("Dumping wal as part of shutdown");
command_to_run = std::move(_command_queue.front());
if (_shutdown_requested)
ilog("Dumping wal as part of shutdown ${c}", ("c", command_to_run));
_command_queue.pop_front();
commands_remaining = _command_queue.size();
}
Loading