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;