diff --git a/local-cluster/src/validator_configs.rs b/local-cluster/src/validator_configs.rs index f8aae532d825b4..437c0bbfaea755 100644 --- a/local-cluster/src/validator_configs.rs +++ b/local-cluster/src/validator_configs.rs @@ -66,6 +66,7 @@ pub fn safe_clone_config(config: &ValidatorConfig) -> ValidatorConfig { wait_to_vote_slot: config.wait_to_vote_slot, ledger_column_options: config.ledger_column_options.clone(), enable_quic_servers: config.enable_quic_servers, + vote_accounts_to_monitor: config.vote_accounts_to_monitor.clone(), } } diff --git a/replica-node/src/main.rs b/replica-node/src/main.rs index 07369ebd635c33..06cf8b2add6153 100644 --- a/replica-node/src/main.rs +++ b/replica-node/src/main.rs @@ -401,6 +401,7 @@ pub fn main() { account_indexes: AccountSecondaryIndexes::default(), accounts_db_caching_enabled: false, replica_exit: Arc::new(RwLock::new(Exit::default())), + vote_accounts_to_monitor: Arc::new(HashSet::default()), }; let replica = ReplicaNode::new(config); diff --git a/replica-node/src/replica_node.rs b/replica-node/src/replica_node.rs index 29ba56cf81f1fb..872d96c985842c 100644 --- a/replica-node/src/replica_node.rs +++ b/replica-node/src/replica_node.rs @@ -1,3 +1,7 @@ +use std::collections::HashSet; + +use solana_sdk::pubkey::Pubkey; + use { crate::accountsdb_repl_service::AccountsDbReplService, crossbeam_channel::unbounded, @@ -58,6 +62,7 @@ pub struct ReplicaNodeConfig { pub accounts_db_caching_enabled: bool, pub replica_exit: Arc>, pub socket_addr_space: SocketAddrSpace, + pub vote_accounts_to_monitor: Arc>, } pub struct ReplicaNode { @@ -251,6 +256,7 @@ fn start_client_rpc_services( leader_schedule_cache.clone(), connection_cache, max_complete_transaction_status_slot, + replica_config.vote_accounts_to_monitor.clone(), )), Some(pubsub_service), Some(OptimisticallyConfirmedBankTracker::new(