From 6ffc8d0f0d95260b1deaae054a1f9ea3ce72aa73 Mon Sep 17 00:00:00 2001 From: GroovieGermanikus Date: Wed, 8 May 2024 16:15:20 +0200 Subject: [PATCH] bench ONLY spl accounts --- examples/bench_geyser_grpc_accounts.rs | 29 ++++++++------------------ 1 file changed, 9 insertions(+), 20 deletions(-) diff --git a/examples/bench_geyser_grpc_accounts.rs b/examples/bench_geyser_grpc_accounts.rs index 1fa277b..d3fa11a 100644 --- a/examples/bench_geyser_grpc_accounts.rs +++ b/examples/bench_geyser_grpc_accounts.rs @@ -68,20 +68,20 @@ pub async fn main() { // exit_notify.resubscribe(), // ); - let _all_accounts = create_geyser_autoconnection_task_with_mpsc( - config.clone(), - all_accounts(), - autoconnect_tx.clone(), - exit_notify.resubscribe(), - ); - - // let _token_accounts_task = create_geyser_autoconnection_task_with_mpsc( + // let _all_accounts = create_geyser_autoconnection_task_with_mpsc( // config.clone(), - // token_accounts(), + // all_accounts(), // autoconnect_tx.clone(), // exit_notify.resubscribe(), // ); + let _token_accounts_task = create_geyser_autoconnection_task_with_mpsc( + config.clone(), + token_accounts(), + autoconnect_tx.clone(), + exit_notify.resubscribe(), + ); + let current_processed_slot = AtomicSlot::default(); start_tracking_slots(current_processed_slot.clone()); start_tracking_account_consumer(geyser_messages_rx, current_processed_slot.clone()); @@ -282,19 +282,8 @@ pub fn token_accounts() -> SubscribeRequest { }, ); - - let mut slots_subs = HashMap::new(); - slots_subs.insert("client".to_string(), SubscribeRequestFilterSlots { - filter_by_commitment: Some(true), - }); - - let mut blocks_meta_subs = HashMap::new(); - blocks_meta_subs.insert("client".to_string(), SubscribeRequestFilterBlocksMeta {}); - SubscribeRequest { - slots: slots_subs, accounts: accounts_subs, - blocks_meta: blocks_meta_subs, ..Default::default() } }