Struct RangeBlockedList

struct RangeBlockedList {
    blocked: Vec<Arc<RangeBlocked>>,
}

A list of ranges blocked for some kind of concurrent access.

Depending on the use, some will block all concurrent access (i.e. serializing writes will block both serializing and non-serializing writes (strong blockers)), while others will only block a subset (non-serializing writes will only block serializing writes (weak blockers)).

Fields

blocked: Vec<Arc<RangeBlocked>>

The list of ranges.

Serializing writes (strong write blockers) are supposed to be rare, so it is important that entering and removing items into/from this list is cheap, not that iterating it is.

Implementations

impl RangeBlockedList

fn collect_intersecting_await_futures( &self, check_range: &Range<u64>, future_vector: &mut FutureVector<(), RecvError, Receiver<()>>, )

Collects futures to await intersecting request.

Adds a future to future_vector for every intersecting request; awaiting that future will await the request.

fn block(&mut self, range: Range<u64>) -> Arc<RangeBlocked>

Enter a new blocked range into the list.

This only blocks new requests, old requests must separately be awaited by awaiting all futures returned by collect_intersecting_await_futures().

Trait Implementations

impl Debug for RangeBlockedList

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

Formats the value using the given formatter.

impl Default for RangeBlockedList

fn default() -> RangeBlockedList

Returns the “default value” for a type.