Struct solana_runtime::accounts_db::AccountsDB

pub struct AccountsDB {
    pub accounts_index: RwLock<AccountsIndex<AccountInfo>>,
    pub storage: RwLock<AccountStorage>,
    pub next_id: AtomicUsize,
    pub shrink_candidate_slots: Mutex<Vec<Slot>>,
    pub thread_pool: ThreadPool,
    pub thread_pool_clean: ThreadPool,
    pub bank_hashes: RwLock<HashMap<Slot, BankHashInfo>>,
    pub dead_slots: RwLock<HashSet<Slot>>,
    // some fields omitted
}

Fields

accounts_index: RwLock<AccountsIndex<AccountInfo>>

Keeps tracks of index into AppendVec on a per slot basis

storage: RwLock<AccountStorage>

next_id: AtomicUsize

distribute the accounts across storage lists

shrink_candidate_slots: Mutex<Vec<Slot>>

thread_pool: ThreadPool

Thread pool used for par_iter

thread_pool_clean: ThreadPool

bank_hashes: RwLock<HashMap<Slot, BankHashInfo>>

dead_slots: RwLock<HashSet<Slot>>

Methods

impl AccountsDB

pub fn new(paths: Vec<PathBuf>) -> Self

pub fn accounts_from_stream<R: Read, P: AsRef<Path>>(
    &self,
    stream: &mut BufReader<R>,
    stream_append_vecs_path: P
) -> Result<(), IOError>

pub fn clean_accounts(&self)

pub fn process_dead_slots(&self)

pub fn process_stale_slot(&self)

pub fn shrink_all_stale_slots(&self)

pub fn scan_accounts<F, A>(
    &self,
    ancestors: &HashMap<Slot, usize>,
    scan_func: F
) -> A where
    F: Fn(&mut A, Option<(&Pubkey, Account, Slot)>),
    A: Default, 

pub fn scan_account_storage<F, B>(&self, slot: Slot, scan_func: F) -> Vec<B> where
    F: Fn(&StoredAccount, AppendVecId, &mut B) + Send + Sync,
    B: Send + Default, 

Scan a specific slot through all the account storage in parallel with sequential read

pub fn set_hash(&self, slot: Slot, parent_slot: Slot)

pub fn load(
    storage: &AccountStorage,
    ancestors: &HashMap<Slot, usize>,
    accounts_index: &AccountsIndex<AccountInfo>,
    pubkey: &Pubkey
) -> Option<(Account, Slot)>

pub fn load_slow(
    &self,
    ancestors: &HashMap<Slot, usize>,
    pubkey: &Pubkey
) -> Option<(Account, Slot)>

pub fn purge_slot(&self, slot: Slot)

pub fn purge_slots(&self, slots: &HashSet<Slot>)

pub fn remove_unrooted_slot(&self, remove_slot: Slot)

pub fn hash_stored_account(slot: Slot, account: &StoredAccount) -> Hash

pub fn hash_account(slot: Slot, account: &Account, pubkey: &Pubkey) -> Hash

pub fn hash_account_data(
    slot: Slot,
    lamports: u64,
    executable: bool,
    rent_epoch: Epoch,
    data: &[u8],
    pubkey: &Pubkey
) -> Hash

pub fn compute_merkle_root(hashes: Vec<(Pubkey, Hash)>, fanout: usize) -> Hash

pub fn get_accounts_hash(&self, slot: Slot) -> Hash

pub fn update_accounts_hash(
    &self,
    slot: Slot,
    ancestors: &HashMap<Slot, usize>
) -> Hash

pub fn verify_bank_hash(
    &self,
    slot: Slot,
    ancestors: &HashMap<Slot, usize>
) -> Result<(), BankHashVerificationError>

pub fn get_accounts_delta_hash(&self, slot: Slot) -> Hash

pub fn clean_dead_slots(&self, dead_slots: &HashSet<Slot>)

pub fn freeze_accounts(
    &mut self,
    ancestors: &HashMap<Slot, usize>,
    account_pubkeys: &[Pubkey]
)

pub fn store(&self, slot: Slot, accounts: &[(&Pubkey, &Account)])

Store the account update.

pub fn add_root(&self, slot: Slot)

pub fn get_snapshot_storages(&self, snapshot_slot: Slot) -> SnapshotStorages

Trait Implementations

impl Debug for AccountsDB

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

Formats the value using the given formatter.

impl Default for AccountsDB

fn default() -> Self

Returns the "default value" for a type.