blockworks-foundation
/
solana
mirror of https://github.com/blockworks-foundation/solana.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

log initialization of notifiers

This commit is contained in:
steve-gg 2024-04-10 13:27:14 +02:00
parent d3e5206055
commit e3117fe41b
No known key found for this signature in database
GPG Key ID: 5B6EB831A5CD2015
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
geyser-plugin-manager/src/geyser_plugin_service.rs
View File

@ -90,23 +90,29 @@ impl GeyserPluginService {
if account_data_notifications_enabled {
let accounts_update_notifier =
AccountsUpdateNotifierImpl::new(plugin_manager.clone());
info!("Starting AccountsUpdateNotifierImpl");
Some(Arc::new(RwLock::new(accounts_update_notifier)))
} else {
info!("Disable AccountsUpdateNotifierImpl");
None
};
let transaction_notifier: Option<TransactionNotifierLock> =
if transaction_notifications_enabled {
let transaction_notifier = TransactionNotifierImpl::new(plugin_manager.clone());
info!("Starting TransactionNotifierImpl");
Some(Arc::new(RwLock::new(transaction_notifier)))
} else {
info!("Disable TransactionNotifierImpl");
None
};
let entry_notifier: Option<EntryNotifierLock> = if entry_notifications_enabled {
let entry_notifier = EntryNotifierImpl::new(plugin_manager.clone());
info!("Starting EntryNotifierImpl");
Some(Arc::new(RwLock::new(entry_notifier)))
} else {
info!("Disable EntryNotifierImpl");
None
};
@ -117,6 +123,7 @@ impl GeyserPluginService {
|| transaction_notifications_enabled
|| entry_notifications_enabled
{
info!("Starting SlotStatusObserver");
let slot_status_notifier = SlotStatusNotifierImpl::new(plugin_manager.clone());
let slot_status_notifier = Arc::new(RwLock::new(slot_status_notifier));
(
@ -129,6 +136,7 @@ impl GeyserPluginService {
)))),
)
} else {
info!("Disable SlotStatusObserver");
(None, None)
};