diff --git a/src/fullnode.rs b/src/fullnode.rs index d0dc2718db..c72cf22ef1 100644 --- a/src/fullnode.rs +++ b/src/fullnode.rs @@ -166,7 +166,7 @@ impl FullNode { thread_hdls.extend(rpu.thread_hdls); let blob_recycler = BlobRecycler::default(); - let tpu = Tpu::new( + let (tpu, blob_receiver) = Tpu::new( bank.clone(), tick_duration, transactions_socket, @@ -195,7 +195,7 @@ impl FullNode { window, entry_height, blob_recycler.clone(), - tpu.blob_receiver, + blob_receiver, ); thread_hdls.extend(vec![t_broadcast]);