From d95e8030fc967cf7c297e1763166155da4f9d8c4 Mon Sep 17 00:00:00 2001 From: Rob Walker Date: Tue, 26 Jun 2018 14:35:28 -0700 Subject: [PATCH] ... --- src/server.rs | 1 + src/streamer.rs | 5 +++-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/src/server.rs b/src/server.rs index ff9cad087d..50f976c44b 100644 --- a/src/server.rs +++ b/src/server.rs @@ -91,6 +91,7 @@ impl Server { window, blob_recycler.clone(), tpu.blob_receiver, + bank.entry_count(), ); thread_hdls.extend(vec![t_broadcast]); diff --git a/src/streamer.rs b/src/streamer.rs index 039647bff7..159a18910b 100644 --- a/src/streamer.rs +++ b/src/streamer.rs @@ -533,12 +533,13 @@ pub fn broadcaster( window: Window, recycler: BlobRecycler, r: BlobReceiver, + entry_count: usize, ) -> JoinHandle<()> { Builder::new() .name("solana-broadcaster".to_string()) .spawn(move || { - let mut transmit_index = 0; - let mut receive_index = 0; + let mut transmit_index = entry_count as u64; + let mut receive_index = entry_count as u64; loop { if exit.load(Ordering::Relaxed) { break;