Skip to content

Commit

Permalink
Revert "report udp stats from validator (solana-labs#20587)"
Browse files Browse the repository at this point in the history
This reverts commit 46133b6.
  • Loading branch information
frits-metalogix authored Nov 24, 2021
1 parent dad1133 commit 1ae614e
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 243 deletions.
1 change: 0 additions & 1 deletion core/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,6 @@ pub mod sigverify;
pub mod sigverify_shreds;
pub mod sigverify_stage;
pub mod snapshot_packager_service;
pub mod system_monitor_service;
pub mod test_validator;
pub mod tower_storage;
pub mod tpu;
Expand Down
227 changes: 0 additions & 227 deletions core/src/system_monitor_service.rs

This file was deleted.

15 changes: 0 additions & 15 deletions core/src/validator.rs
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@ use {
serve_repair_service::ServeRepairService,
sigverify,
snapshot_packager_service::SnapshotPackagerService,
system_monitor_service::{verify_udp_stats_access, SystemMonitorService},
tower_storage::TowerStorage,
tpu::{Tpu, DEFAULT_TPU_COALESCE_MS},
tvu::{Sockets, Tvu, TvuConfig},
Expand Down Expand Up @@ -276,7 +275,6 @@ pub struct Validator {
transaction_status_service: Option<TransactionStatusService>,
rewards_recorder_service: Option<RewardsRecorderService>,
cache_block_meta_service: Option<CacheBlockMetaService>,
system_monitor_service: Option<SystemMonitorService>,
sample_performance_service: Option<SamplePerformanceService>,
gossip_service: GossipService,
serve_repair_service: ServeRepairService,
Expand Down Expand Up @@ -450,12 +448,6 @@ impl Validator {

*start_progress.write().unwrap() = ValidatorStartProgress::StartingServices;

verify_udp_stats_access().unwrap_or_else(|err| {
error!("Failed to access UDP stats: {}", err);
abort();
});
let system_monitor_service = Some(SystemMonitorService::new(Arc::clone(&exit)));

let leader_schedule_cache = Arc::new(leader_schedule_cache);
let bank = bank_forks.working_bank();
if let Some(ref shrink_paths) = config.account_shrink_paths {
Expand Down Expand Up @@ -880,7 +872,6 @@ impl Validator {
transaction_status_service,
rewards_recorder_service,
cache_block_meta_service,
system_monitor_service,
sample_performance_service,
snapshot_packager_service,
completed_data_sets_service,
Expand Down Expand Up @@ -975,12 +966,6 @@ impl Validator {
.expect("cache_block_meta_service");
}

if let Some(system_monitor_service) = self.system_monitor_service {
system_monitor_service
.join()
.expect("system_monitor_service");
}

if let Some(sample_performance_service) = self.sample_performance_service {
sample_performance_service
.join()
Expand Down

0 comments on commit 1ae614e

Please sign in to comment.