diff --git a/core/src/validator.rs b/core/src/validator.rs index 7d40ce2c8c4b5c..571d5e852a257d 100644 --- a/core/src/validator.rs +++ b/core/src/validator.rs @@ -1024,7 +1024,7 @@ impl Validator { let staked_nodes = Arc::new(RwLock::new(StakedNodes::default())); // ConnectionCache might be used for JsonRpc and for Forwarding. Since - // the later is not migrated yet to the tpu-client-next, create + // the latter is not migrated yet to the tpu-client-next, create // ConnectionCache regardless of config.use_tpu_client_next for now. let connection_cache = if use_quic { let connection_cache = ConnectionCache::new_with_client_options( @@ -1635,10 +1635,9 @@ impl Validator { *start_progress.write().unwrap() = ValidatorStartProgress::Running; if let Some(client_updater) = client_updater { key_notifies.push(client_updater); - } else { - // add connection_cache because it is still used in Forwarder. - key_notifies.push(connection_cache); } + // add connection_cache because it is still used in Forwarder. + key_notifies.push(connection_cache); *admin_rpc_service_post_init.write().unwrap() = Some(AdminRpcRequestMetadataPostInit { bank_forks: bank_forks.clone(), diff --git a/rpc/src/rpc.rs b/rpc/src/rpc.rs index c0e3f63ca7acc6..f7637539f5b531 100644 --- a/rpc/src/rpc.rs +++ b/rpc/src/rpc.rs @@ -379,6 +379,10 @@ impl JsonRpcRequestProcessor { let (transaction_sender, transaction_receiver) = unbounded(); let client = Client::create_client(runtime, my_tpu_address, None, 1); + assert!( + client.protocol() == Protocol::QUIC, + "UDP is not supported by this test." + ); SendTransactionService::new( &bank_forks, transaction_receiver, @@ -6528,6 +6532,10 @@ pub mod tests { Arc::new(PrioritizationFeeCache::default()), ); let client = C::create_client(maybe_runtime, my_tpu_address, None, 1); + assert!( + client.protocol() == Protocol::QUIC, + "UDP is not supported by this test." + ); SendTransactionService::new(&bank_forks, receiver, client, 1000, exit.clone()); let mut bad_transaction = system_transaction::transfer( @@ -6799,6 +6807,10 @@ pub mod tests { Arc::new(PrioritizationFeeCache::default()), ); let client = C::create_client(maybe_runtime, my_tpu_address, None, 1); + assert!( + client.protocol() == Protocol::QUIC, + "UDP is not supported by this test." + ); SendTransactionService::new(&bank_forks, receiver, client, 1000, exit); assert_eq!(