Struct ringbuf::ring_buffer::RbReadCache

pub struct RbReadCache<T, R: RbRef>where
    R::Rb: RbRead<T>,{ /* private fields */ }

Caching read end of some ring buffer.

A free space of removed items is not visible for an opposite write end until Self::commit/Self::sync is called or Self is dropped. Items inserted by an opposite write end is not visible for Self until Self::sync is called.

Used to implement PostponedConsumer.

Implementations

impl<T, R: RbRef> RbReadCache<T, R>where R::Rb: RbRead<T>,

pub unsafe fn new(rb_ref: R) -> Self

Create new ring buffer cache.

Safety

There must be only one instance containing the same ring buffer reference.

pub fn commit(&mut self)

Commit changes to the ring buffer.

pub fn sync(&mut self)

Commit changes and fetch updates from the ring buffer.

pub fn release(self) -> R

Commit and destroy Self returning underlying ring buffer.

Trait Implementations

impl<T, R: RbRef> Drop for RbReadCache<T, R>where R::Rb: RbRead<T>,

fn drop(&mut self)

Executes the destructor for this type.

impl<T, R: RbRef> RbBase<T> for RbReadCache<T, R>where R::Rb: RbRead<T>,

unsafe fn slices( &self, head: usize, tail: usize ) -> (&mut [MaybeUninit<T>], &mut [MaybeUninit<T>])

Returns part of underlying raw ring buffer memory as slices.

fn capacity_nonzero(&self) -> NonZeroUsize

Capacity of the ring buffer.

fn head(&self) -> usize

Head position.

fn tail(&self) -> usize

Tail position.

fn modulus(&self) -> NonZeroUsize

Modulus for head and tail values.

fn occupied_len(&self) -> usize

The number of items stored in the buffer at the moment.

fn vacant_len(&self) -> usize

The number of vacant places in the buffer at the moment.

fn is_empty(&self) -> bool

Checks if the occupied range is empty.

fn is_full(&self) -> bool

Checks if the vacant range is empty.

impl<T, R: RbRef> RbRead<T> for RbReadCache<T, R>where R::Rb: RbRead<T>,

unsafe fn set_head(&self, value: usize)

Sets the new head position.

unsafe fn advance_head(&self, count: usize)

Move head position by count items forward.

fn occupied_ranges(&self) -> (Range<usize>, Range<usize>)

Returns a pair of ranges of Self::occupied_slices location in underlying container.

unsafe fn occupied_slices( &self ) -> (&mut [MaybeUninit<T>], &mut [MaybeUninit<T>])

Provides a direct mutable access to the ring buffer occupied memory.

unsafe fn skip_internal(&self, count_or_all: Option<usize>) -> usize

Removes items from the head of ring buffer and drops them.