Struct AppendVec

pub struct AppendVec { /* private fields */ }

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

impl AppendVec

pub fn new(file: &Path, create: bool, size: usize) -> Self

pub fn flush(&self) -> Result<()>

pub fn reset(&self)

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)>

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

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.

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

pub fn account_iter(&self) -> AppendVecAccountsIter<'_>

Return iterator for account metadata

pub fn accounts(&self, offset: usize) -> Vec<StoredAccountMeta<'_>>

Return a vector of account metadata for each account, starting from offset.

pub fn append_accounts<'a, 'b, T: ReadableAccount + Sync, U: StorableAccounts<'a, T>, V: Borrow<AccountHash>>( &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.

Trait Implementations

impl AbiExample for AppendVec

fn example() -> Self

impl Debug for AppendVec

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

Formats the value using the given formatter.

impl Drop for AppendVec

fn drop(&mut self)

Executes the destructor for this type.