gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Broadcast blobs even if the peers have no stake (#4597)

Browse Source
This commit is contained in:
Pankaj Garg
2019-06-07 14:12:27 -07:00
committed by GitHub
parent b55927370b
commit ac6dbf8f04
1 changed files with 11 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
core/src/broadcast_stage.rs
View File

@ -127,23 +127,19 @@ impl Broadcast {
let bank_epoch = bank.get_stakers_epoch(bank.slot()); let bank_epoch = bank.get_stakers_epoch(bank.slot());
let stakes = staking_utils::staked_nodes_at_epoch(&bank, bank_epoch); let stakes = staking_utils::staked_nodes_at_epoch(&bank, bank_epoch);
if let Some(nodes) = stakes.as_ref() { // Send out data
if nodes.len() > 1 { cluster_info
// Send out data .read()
cluster_info .unwrap()
.read() .broadcast(sock, &blobs, stakes.as_ref())?;
.unwrap()
.broadcast(sock, &blobs, stakes.as_ref())?;
inc_new_counter_debug!("streamer-broadcast-sent", blobs.len()); inc_new_counter_debug!("streamer-broadcast-sent", blobs.len());
// send out erasures // send out erasures
cluster_info cluster_info
.read() .read()
.unwrap() .unwrap()
.broadcast(sock, &coding, stakes.as_ref())?; .broadcast(sock, &coding, stakes.as_ref())?;
}
}
self.update_broadcast_stats( self.update_broadcast_stats(
duration_as_ms(&broadcast_start.elapsed()), duration_as_ms(&broadcast_start.elapsed()),