Struct BlockFragmentStore 

pub struct BlockFragmentStore { /* private fields */ }

Production-grade store for fragmented blocks.

Handles concurrent fragment arrival, checksum verification, automatic assembly on completion, LRU-style eviction of the oldest pending sets when the cap is exceeded, and a bounded assembled-block cache.

Implementations

impl BlockFragmentStore

pub fn new(max_pending: usize, max_assembled: usize) -> Self

Create a new store with the given capacity limits.

• max_pending – maximum number of in-progress fragment sets.
• max_assembled – maximum number of assembled blocks kept in cache.

pub fn store_fragment( &mut self, fragment: BfsFragment, now: u64, ) -> Result<FragmentSetState, FragmentError>

Store a fragment.

If the fragment completes its set, assembly is attempted automatically and the pending set is removed. If max_pending would be exceeded when creating a new set, the oldest pending set (by created_at) is dropped.

Returns the current FragmentSetState after the operation.

pub fn get_state(&self, block_cid: &str) -> Option<FragmentSetState>

Return the current state of a fragment set.

Returns None if neither a pending set nor an assembled block exists for the given CID.

pub fn missing_indices(&self, block_cid: &str) -> Vec<u32>

Return the indices of fragments that have not yet been received, in ascending order. Returns an empty vec if the block is assembled or unknown.

pub fn assemble( &mut self, block_cid: &str, now: u64, ) -> Result<AssembledBlock, FragmentError>

Assemble a block from its fragments.

All fragments must be present and pass checksum verification. On success, the assembled block is stored in the cache and the pending set is removed.

pub fn get_assembled(&self, block_cid: &str) -> Option<&[u8]>

Return a reference to the data of an assembled block, or None if not present in the cache.

pub fn get_assembled_block(&self, block_cid: &str) -> Option<&AssembledBlock>

Return a reference to the full AssembledBlock struct, if cached.

pub fn verify_fragment(fragment: &BfsFragment) -> bool

Return true if the fragment’s checksum matches the recomputed value.

pub fn verify_set(set: &FragmentSet) -> Vec<u32>

Return the indices of fragments in a set whose checksums do not match.

pub fn evict_stale_pending(&mut self, max_age_ms: u64, now: u64) -> usize

Remove all pending (incomplete) sets whose created_at is older than max_age_ms milliseconds before now. Returns the number of sets removed.

pub fn evict_assembled(&mut self, cid: &str) -> bool

Remove an assembled block from the cache by CID. Returns true if the block was present and removed.

pub fn pending_count(&self) -> usize

Number of pending (incomplete) fragment sets.

pub fn assembled_count(&self) -> usize

Number of assembled blocks in the cache.

pub fn stats(&self) -> FragmentStats

Aggregate statistics about the store.

pub fn pending_cids(&self) -> Vec<&str>

Return all pending fragment set CIDs.

pub fn assembled_cids(&self) -> Vec<&str>

Return all assembled block CIDs.

pub fn clear_pending(&mut self) -> usize

Clear all pending sets without assembling them. Returns the number of sets dropped.

pub fn clear_assembled(&mut self) -> usize

Clear all assembled blocks from the cache. Returns the number of blocks dropped.

pub fn pending_capacity_remaining(&self) -> usize

Return how many more pending sets can be accepted before the cap is hit.

Trait Implementations

impl Debug for BlockFragmentStore

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

Formats the value using the given formatter.