From d135e3b839ccf17f85d4a47284dce52bb82dce66 Mon Sep 17 00:00:00 2001 From: "mergify[bot]" <37929162+mergify[bot]@users.noreply.github.com> Date: Thu, 24 Mar 2022 22:03:33 +0000 Subject: [PATCH] Use QUIC client in voting service (#23713) (#23813) * Use QUIC client in voting service * guard quic-client usage with a flag * add measure to time the quic client * move time measure outside if block * remove quic vs UDP flag from voting service (cherry picked from commit 5d03b188c8c362dd33840ae91feed951905ebfda) Co-authored-by: Pankaj Garg --- core/src/voting_service.rs | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/core/src/voting_service.rs b/core/src/voting_service.rs index 7ab6d9e9e3..4d18c33bec 100644 --- a/core/src/voting_service.rs +++ b/core/src/voting_service.rs @@ -1,6 +1,7 @@ use { crate::tower_storage::{SavedTowerVersions, TowerStorage}, crossbeam_channel::Receiver, + solana_client::connection_cache::get_connection, solana_gossip::cluster_info::ClusterInfo, solana_measure::measure::Measure, solana_poh::poh_recorder::PohRecorder, @@ -86,7 +87,12 @@ impl VotingService { } else { crate::banking_stage::next_leader_tpu(cluster_info, poh_recorder) }; - let _ = cluster_info.send_transaction(vote_op.tx(), target_address); + + let mut measure = Measure::start("vote_tx_send-ms"); + let target_address = target_address.unwrap_or_else(|| cluster_info.my_contact_info().tpu); + let _ = get_connection(&target_address).send_transaction(vote_op.tx()); + measure.stop(); + inc_new_counter_info!("vote_tx_send-ms", measure.as_ms() as usize); match vote_op { VoteOp::PushVote {