More logging around irreversible signal

AntelopeIO · Apr 3, 2024 · d513582 · d513582
1 parent 08ce170
commit d513582
Show file tree

Hide file tree

Showing 6 changed files with 16 additions and 0 deletions.
diff --git a/libraries/chain/controller.cpp b/libraries/chain/controller.cpp
@@ -1196,8 +1196,10 @@ struct controller_impl {
       set_activation_handler<builtin_protocol_feature_t::instant_finality>();
 
       irreversible_block.connect([this](const block_signal_params& t) {
+         dlog("on irreversible");
          const auto& [ block, id] = t;
          wasmif.current_lib(block->block_num());
+         dlog("wasmif current_lib done");
       });
 
 

diff --git a/plugins/chain_plugin/chain_plugin.cpp b/plugins/chain_plugin/chain_plugin.cpp
@@ -1041,14 +1041,20 @@ void chain_plugin_impl::plugin_initialize(const variables_map& options) {
          const auto& [ block, id ] = t;
 
          if (_trx_retry_db) {
+            dlog("trx retry on_irreversible_block");
             _trx_retry_db->on_irreversible_block(block);
+            dlog("trx retry on_irreversible_block done");
          }
 
          if (_trx_finality_status_processing) {
+            dlog("trx finality status on_irreversible_block");
             _trx_finality_status_processing->signal_irreversible_block(block, id);
+            dlog("trx finality status on_irreversible_block done");
          }
 
+         dlog("irreversible_block_channel.publish");
          irreversible_block_channel.publish( priority::low, t );
+         dlog("irreversible_block_channel.publish done");
       } );
 
       applied_transaction_connection = chain->applied_transaction().connect(

diff --git a/plugins/net_plugin/net_plugin.cpp b/plugins/net_plugin/net_plugin.cpp
@@ -4421,8 +4421,10 @@ namespace eosio {
             my->on_accepted_block();
          } );
          cc.irreversible_block().connect( [my = shared_from_this()]( const block_signal_params& t ) {
+            dlog("on_irreversible_block");
             const auto& [ block, id ] = t;
             my->on_irreversible_block( id, block->block_num() );
+            dlog("on_irreversible_block done");
          } );
 
          cc.voted_block().connect( [my = shared_from_this()]( const vote_message& vote ) {

diff --git a/plugins/producer_plugin/producer_plugin.cpp b/plugins/producer_plugin/producer_plugin.cpp
@@ -1367,8 +1367,10 @@ void producer_plugin_impl::plugin_startup() {
             on_block_header(block->producer, block->block_num(), block->timestamp);
          }));
          _irreversible_block_connection.emplace(chain.irreversible_block().connect([this](const block_signal_params& t) {
+            dlog("on_irreversible_block");
             const auto& [ block, id ] = t;
             on_irreversible_block(block);
+            dlog("on_irreversible_block done");
          }));
 
          _block_start_connection.emplace(chain.block_start().connect([this, &chain](uint32_t bs) {

diff --git a/plugins/test_control_plugin/test_control_plugin.cpp b/plugins/test_control_plugin/test_control_plugin.cpp
@@ -33,8 +33,10 @@ class test_control_plugin_impl {
 void test_control_plugin_impl::connect() {
    _irreversible_block_connection.emplace(
          _chain.irreversible_block().connect( [&]( const chain::block_signal_params& t ) {
+            dlog("on_irreversible_block");
             const auto& [ block, id ] = t;
             applied_irreversible_block( id );
+            dlog("on_irreversible_block done");
          } ));
    _accepted_block_connection =
          _chain.accepted_block().connect( [&]( const chain::block_signal_params& t ) {

diff --git a/plugins/trace_api_plugin/trace_api_plugin.cpp b/plugins/trace_api_plugin/trace_api_plugin.cpp
@@ -386,10 +386,12 @@ struct trace_api_plugin_impl {
 
       irreversible_block_connection.emplace(
          chain.irreversible_block().connect([this](const chain::block_signal_params& t) {
+            dlog("on_irreversible_block");
             const auto& [ block, id ] = t;
             emit_killer([&](){
                extraction->signal_irreversible_block(block->block_num());
             });
+            dlog("on_irreversible_block done");
          }));
 
    }