Skip to content

Commit

Permalink
Add randomness to broadcast
Browse files Browse the repository at this point in the history
  • Loading branch information
sakridge committed Jan 18, 2019
1 parent 24a9783 commit bbb1c9d
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion src/cluster_info.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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);

Expand Down

0 comments on commit bbb1c9d

Please sign in to comment.