Struct massa_storage::Storage

pub struct Storage {
    pub(crate) blocks: Arc<RwLock<BlockIndexes>>,
    pub(crate) operations: Arc<RwLock<OperationIndexes>>,
    pub(crate) endorsements: Arc<RwLock<EndorsementIndexes>>,
    pub(crate) block_owners: Arc<RwLock<PreHashMap<BlockId, usize>>>,
    pub(crate) operation_owners: Arc<RwLock<PreHashMap<OperationId, usize>>>,
    pub(crate) endorsement_owners: Arc<RwLock<PreHashMap<EndorsementId, usize>>>,
    pub(crate) local_used_blocks: PreHashSet<BlockId>,
    pub(crate) local_used_ops: PreHashSet<OperationId>,
    pub(crate) local_used_endorsements: PreHashSet<EndorsementId>,
}

A storage system for objects (blocks, operations…), shared by various components.

Fields

blocks: Arc<RwLock<BlockIndexes>>

global block storage

operations: Arc<RwLock<OperationIndexes>>

global operation storage

endorsements: Arc<RwLock<EndorsementIndexes>>

global operation storage

block_owners: Arc<RwLock<PreHashMap<BlockId, usize>>>

global block reference counter

operation_owners: Arc<RwLock<PreHashMap<OperationId, usize>>>

global operation reference counter

endorsement_owners: Arc<RwLock<PreHashMap<EndorsementId, usize>>>

global endorsement reference counter

local_used_blocks: PreHashSet<BlockId>

locally used block references

local_used_ops: PreHashSet<OperationId>

locally used operation references

local_used_endorsements: PreHashSet<EndorsementId>

locally used endorsement references

Implementations

impl Storage

pub fn create_root() -> Storage

Creates a new Storage instance. Must be called only one time in the execution:

• In the main for the node
• At the top of the test in tests

All others instances of Storage must be cloned from this one using clone() or clone_without_refs().

pub fn clone_without_refs(&self) -> Self

Clones the object to a new one that has no references

pub fn extend(&mut self, other: Storage)

Efficiently extends the current Storage by consuming the refs of another storage.

pub fn split_off( &mut self, blocks: &PreHashSet<BlockId>, operations: &PreHashSet<OperationId>, endorsements: &PreHashSet<EndorsementId>, ) -> Storage

Efficiently splits off a subset of the reference ownership into a new Storage object. Panics if some of the refs are not owned by the source.

pub(crate) fn internal_claim_refs<IdT: Id + PartialEq + Eq + Hash + PreHashed + Copy>( ids: &PreHashSet<IdT>, owners: &mut RwLockWriteGuard<'_, PreHashMap<IdT, usize>>, local_used_ids: &mut PreHashSet<IdT>, )

internal helper to locally claim a reference to an object

pub fn get_block_refs(&self) -> &PreHashSet<BlockId>

get the block reference ownership

pub fn claim_block_refs( &mut self, ids: &PreHashSet<BlockId>, ) -> PreHashSet<BlockId>

Claim block references. Returns the set of block refs that were found and claimed.

pub fn drop_block_refs(&mut self, ids: &PreHashSet<BlockId>)

Drop block references

pub fn store_block(&mut self, block: SecureShareBlock)

Store a block Note that this also claims a local reference to the block

pub fn claim_operation_refs( &mut self, ids: &PreHashSet<OperationId>, ) -> PreHashSet<OperationId>

Claim operation references. Returns the set of operation refs that were found and claimed.

pub fn get_op_refs(&self) -> &PreHashSet<OperationId>

get the operation reference ownership

pub fn drop_operation_refs(&mut self, ids: &PreHashSet<OperationId>)

Drop local operation references. Ignores already-absent refs.

pub fn store_operations(&mut self, operations: Vec<SecureShareOperation>)

Store operations Claims a local reference to the added operation

pub fn read_operations(&self) -> RwLockReadGuard<'_, OperationIndexes>

Gets a read reference to the operations index

pub fn read_endorsements(&self) -> RwLockReadGuard<'_, EndorsementIndexes>

Gets a read reference to the endorsements index

pub fn read_blocks(&self) -> RwLockReadGuard<'_, BlockIndexes>

Gets a read reference to the blocks index

pub fn claim_endorsement_refs( &mut self, ids: &PreHashSet<EndorsementId>, ) -> PreHashSet<EndorsementId>

Claim endorsement references. Returns the set of operation refs that were found and claimed.

pub fn get_endorsement_refs(&self) -> &PreHashSet<EndorsementId>

get the endorsement reference ownership

pub fn drop_endorsement_refs(&mut self, ids: &PreHashSet<EndorsementId>)

Drop local endorsement references. Ignores already-absent refs.

pub fn store_endorsements(&mut self, endorsements: Vec<SecureShareEndorsement>)

Store endorsements Claims local references to the added endorsements

Trait Implementations

impl Clone for Storage

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Storage

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

Formats the value using the given formatter.

impl Drop for Storage

fn drop(&mut self)

cleanup on Storage instance drop