Skip to content
This repository has been archived by the owner on Jan 13, 2025. It is now read-only.

RPC Notifier Signal when Setup Complete #27481

Merged
merged 2 commits into from
Sep 1, 2022
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 5 additions & 2 deletions rpc/src/rpc_subscriptions.rs
Original file line number Diff line number Diff line change
Expand Up @@ -573,15 +573,18 @@ impl RpcSubscriptions {
let blockstore = Blockstore::open(&ledger_path).unwrap();
let blockstore = Arc::new(blockstore);

Self::new_with_config(
let rpc_subscriptions = Self::new_with_config(
exit,
max_complete_transaction_status_slot,
blockstore,
bank_forks,
block_commitment_cache,
optimistically_confirmed_bank,
&PubSubConfig::default_for_tests(),
)
);
// Ensure RPC notifier is ready to receive notifications before proceeding
bw-solana marked this conversation as resolved.
Show resolved Hide resolved
std::thread::sleep(Duration::from_millis(100));
rpc_subscriptions
}

pub fn new_for_tests_with_blockstore(
Expand Down