Plumb EntryNotfierSender into Tpu

solana-labs · Apr 20, 2023 · 4cd8b61 · 4cd8b61
1 parent 0e0bf05
commit 4cd8b61
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/core/src/tpu.rs b/core/src/tpu.rs
@@ -19,7 +19,10 @@ use {
     crossbeam_channel::{unbounded, Receiver},
     solana_client::connection_cache::ConnectionCache,
     solana_gossip::cluster_info::ClusterInfo,
-    solana_ledger::{blockstore::Blockstore, blockstore_processor::TransactionStatusSender},
+    solana_ledger::{
+        blockstore::Blockstore, blockstore_processor::TransactionStatusSender,
+        entry_notifier_service::EntryNotifierSender,
+    },
     solana_poh::poh_recorder::{PohRecorder, WorkingBankEntry},
     solana_rpc::{
         optimistically_confirmed_bank_tracker::BankNotificationSender,
@@ -80,6 +83,7 @@ impl Tpu {
         sockets: TpuSockets,
         subscriptions: &Arc<RpcSubscriptions>,
         transaction_status_sender: Option<TransactionStatusSender>,
+        _entry_notification_sender: Option<EntryNotifierSender>,
         blockstore: &Arc<Blockstore>,
         broadcast_type: &BroadcastStageType,
         exit: &Arc<AtomicBool>,

diff --git a/core/src/validator.rs b/core/src/validator.rs
@@ -1150,6 +1150,7 @@ impl Validator {
             },
             &rpc_subscriptions,
             transaction_status_sender,
+            entry_notification_sender.clone(),
             &blockstore,
             &config.broadcast_stage_type,
             &exit,