Skip to content

Commit

Permalink
bench ONLY spl accounts
Browse files Browse the repository at this point in the history
  • Loading branch information
grooviegermanikus committed May 8, 2024
1 parent 61b202a commit 6ffc8d0
Showing 1 changed file with 9 additions and 20 deletions.
29 changes: 9 additions & 20 deletions examples/bench_geyser_grpc_accounts.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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());
Expand Down Expand Up @@ -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()
}
}
Expand Down

0 comments on commit 6ffc8d0

Please sign in to comment.