diff --git a/core/src/broadcast_stage.rs b/core/src/broadcast_stage.rs index a869ed4e05..dd763dbbb0 100644 --- a/core/src/broadcast_stage.rs +++ b/core/src/broadcast_stage.rs @@ -127,23 +127,19 @@ impl Broadcast { let bank_epoch = bank.get_stakers_epoch(bank.slot()); let stakes = staking_utils::staked_nodes_at_epoch(&bank, bank_epoch); - if let Some(nodes) = stakes.as_ref() { - if nodes.len() > 1 { - // Send out data - cluster_info - .read() - .unwrap() - .broadcast(sock, &blobs, stakes.as_ref())?; + // Send out data + cluster_info + .read() + .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 - cluster_info - .read() - .unwrap() - .broadcast(sock, &coding, stakes.as_ref())?; - } - } + // send out erasures + cluster_info + .read() + .unwrap() + .broadcast(sock, &coding, stakes.as_ref())?; self.update_broadcast_stats( duration_as_ms(&broadcast_start.elapsed()),