Struct sel4_shared_ring_buffer::RingBuffer

pub struct RingBuffer<'a, R: RingBufferRole, T = Descriptor> { /* private fields */ }

Implementations

impl<'a, R: RingBufferRole, T: Copy> RingBuffer<'a, R, T>

pub fn new( ptr: ExternallySharedRef<'a, RawRingBuffer<T>>, initialization_strategy: InitializationStrategy, ) -> Self

pub const fn capacity(&self) -> usize

pub fn num_filled_slots(&mut self) -> Result<usize, PeerMisbehaviorError>

pub fn num_empty_slots(&mut self) -> Result<usize, PeerMisbehaviorError>

pub fn is_empty(&mut self) -> Result<bool, PeerMisbehaviorError>

pub fn is_full(&mut self) -> Result<bool, PeerMisbehaviorError>

impl<'a, T: Copy + FromBytes + AsBytes> RingBuffer<'a, Write, T>

pub fn enqueue_and_commit( &mut self, desc: T, ) -> Result<Result<(), T>, PeerMisbehaviorError>

pub fn enqueue_without_committing( &mut self, desc: T, ) -> Result<Result<(), T>, PeerMisbehaviorError>

pub fn enqueue( &mut self, desc: T, commit: bool, ) -> Result<Result<(), T>, PeerMisbehaviorError>

pub fn force_enqueue(&mut self, desc: T, commit: bool)

pub fn commit(&mut self)

impl<'a, T: Copy + FromBytes + AsBytes> RingBuffer<'a, Read, T>

pub fn dequeue(&mut self) -> Result<Option<T>, PeerMisbehaviorError>

pub fn force_dequeue(&mut self) -> T