Struct BlobRangeMap 

pub struct BlobRangeMap { /* private fields */ }

An implementation of RangeMap to support cache state tracking by using a bitmap file.

The BlobRangeMap is an implementation of RangeMap which uses a bitmap file and atomic bitmap operations to track readiness state. It creates or opens a file with the name $blob_id.range_map to record whether a data range has been cached by the blob cache, and atomic bitmap operations are used to manipulate the state bit. The bitmap file will be persisted to disk.

Implementations

impl BlobRangeMap

pub fn new(blob_path: &str, count: u32, shift: u32) -> Result<Self>

Create a new instance of BlobRangeMap.

pub fn open( blob_id: &str, workdir: &str, count: u32, shift: u32, ) -> Result<Self>

Create a new instance of BlobRangeMap from an existing chunk map file.

Trait Implementations

impl RangeMap for BlobRangeMap

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

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

type I = u64

fn is_range_all_ready(&self) -> bool

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

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

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

fn set_range_ready_and_clear_pending( &self, start: u64, count: u64, ) -> 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.