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

source

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

source

pub fn set_no_remove_on_drop(&mut self)

source

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

source

pub fn reset(&self)

source

pub fn remaining_bytes(&self) -> u64

how many more bytes can be stored in this append vec

source

pub fn len(&self) -> usize

source

pub fn is_empty(&self) -> bool

source

pub fn capacity(&self) -> u64

source

pub fn file_name(slot: Slot, id: impl Display) -> String

source

pub fn new_from_file<P: AsRef<Path>>( path: P, current_len: usize ) -> Result<(Self, usize)>

source

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

source

pub fn get_account<'a>( &'a self, offset: usize ) -> Option<(StoredAccountMeta<'a>, usize)>

Return 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.

source

pub fn get_path(&self) -> PathBuf

source

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

Return iterator for account metadata

source

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

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

source

pub fn append_accounts( &self, accounts: &[(StoredMeta, Option<&impl ReadableAccount>)], hashes: &[impl Borrow<Hash>] ) -> Vec<usize>

Copy each account metadata, account and hash to the internal buffer. Return the starting offset of each account metadata. After each account is appended, the internal current_len is updated and will be available to other threads.

source

pub fn append_account( &self, storage_meta: StoredMeta, account: &AccountSharedData, hash: Hash ) -> Option<usize>

Copy the account metadata, account and hash to the internal buffer. Return the starting offset of the account metadata. After the account is appended, the internal current_len is updated.

Trait Implementations§

source§

impl AbiExample for AppendVec

source§

fn example() -> Self

source§

impl Debug for AppendVec

source§

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

Formats the value using the given formatter. Read more
source§

impl Drop for AppendVec

source§

fn drop(&mut self)

Executes the destructor for this type. Read more

Auto Trait Implementations§

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