Struct AccountsDb

Source

pub struct AccountsDb {Show 20 fields
    pub accounts_index: AccountsIndex<AccountInfo, AccountInfo>,
    pub ancient_append_vec_offset: Option<i64>,
    pub ancient_storage_ideal_size: u64,
    pub max_ancient_storages: usize,
    pub skip_initial_hash_calc: bool,
    pub storage: AccountStorage,
    pub accounts_cache: AccountsCache,
    pub next_id: AtomicAccountsFileId,
    pub shrink_candidate_slots: Mutex<IntSet<Slot>>,
    pub write_version: AtomicU64,
    pub paths: Vec<PathBuf>,
    pub temp_paths: Option<Vec<TempDir>>,
    pub thread_pool_foreground: ThreadPool,
    pub thread_pool_background: ThreadPool,
    pub stats: AccountsStats,
    pub shrink_stats: ShrinkStats,
    pub account_indexes: AccountSecondaryIndexes,
    pub log_dead_slots: AtomicBool,
    pub partitioned_epoch_rewards_config: PartitionedEpochRewardsConfig,
    pub mark_obsolete_accounts: MarkObsoleteAccounts,
    /* private fields */
}

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

Fields§

§accounts_index: AccountsIndex<AccountInfo, AccountInfo>

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

Keeps tracks of index into AppendVec on a per slot basis

§ancient_append_vec_offset: Option<i64>

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

Some(offset) iff we want to squash old append vecs together into ‘ancient append vecs’ Some(offset) means for slots up to (max_slot - (slots_per_epoch - ‘offset’)), put them in ancient append vecs

§ancient_storage_ideal_size: u64

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

§max_ancient_storages: usize

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

§skip_initial_hash_calc: bool

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

true iff we want to skip the initial hash calculation on startup

§storage: AccountStorage

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

§accounts_cache: AccountsCache

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

§next_id: AtomicAccountsFileId

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

distribute the accounts across storage lists

§shrink_candidate_slots: Mutex<IntSet<Slot>>

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

Set of shrinkable stores organized by map of slot to storage id

§write_version: AtomicU64

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

§paths: Vec<PathBuf>

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

Set of storage paths to pick from

§temp_paths: Option<Vec<TempDir>>

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

Directory of paths this accounts_db needs to hold/remove

§thread_pool_foreground: ThreadPool

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

Thread pool for foreground tasks, e.g. transaction processing

§thread_pool_background: ThreadPool

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

Thread pool for background tasks, e.g. AccountsBackgroundService and flush/clean/shrink

§stats: AccountsStats

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

§shrink_stats: ShrinkStats

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

§account_indexes: AccountSecondaryIndexes

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

§log_dead_slots: AtomicBool

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

Used to disable logging dead slots during removal. allow disabling noisy log

§partitioned_epoch_rewards_config: PartitionedEpochRewardsConfig

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

this will live here until the feature for partitioned epoch rewards is activated. At that point, this and other code can be deleted.

§mark_obsolete_accounts: MarkObsoleteAccounts

👎Deprecated since 3.1.0: This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

Flag to indicate if the experimental obsolete account tracking feature is enabled. This feature tracks obsolete accounts in the account storage entry allowing for earlier cleaning of obsolete accounts in the storages and index.

Struct AccountsDb Copy item path

Fields§

Implementations§

impl AccountsDb

pub fn notify_account_at_accounts_update( &self, slot: Slot, account: &AccountSharedData, txn: &Option<&SanitizedTransaction>, pubkey: &Pubkey, write_version: u64, )

impl AccountsDb

pub fn new_with_config( paths: Vec<PathBuf>, accounts_db_config: AccountsDbConfig, accounts_update_notifier: Option<AccountsUpdateNotifier>, exit: Arc<AtomicBool>, ) -> Self

pub fn file_size(&self) -> u64

pub fn get_base_working_path(&self) -> PathBuf

pub fn has_accounts_update_notifier(&self) -> bool

pub fn purge_keys_exact<C>( &self, pubkey_to_slot_set: impl IntoIterator<Item = (Pubkey, C)>, ) -> (ReclaimsSlotList<AccountInfo>, HashSet<Pubkey>)where C: for<'a> Contains<'a, Slot>,

pub fn clean_accounts( &self, max_clean_root_inclusive: Option<Slot>, is_startup: bool, epoch_schedule: &EpochSchedule, )

pub fn get_unique_accounts_from_storage( &self, store: &AccountStorageEntry, ) -> GetUniqueAccountsResult

