Struct BlobStateMap 

pub struct BlobStateMap<C, I> { /* private fields */ }

Adapter structure to enable concurrent chunk readiness manipulating based on a base ChunkMap object.

A base ChunkMap, such as IndexedChunkMap, only tracks chunk readiness state, but doesn’t support concurrent manipulating of the chunk readiness state. The BlobStateMap structure acts as an adapter to enable concurrent chunk readiness state manipulation.

Implementations

impl BlobStateMap<BlobRangeMap, u64>

pub fn from_range_map(map: BlobRangeMap) -> Self

Create a new instance of BlobStateMap from a BlobRangeMap object.

Trait Implementations

impl<C, I> ChunkMap for BlobStateMap<C, I>

where C: ChunkMap + ChunkIndexGetter<Index = I>, I: Eq + Hash + Display + Send + 'static,

fn is_ready(&self, chunk: &dyn BlobChunkInfo) -> Result<bool>

Check whether the chunk is ready for use.

fn is_pending(&self, chunk: &dyn BlobChunkInfo) -> Result<bool>

Check whether the chunk is pending for downloading.

fn check_ready_and_mark_pending( &self, chunk: &dyn BlobChunkInfo, ) -> StorageResult<bool>

Check whether the chunk is ready for use, and mark it as pending if not ready yet.

fn set_ready_and_clear_pending(&self, chunk: &dyn BlobChunkInfo) -> Result<()>

Set the chunk to ready for use and clear the pending state.

fn clear_pending(&self, chunk: &dyn BlobChunkInfo)

Clear the pending state of the chunk.

fn is_persist(&self) -> bool

Check whether the implementation supports state persistence.

fn as_range_map(&self) -> Option<&dyn RangeMap<I = u32>>

Convert the objet to an RangeMap object.

fn is_ready_or_pending(&self, chunk: &dyn BlobChunkInfo) -> Result<bool>

Check whether a chunk is ready for use or pending for downloading.

impl<C, I> From<C> for BlobStateMap<C, I>

where C: ChunkMap + ChunkIndexGetter<Index = I>, I: Eq + Hash + Display,

fn from(c: C) -> Self

Converts to this type from the input type.

impl RangeMap for BlobStateMap<BlobRangeMap, u64>

type I = u64

fn is_range_all_ready(&self) -> bool

Check whether all chunks or data managed by the RangeMap object are ready.

fn is_range_ready(&self, start: Self::I, count: Self::I) -> Result<bool>

Check whether all chunks or data in the range are ready for use.

fn check_range_ready_and_mark_pending( &self, start: Self::I, count: Self::I, ) -> Result<Option<Vec<Self::I>>>

Check whether all chunks or data in the range [start, start + count) are ready.

fn set_range_ready_and_clear_pending( &self, start: Self::I, count: Self::I, ) -> Result<()>

Mark all chunks or data in the range as ready for use.

fn clear_range_pending(&self, start: Self::I, count: Self::I)

Clear the pending state for all chunks or data in the range.

fn wait_for_range_ready(&self, start: Self::I, count: Self::I) -> Result<bool>

Wait for all chunks or data in the range to be ready until timeout.

impl RangeMap for BlobStateMap<IndexedChunkMap, u32>

type I = u32

fn is_range_all_ready(&self) -> bool

Check whether all chunks or data managed by the RangeMap object are ready.

fn is_range_ready(&self, start: Self::I, count: Self::I) -> Result<bool>

Check whether all chunks or data in the range are ready for use.

fn check_range_ready_and_mark_pending( &self, start: Self::I, count: Self::I, ) -> Result<Option<Vec<Self::I>>>

Check whether all chunks or data in the range [start, start + count) are ready.

fn set_range_ready_and_clear_pending( &self, start: Self::I, count: Self::I, ) -> Result<()>

Mark all chunks or data in the range as ready for use.

fn clear_range_pending(&self, start: Self::I, count: Self::I)

Clear the pending state for all chunks or data in the range.

fn wait_for_range_ready(&self, start: Self::I, count: Self::I) -> Result<bool>

Wait for all chunks or data in the range to be ready until timeout.