From 2f1107ff4ffcaccd7cd4eede8e09cfac1166e7e6 Mon Sep 17 00:00:00 2001 From: Stephen Akridge Date: Thu, 17 Jan 2019 14:41:48 -0800 Subject: [PATCH] Add randomness to broadcast --- src/cluster_info.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/cluster_info.rs b/src/cluster_info.rs index 089360233..cff5d04d0 100644 --- a/src/cluster_info.rs +++ b/src/cluster_info.rs @@ -637,8 +637,9 @@ impl ClusterInfo { let mut orders = Vec::with_capacity(blobs.len()); + let x = thread_rng().gen_range(0, broadcast_table.len()); for (i, blob) in blobs.iter().enumerate() { - let br_idx = i % broadcast_table.len(); + let br_idx = (x + i) % broadcast_table.len(); trace!("broadcast order data br_idx {}", br_idx);