pub struct AccountsIndex<T: IndexValue> {
    pub account_maps: Vec<AccountMap<T>>,
    pub bin_calculator: PubkeyBinCalculator24,
    pub removed_bank_ids: Mutex<HashSet<BankId>>,
    pub scan_results_limit_bytes: Option<usize>,
    pub roots_added: AtomicUsize,
    pub roots_removed: AtomicUsize,
    pub active_scans: AtomicUsize,
    pub max_distance_to_min_scan_slot: AtomicU64,
    pub rent_paying_accounts_by_partition: OnceCell<RentPayingAccountsByPartition>,
    /* private fields */
}

Fields§

§account_maps: Vec<AccountMap<T>>§bin_calculator: PubkeyBinCalculator24§removed_bank_ids: Mutex<HashSet<BankId>>§scan_results_limit_bytes: Option<usize>

when a scan’s accumulated data exceeds this limit, abort the scan

§roots_added: AtomicUsize§roots_removed: AtomicUsize§active_scans: AtomicUsize§max_distance_to_min_scan_slot: AtomicU64§rent_paying_accounts_by_partition: OnceCell<RentPayingAccountsByPartition>

populated at generate_index time - accounts that could possibly be rent paying

Implementations§

source§

impl<T: IndexValue> AccountsIndex<T>

source

pub fn default_for_tests() -> Self

source

pub fn new(config: Option<AccountsIndexConfig>) -> Self

source

pub fn is_disk_index_enabled(&self) -> bool

is the accounts index using disk as a backing store

source

pub fn get_account_read_entry( &self, pubkey: &Pubkey ) -> Option<ReadAccountMapEntry<T>>

source

pub fn get_account_read_entry_with_lock( &self, pubkey: &Pubkey, lock: &&'_ AccountMap<T> ) -> Option<ReadAccountMapEntry<T>>

source

pub fn handle_dead_keys( &self, dead_keys: &[&Pubkey], account_indexes: &AccountSecondaryIndexes ) -> HashSet<Pubkey>

Remove keys from the account index if the key’s slot list is empty. Returns the keys that were removed from the index. These keys should not be accessed again in the current code path.

source

pub fn get_rooted_entries( &self, slice: SlotSlice<'_, T>, max: Option<Slot> ) -> SlotList<T>

source

pub fn roots_and_ref_count( &self, locked_account_entry: &ReadAccountMapEntry<T>, max: Option<Slot> ) -> (SlotList<T>, RefCount)

source

pub fn purge_exact<'a, C>( &'a self, pubkey: &Pubkey, slots_to_purge: &'a C, reclaims: &mut SlotList<T> ) -> boolwhere C: Contains<'a, Slot>,

source

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

source

pub fn hold_range_in_memory<R>( &self, range: &R, start_holding: bool, thread_pool: &ThreadPool )where R: RangeBounds<Pubkey> + Debug + Sync,

source

pub fn set_startup(&self, value: Startup)

source

pub fn get_startup_remaining_items_to_flush_estimate(&self) -> usize

source

pub fn bins(&self) -> usize

source

pub fn retrieve_duplicate_keys_from_startup(&self) -> Vec<Vec<(Slot, Pubkey)>>

return Vec<Vec<>> because the internal vecs are already allocated per bin

source

pub fn upsert( &self, new_slot: Slot, old_slot: Slot, pubkey: &Pubkey, account: &impl ReadableAccount, account_indexes: &AccountSecondaryIndexes, account_info: T, reclaims: &mut SlotList<T>, reclaim: UpsertReclaim )

Updates the given pubkey at the given slot with the new account information. on return, the index’s previous account info may be returned in ‘reclaims’ depending on ‘previous_slot_entry_was_cached’

source

pub fn unref_from_storage(&self, pubkey: &Pubkey)

source

pub fn ref_count_from_storage(&self, pubkey: &Pubkey) -> RefCount

source

pub fn clean_rooted_entries( &self, pubkey: &Pubkey, reclaims: &mut SlotList<T>, max_clean_root: Option<Slot> ) -> bool

return true if pubkey was removed from the accounts index or does not exist in the accounts index This means it should NOT be unref’d later.

source

pub fn get_rooted_from_list<'a>( &self, slots: impl Iterator<Item = &'a Slot> ) -> Vec<Slot>

Given a list of slots, return a new list of only the slots that are rooted

source

pub fn is_alive_root(&self, slot: Slot) -> bool

source

pub fn add_root(&self, slot: Slot, caching_enabled: bool)

source

pub fn add_uncleaned_roots<I>(&self, roots: I)where I: IntoIterator<Item = Slot>,

source

pub fn max_root_inclusive(&self) -> Slot

source

pub fn get_next_original_root( &self, slot: Slot, ancestors: Option<&Ancestors> ) -> Option<Slot>

return the lowest original root >= slot, including historical_roots and ancestors

source

pub fn remove_old_historical_roots( &self, oldest_slot_to_keep: Slot, keep: &HashSet<Slot> )

roots are inserted into ‘historical_roots’ and ‘roots’ as a new root is made. roots are removed form ‘roots’ as all entries in the append vec become outdated. This function exists to clean older entries from ‘historical_roots’. all roots < ‘oldest_slot_to_keep’ are removed from ‘historical_roots’.

source

pub fn clean_dead_slot( &self, slot: Slot, stats: &mut AccountsIndexRootsStats ) -> bool

Remove the slot when the storage for the slot is freed Accounts no longer reference this slot. return true if slot was a root

source

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

source

pub fn reset_uncleaned_roots( &self, max_clean_root: Option<Slot> ) -> HashSet<Slot>

source

pub fn is_uncleaned_root(&self, slot: Slot) -> bool

source

pub fn num_alive_roots(&self) -> usize

source

pub fn all_alive_roots(&self) -> Vec<Slot>

source

pub fn clone_uncleaned_roots(&self) -> HashSet<Slot>

source

pub fn uncleaned_roots_len(&self) -> usize

Trait Implementations§

source§

impl<T: Debug + IndexValue> Debug for AccountsIndex<T>

source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<T> !RefUnwindSafe for AccountsIndex<T>

§

impl<T> Send for AccountsIndex<T>

§

impl<T> Sync for AccountsIndex<T>

§

impl<T> Unpin for AccountsIndex<T>

§

impl<T> !UnwindSafe for AccountsIndex<T>

Blanket Implementations§

source§

impl<T> AbiExample for T

source§

default fn example() -> T

source§

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

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

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

const: unstable · source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

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

const: unstable · source§

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

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

const: unstable · source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

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

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

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

const: unstable · source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

§

impl<T> Pointable for T

§

const ALIGN: usize = mem::align_of::<T>()

The alignment of pointer.
§

type Init = T

The type for initializers.
§

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

Initializes a with the given initializer. Read more
§

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

Dereferences the given pointer. Read more
§

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

Mutably dereferences the given pointer. Read more
§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
source§

impl<T> Same<T> for T

§

type Output = T

Should always be Self
source§

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

§

type Error = Infallible

The type returned in the event of a conversion error.
const: unstable · source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

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

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
const: unstable · source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

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

§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

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

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more