diff --git a/core/src/validator.rs b/core/src/validator.rs index e38163cf6b..3159afbdab 100644 --- a/core/src/validator.rs +++ b/core/src/validator.rs @@ -1,89 +1,5 @@ //! The `validator` module hosts all the validator microservices. -<<<<<<< HEAD -use crate::{ - broadcast_stage::BroadcastStageType, - cache_block_meta_service::{CacheBlockMetaSender, CacheBlockMetaService}, - cluster_info_vote_listener::VoteTracker, - completed_data_sets_service::CompletedDataSetsService, - consensus::{reconcile_blockstore_roots_with_tower, Tower}, - rewards_recorder_service::{RewardsRecorderSender, RewardsRecorderService}, - sample_performance_service::SamplePerformanceService, - serve_repair::ServeRepair, - serve_repair_service::ServeRepairService, - sigverify, - snapshot_packager_service::{PendingSnapshotPackage, SnapshotPackagerService}, - tpu::{Tpu, DEFAULT_TPU_COALESCE_MS}, - tvu::{Sockets, Tvu, TvuConfig}, -}; -use crossbeam_channel::{bounded, unbounded}; -use rand::{thread_rng, Rng}; -use solana_gossip::{ - cluster_info::{ - ClusterInfo, Node, DEFAULT_CONTACT_DEBUG_INTERVAL_MILLIS, - DEFAULT_CONTACT_SAVE_INTERVAL_MILLIS, - }, - contact_info::ContactInfo, - gossip_service::GossipService, -}; -use solana_ledger::{ - bank_forks_utils, - blockstore::{Blockstore, BlockstoreSignals, CompletedSlotsReceiver, PurgeType}, - blockstore_db::BlockstoreRecoveryMode, - blockstore_processor::{self, TransactionStatusSender}, - leader_schedule::FixedSchedule, - leader_schedule_cache::LeaderScheduleCache, - poh::compute_hash_time_ns, -}; -use solana_measure::measure::Measure; -use solana_metrics::datapoint_info; -use solana_poh::{ - poh_recorder::{PohRecorder, GRACE_TICKS_FACTOR, MAX_GRACE_SLOTS}, - poh_service::{self, PohService}, -}; -use solana_rpc::{ - max_slots::MaxSlots, - optimistically_confirmed_bank_tracker::{ - OptimisticallyConfirmedBank, OptimisticallyConfirmedBankTracker, - }, - rpc::JsonRpcConfig, - rpc_pubsub_service::{PubSubConfig, PubSubService}, - rpc_service::JsonRpcService, - rpc_subscriptions::RpcSubscriptions, - transaction_status_service::TransactionStatusService, -}; -use solana_runtime::{ - accounts_db::AccountShrinkThreshold, - accounts_index::AccountSecondaryIndexes, - bank::Bank, - bank_forks::{BankForks, SnapshotConfig}, - commitment::BlockCommitmentCache, - hardened_unpack::{open_genesis_config, MAX_GENESIS_ARCHIVE_UNPACKED_SIZE}, -}; -use solana_sdk::{ - clock::Slot, - epoch_schedule::MAX_LEADER_SCHEDULE_EPOCH_OFFSET, - exit::Exit, - genesis_config::GenesisConfig, - hash::Hash, - pubkey::Pubkey, - shred_version::compute_shred_version, - signature::{Keypair, Signer}, - timing::timestamp, -}; -use solana_streamer::socket::SocketAddrSpace; -use solana_vote_program::vote_state::VoteState; -use std::{ - collections::HashSet, - net::SocketAddr, - ops::Deref, - path::{Path, PathBuf}, - sync::atomic::{AtomicBool, AtomicU64, Ordering}, - sync::mpsc::Receiver, - sync::{Arc, Mutex, RwLock}, - thread::{sleep, Builder}, - time::{Duration, Instant}, -======= use { crate::{ broadcast_stage::BroadcastStageType, @@ -91,20 +7,17 @@ use { cluster_info_vote_listener::VoteTracker, completed_data_sets_service::CompletedDataSetsService, consensus::{reconcile_blockstore_roots_with_tower, Tower}, - cost_model::CostModel, rewards_recorder_service::{RewardsRecorderSender, RewardsRecorderService}, sample_performance_service::SamplePerformanceService, serve_repair::ServeRepair, serve_repair_service::ServeRepairService, sigverify, snapshot_packager_service::{PendingSnapshotPackage, SnapshotPackagerService}, - tower_storage::TowerStorage, tpu::{Tpu, DEFAULT_TPU_COALESCE_MS}, tvu::{Sockets, Tvu, TvuConfig}, }, crossbeam_channel::{bounded, unbounded}, rand::{thread_rng, Rng}, - solana_entry::poh::compute_hash_time_ns, solana_gossip::{ cluster_info::{ ClusterInfo, Node, DEFAULT_CONTACT_DEBUG_INTERVAL_MILLIS, @@ -121,6 +34,7 @@ use { blockstore_processor::{self, TransactionStatusSender}, leader_schedule::FixedSchedule, leader_schedule_cache::LeaderScheduleCache, + poh::compute_hash_time_ns, }, solana_measure::measure::Measure, solana_metrics::datapoint_info, @@ -134,7 +48,6 @@ use { OptimisticallyConfirmedBank, OptimisticallyConfirmedBankTracker, }, rpc::JsonRpcConfig, - rpc_completed_slots_service::RpcCompletedSlotsService, rpc_pubsub_service::{PubSubConfig, PubSubService}, rpc_service::JsonRpcService, rpc_subscriptions::RpcSubscriptions, @@ -144,12 +57,9 @@ use { accounts_db::AccountShrinkThreshold, accounts_index::AccountSecondaryIndexes, bank::Bank, - bank_forks::BankForks, + bank_forks::{BankForks, SnapshotConfig}, commitment::BlockCommitmentCache, hardened_unpack::{open_genesis_config, MAX_GENESIS_ARCHIVE_UNPACKED_SIZE}, - snapshot_archive_info::SnapshotArchiveInfoGetter, - snapshot_config::SnapshotConfig, - snapshot_utils, }, solana_sdk::{ clock::Slot, @@ -174,10 +84,9 @@ use { mpsc::Receiver, Arc, Mutex, RwLock, }, - thread::{sleep, Builder, JoinHandle}, + thread::{sleep, Builder}, time::{Duration, Instant}, }, ->>>>>>> 7a789e076 (filters for recent contact-infos when checking for live stake (#19204)) }; const MAX_COMPLETED_DATA_SETS_IN_CHANNEL: usize = 100_000;