Struct solana_runtime::accounts_db::AccountsDB

pub struct AccountsDB {
    pub accounts_index: RwLock<AccountsIndex<AccountInfo>>,
    pub storage: RwLock<AccountStorage>,
    pub next_id: AtomicUsize,
    // some fields omitted
}

Fields

accounts_index: RwLock<AccountsIndex<AccountInfo>>

Keeps tracks of index into AppendVec on a per fork basis

storage: RwLock<AccountStorage>

Account storage

next_id: AtomicUsize

distribute the accounts across storage lists

Methods

impl AccountsDB

pub fn new_with_file_size(paths: &str, file_size: u64) -> Self

pub fn new(paths: &str) -> Self

pub fn update_from_stream<R: Read>(
    &self,
    stream: &mut BufReader<R>
) -> Result<(), Error>

pub fn has_accounts(&self, fork: Fork) -> bool

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

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

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

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

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

pub fn purge_fork(&self, fork: Fork)

pub fn store(
    &self,
    fork_id: Fork,
    accounts: &HashMap<&Pubkey, (&Account, LamportCredit)>
)

Store the account update.

pub fn add_root(&self, fork: Fork)

Trait Implementations

impl Default for AccountsDB

fn default() -> Self

Returns the "default value" for a type.

impl Debug for AccountsDB

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

Formats the value using the given formatter.

impl Serialize for AccountsDB

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error> where
    S: Serializer, 

Serialize this value into the given Serde serializer.