Struct solana_runtime::append_vec::AppendVec
source · pub struct AppendVec { /* private fields */ }
Expand description
A thread-safe, file-backed block of memory used to store Account
instances. Append operations
are serialized such that only one thread updates the internal append_lock
at a time. No
restrictions are placed on reading. That is, one may read items from one thread while another
is appending new items.
Implementations§
source§impl AppendVec
impl AppendVec
pub fn new(file: &Path, create: bool, size: usize) -> Self
pub fn set_no_remove_on_drop(&mut self)
pub fn flush(&self) -> Result<()>
pub fn reset(&self)
sourcepub fn remaining_bytes(&self) -> u64
pub fn remaining_bytes(&self) -> u64
how many more bytes can be stored in this append vec
pub fn len(&self) -> usize
pub fn is_empty(&self) -> bool
pub fn capacity(&self) -> u64
pub fn file_name(slot: Slot, id: impl Display) -> String
pub fn new_from_file<P: AsRef<Path>>( path: P, current_len: usize ) -> Result<(Self, usize)>
sourcepub fn new_from_file_unchecked<P: AsRef<Path>>(
path: P,
current_len: usize
) -> Result<Self>
pub fn new_from_file_unchecked<P: AsRef<Path>>( path: P, current_len: usize ) -> Result<Self>
Creates an appendvec from file without performing sanitize checks or counting the number of accounts
sourcepub fn get_account(
&self,
offset: usize
) -> Option<(StoredAccountMeta<'_>, usize)>
pub fn get_account( &self, offset: usize ) -> Option<(StoredAccountMeta<'_>, usize)>
Return stored account metadata for the account at offset
if its data doesn’t overrun
the internal buffer. Otherwise return None. Also return the offset of the first byte
after the requested data that falls on a 64-byte boundary.
sourcepub fn account_matches_owners(
&self,
offset: usize,
owners: &[&Pubkey]
) -> Result<usize, MatchAccountOwnerError>
pub fn account_matches_owners( &self, offset: usize, owners: &[&Pubkey] ) -> Result<usize, MatchAccountOwnerError>
Return Ok(index_of_matching_owner) if the account owner at offset
is one of the pubkeys in owners
.
Return Err(MatchAccountOwnerError::NoMatch) if the account has 0 lamports or the owner is not one of
the pubkeys in owners
.
Return Err(MatchAccountOwnerError::UnableToLoad) if the offset
value causes a data overrun.
pub fn get_path(&self) -> PathBuf
sourcepub fn account_iter(&self) -> AppendVecAccountsIter<'_> ⓘ
pub fn account_iter(&self) -> AppendVecAccountsIter<'_> ⓘ
Return iterator for account metadata
sourcepub fn accounts(&self, offset: usize) -> Vec<StoredAccountMeta<'_>>
pub fn accounts(&self, offset: usize) -> Vec<StoredAccountMeta<'_>>
Return a vector of account metadata for each account, starting from offset
.
sourcepub fn append_accounts<'a, 'b, T: ReadableAccount + Sync, U: StorableAccounts<'a, T>, V: Borrow<Hash>>(
&self,
accounts: &StorableAccountsWithHashesAndWriteVersions<'a, 'b, T, U, V>,
skip: usize
) -> Option<Vec<StoredAccountInfo>>
pub fn append_accounts<'a, 'b, T: ReadableAccount + Sync, U: StorableAccounts<'a, T>, V: Borrow<Hash>>( &self, accounts: &StorableAccountsWithHashesAndWriteVersions<'a, 'b, T, U, V>, skip: usize ) -> Option<Vec<StoredAccountInfo>>
Copy each account metadata, account and hash to the internal buffer.
If there is no room to write the first entry, None is returned.
Otherwise, returns the starting offset of each account metadata.
Plus, the final return value is the offset where the next entry would be appended.
So, return.len() is 1 + (number of accounts written)
After each account is appended, the internal current_len
is updated
and will be available to other threads.