pub fn mark_dirty_dead_stores( &self, slot: Slot, add_dirty_stores: bool, shrink_in_progress: Option<ShrinkInProgress<'_>>, shrink_can_be_active: bool, ) -> Vec<Arc<AccountStorageEntry>>

pub fn get_store_for_shrink( &self, slot: Slot, size: u64, ) -> ShrinkInProgress<'_>

pub fn shrink_ancient_slots(&self, epoch_schedule: &EpochSchedule)

pub fn shrink_candidate_slots(&self, epoch_schedule: &EpochSchedule) -> usize

pub fn shrink_all_slots( &self, is_startup: bool, epoch_schedule: &EpochSchedule, newest_slot_skip_shrink_inclusive: Option<Slot>, )

pub fn scan_accounts<F>( &self, ancestors: &Ancestors, bank_id: BankId, scan_func: F, config: &ScanConfig, ) -> ScanResult<()>where F: FnMut(Option<(&Pubkey, AccountSharedData, Slot)>),

pub fn index_scan_accounts<F>( &self, ancestors: &Ancestors, bank_id: BankId, index_key: IndexKey, scan_func: F, config: &ScanConfig, ) -> ScanResult<bool>where F: FnMut(Option<(&Pubkey, AccountSharedData, Slot)>),

pub fn scan_cache_storage_fallback<R, B>( &self, slot: Slot, cache_map_func: impl Fn(&LoadedAccount<'_>) -> Option<R> + Sync, storage_fallback_func: impl Fn(&mut B, &AccountsFile) + Sync, ) -> ScanStorageResult<R, B>where R: Send, B: Send + Default + Sync,

pub fn load( &self, ancestors: &Ancestors, pubkey: &Pubkey, load_hint: LoadHint, ) -> Option<(AccountSharedData, Slot)>

pub fn load_account_into_read_cache( &self, ancestors: &Ancestors, pubkey: &Pubkey, )

pub fn load_with_fixed_root( &self, ancestors: &Ancestors, pubkey: &Pubkey, ) -> Option<(AccountSharedData, Slot)>

pub fn load_account_with( &self, ancestors: &Ancestors, pubkey: &Pubkey, should_put_in_read_cache: bool, ) -> Option<(AccountSharedData, Slot)>

pub fn enable_bank_drop_callback(&self)

pub fn purge_slot( &self, slot: Slot, bank_id: BankId, is_serialized_with_abs: bool, )

pub fn purge_slots_from_cache_and_store<'a>( &self, removed_slots: impl Iterator<Item = &'a Slot> + Clone, purge_stats: &PurgeStats, )

pub fn remove_unrooted_slots(&self, remove_slots: &[(Slot, BankId)])

pub fn lt_hash_account( account: &impl ReadableAccount, pubkey: &Pubkey, ) -> AccountLtHash

pub fn mark_slot_frozen(&self, slot: Slot)

pub fn flush_accounts_cache( &self, force_flush: bool, requested_flush_root: Option<Slot>, )

pub fn calculate_accounts_lt_hash_at_startup_from_index( &self, ancestors: &Ancestors, startup_slot: Slot, ) -> AccountsLtHash

pub fn calculate_capitalization_at_startup_from_index( &self, ancestors: &Ancestors, startup_slot: Slot, ) -> u64

pub fn get_pubkeys_for_slot(&self, slot: Slot) -> Vec<Pubkey>

pub fn get_pubkey_account_for_slot( &self, slot: Slot, ) -> Vec<(Pubkey, AccountSharedData)>

pub fn store_accounts_frozen<'a>( &self, accounts: impl StorableAccounts<'a>, storage: &Arc<AccountStorageEntry>, update_index_thread_selection: UpdateIndexThreadSelection, ) -> StoreAccountsTiming

pub fn add_root(&self, slot: Slot) -> AccountsAddRootTiming

pub fn get_storages( &self, requested_slots: impl RangeBounds<Slot> + Sync, ) -> (Vec<Arc<AccountStorageEntry>>, Vec<Slot>)

pub fn latest_full_snapshot_slot(&self) -> Option<Slot>

pub fn set_latest_full_snapshot_slot(&self, slot: Slot)

pub fn generate_index( &self, limit_load_slot_count_from_snapshot: Option<usize>, verify: bool, ) -> IndexGenerationInfo

pub fn print_accounts_stats(&self, label: &str)

pub fn print_count_and_status(&self, label: &str)

Trait Implementations§

impl Debug for AccountsDb

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Auto Trait Implementations§

impl !Freeze for AccountsDb

impl !RefUnwindSafe for AccountsDb

impl Send for AccountsDb

impl Sync for AccountsDb

impl Unpin for AccountsDb

impl !UnwindSafe for AccountsDb

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Policy<B, E>, P: Policy<B, E>,

Struct AccountsDb

pub fn purge_keys_exact<C>( &self, pubkey_to_slot_set: impl IntoIterator<Item = (Pubkey, C)>, ) -> (ReclaimsSlotList<AccountInfo>, HashSet<Pubkey>)
where C: for<'a> Contains<'a, Slot>,

pub fn scan_accounts<F>( &self, ancestors: &Ancestors, bank_id: BankId, scan_func: F, config: &ScanConfig, ) -> ScanResult<()>
where F: FnMut(Option<(&Pubkey, AccountSharedData, Slot)>),

pub fn index_scan_accounts<F>( &self, ancestors: &Ancestors, bank_id: BankId, index_key: IndexKey, scan_func: F, config: &ScanConfig, ) -> ScanResult<bool>
where F: FnMut(Option<(&Pubkey, AccountSharedData, Slot)>),

pub fn scan_cache_storage_fallback<R, B>( &self, slot: Slot, cache_map_func: impl Fn(&LoadedAccount<'_>) -> Option<R> + Sync, storage_fallback_func: impl Fn(&mut B, &AccountsFile) + Sync, ) -> ScanStorageResult<R, B>
where R: Send, B: Send + Default + Sync,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<T> ErasedDestructor for T
where T: 'static,