Struct sel4_shared_ring_buffer_block_io::OwnedSharedRingBufferBlockIO

pub struct OwnedSharedRingBufferBlockIO<S, A, F> { /* private fields */ }

Implementations

impl<S: SlotSemaphore, A: AbstractBounceBufferAllocator, F: FnMut()> OwnedSharedRingBufferBlockIO<S, A, F>

pub fn new( dma_region: ExternallySharedRef<'static, [u8]>, bounce_buffer_allocator: BounceBufferAllocator<A>, ring_buffers: RingBuffers<'static, Provide, F, BlockIORequest>, ) -> Self

pub fn slot_set_semaphore(&self) -> &SlotSetSemaphoreHandle<S, NUM_SLOT_POOLS>

pub fn issue_read_request( &mut self, reservation: &mut SlotSetReservation<'_, S, NUM_SLOT_POOLS>, start_block_idx: u64, num_bytes: usize, ) -> Result<usize, ErrorOrUserError>

pub fn issue_write_request( &mut self, reservation: &mut SlotSetReservation<'_, S, NUM_SLOT_POOLS>, start_block_idx: u64, buf: &[u8], ) -> Result<usize, ErrorOrUserError>

pub fn issue_request( &mut self, reservation: &mut SlotSetReservation<'_, S, NUM_SLOT_POOLS>, start_block_idx: u64, buf: &mut IssueRequestBuf<'_>, ) -> Result<usize, ErrorOrUserError>

pub fn cancel_request( &mut self, request_index: usize, ) -> Result<(), ErrorOrUserError>

pub fn poll_read_request( &mut self, request_index: usize, buf: &mut [u8], waker: Option<Waker>, ) -> Result<Poll<Result<(), IOError>>, ErrorOrUserError>

pub fn poll_write_request( &mut self, request_index: usize, waker: Option<Waker>, ) -> Result<Poll<Result<(), IOError>>, ErrorOrUserError>

pub fn poll_request( &mut self, request_index: usize, buf: &mut PollRequestBuf<'_>, waker: Option<Waker>, ) -> Result<Poll<Result<(), IOError>>, ErrorOrUserError>

pub fn poll(&mut self) -> Result<bool, ErrorOrUserError>