Struct solana_runtime::accounts_background_service::SnapshotRequestHandler

pub struct SnapshotRequestHandler {
    pub snapshot_config: SnapshotConfig,
    pub snapshot_request_sender: SnapshotRequestSender,
    pub snapshot_request_receiver: SnapshotRequestReceiver,
    pub accounts_package_sender: Sender<AccountsPackage>,
}

Fields

snapshot_config: SnapshotConfig

snapshot_request_sender: SnapshotRequestSender

snapshot_request_receiver: SnapshotRequestReceiver

accounts_package_sender: Sender<AccountsPackage>

Implementations

impl SnapshotRequestHandler

pub fn handle_snapshot_requests( &self, test_hash_calculation: bool, non_snapshot_time_us: u128, last_full_snapshot_slot: &mut Option<Slot> ) -> Option<Result<u64, SnapshotError>>

fn get_next_snapshot_request( &self, last_full_snapshot_slot: Option<Slot> ) -> Option<(SnapshotRequest, AccountsPackageType, usize, usize)>

Get the next snapshot request to handle

Look through the snapshot request channel to find the highest priority one to handle next. If there are no snapshot requests in the channel, return None. Otherwise return the highest priority one. Unhandled snapshot requests with slots GREATER-THAN the handled one will be re-enqueued. The remaining will be dropped.

Also return the number of snapshot requests initially in the channel, and the number of ones re-enqueued.

fn handle_snapshot_request( &self, test_hash_calculation: bool, non_snapshot_time_us: u128, last_full_snapshot_slot: &mut Option<Slot>, snapshot_request: SnapshotRequest, accounts_package_type: AccountsPackageType ) -> Result<u64, SnapshotError>