From da780a3301a51d7c496141a85fcd35014fe6dff5 Mon Sep 17 00:00:00 2001 From: Haoran Yi Date: Mon, 4 Apr 2022 20:27:02 -0500 Subject: [PATCH] debug log --- core/src/validator.rs | 27 +++++++++++++++++++++++++++ 1 file changed, 27 insertions(+) diff --git a/core/src/validator.rs b/core/src/validator.rs index 54cdf11711..dd1f31477b 100644 --- a/core/src/validator.rs +++ b/core/src/validator.rs @@ -1047,21 +1047,26 @@ impl Validator { drop(self.bank_forks); drop(self.cluster_info); + error!("join poh_service"); self.poh_service.join().expect("poh_service"); drop(self.poh_recorder); + error!("join json_rpc_service"); if let Some(json_rpc_service) = self.json_rpc_service { json_rpc_service.join().expect("rpc_service"); } + error!("join pubsub_service"); if let Some(pubsub_service) = self.pubsub_service { pubsub_service.join().expect("pubsub_service"); } + error!("join rpc_completed_slot_service"); self.rpc_completed_slots_service .join() .expect("rpc_completed_slots_service"); + error!("join optimistically_confirmed_bank_tracker"); if let Some(optimistically_confirmed_bank_tracker) = self.optimistically_confirmed_bank_tracker { @@ -1070,66 +1075,88 @@ impl Validator { .expect("optimistically_confirmed_bank_tracker"); } + error!("join transaction_status_service"); if let Some(transaction_status_service) = self.transaction_status_service { transaction_status_service .join() .expect("transaction_status_service"); } + error!("join rewards_recorder_service"); if let Some(rewards_recorder_service) = self.rewards_recorder_service { rewards_recorder_service .join() .expect("rewards_recorder_service"); } + error!("join cache_block_meta_service"); if let Some(cache_block_meta_service) = self.cache_block_meta_service { cache_block_meta_service .join() .expect("cache_block_meta_service"); } + error!("join system_monitor_service"); if let Some(system_monitor_service) = self.system_monitor_service { system_monitor_service .join() .expect("system_monitor_service"); } + error!("join sample_performance_service"); if let Some(sample_performance_service) = self.sample_performance_service { sample_performance_service .join() .expect("sample_performance_service"); } + error!("join snapshot_package_service"); if let Some(s) = self.snapshot_packager_service { s.join().expect("snapshot_packager_service"); } + error!("join gossip_service"); self.gossip_service.join().expect("gossip_service"); + + error!("join serve_repair_service"); self.serve_repair_service .join() .expect("serve_repair_service"); + + error!("join stats_reporter_service"); self.stats_reporter_service .join() .expect("stats_reporter_service"); + + error!("join tpu"); self.tpu.join().expect("tpu"); + + error!("join tvu"); self.tvu.join().expect("tvu"); + + error!("join completed_data_sets_service"); self.completed_data_sets_service .join() .expect("completed_data_sets_service"); + + error!("join ip_echo_server"); if let Some(ip_echo_server) = self.ip_echo_server { ip_echo_server.shutdown_background(); } + error!("join accountsdb_repl_service"); if let Some(accountsdb_repl_service) = self.accountsdb_repl_service { accountsdb_repl_service .join() .expect("accountsdb_repl_service"); } + error!("join geyser_plugin_service"); if let Some(geyser_plugin_service) = self.geyser_plugin_service { geyser_plugin_service.join().expect("geyser_plugin_service"); } + error!("join poh_timing_report_service"); self.poh_timing_report_service .join() .expect("poh_timing_report_service");