blockworks-foundation
/
solana
mirror of https://github.com/blockworks-foundation/solana.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Rename ClusterInfo::send_vote to ClusterInfo::send_transaction

This commit is contained in:
Michael Vines 2021-07-07 11:14:10 -07:00
parent f04340b125
commit 1e0942e900
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/replay_stage.rs
View File

@ -1562,7 +1562,7 @@ impl ReplayStage {
("target_bank_slot", heaviest_bank_on_same_fork.slot(), i64), ("target_bank_slot", heaviest_bank_on_same_fork.slot(), i64),
("target_bank_hash", hash_string, String), ("target_bank_hash", hash_string, String),
); );
let _ = cluster_info.send_vote( let _ = cluster_info.send_transaction(
&vote_tx, &vote_tx,
crate::banking_stage::next_leader_tpu(cluster_info, poh_recorder), crate::banking_stage::next_leader_tpu(cluster_info, poh_recorder),
); );
@ -1601,7 +1601,7 @@ impl ReplayStage {
if let Some(vote_tx) = vote_tx { if let Some(vote_tx) = vote_tx {
tower.refresh_last_vote_tx_blockhash(vote_tx.message.recent_blockhash); tower.refresh_last_vote_tx_blockhash(vote_tx.message.recent_blockhash);
let mut send_time = Measure::start("send_vote"); let mut send_time = Measure::start("send_vote");
let _ = cluster_info.send_vote( let _ = cluster_info.send_transaction(
&vote_tx, &vote_tx,
crate::banking_stage::next_leader_tpu(cluster_info, poh_recorder), crate::banking_stage::next_leader_tpu(cluster_info, poh_recorder),
); );

6
gossip/src/cluster_info.rs
View File

@ -1121,13 +1121,13 @@ impl ClusterInfo {
} }
} }
pub fn send_vote( pub fn send_transaction(
&self, &self,
vote: &Transaction, transaction: &Transaction,
tpu: Option<SocketAddr>, tpu: Option<SocketAddr>,
) -> Result<(), GossipError> { ) -> Result<(), GossipError> {
let tpu = tpu.unwrap_or_else(|| self.my_contact_info().tpu); let tpu = tpu.unwrap_or_else(|| self.my_contact_info().tpu);
let buf = serialize(vote)?; let buf = serialize(transaction)?;
self.socket.send_to(&buf, &tpu)?; self.socket.send_to(&buf, &tpu)?;
Ok(()) Ok(())
} }