From e1d5bb1a269085e73f785f540255c4df0587e6cb Mon Sep 17 00:00:00 2001 From: Rob Walker Date: Thu, 11 Apr 2019 09:15:17 -0700 Subject: [PATCH] add redundant broadcast (#3724) * add redundant broadcast * crank up to full redundancy * Update broadcast_stage.rs * Update broadcast_stage.rs * Update broadcast_stage.rs * Update broadcast_stage.rs --- core/src/broadcast_stage.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/core/src/broadcast_stage.rs b/core/src/broadcast_stage.rs index ea26a7e06e..b1070f6dbf 100644 --- a/core/src/broadcast_stage.rs +++ b/core/src/broadcast_stage.rs @@ -128,7 +128,9 @@ impl Broadcast { inc_new_counter_info!("streamer-broadcast-sent", blobs.len()); - // Fill in the coding blob data from the window data blobs + // generate and transmit any erasure coding blobs. if erasure isn't supported, just send everything again + #[cfg(not(feature = "erasure"))] + ClusterInfo::broadcast(&self.id, contains_last_tick, &broadcast_table, sock, &blobs)?; #[cfg(feature = "erasure")] { let coding = self.coding_generator.next(&blobs)?;