Struct mio_aio::Source

pub struct Source<T> { /* private fields */ }

A Mio source based on a single POSIX AIO operation.

The generic parameter specifies exactly which operation it is. This struct implements mio::Source. After creation, use mio::Source::register to connect it to the event loop.

Implementations

impl<'a> Source<AioFsync<'a>>

pub fn fsync(fd: BorrowedFd<'a>, mode: AioFsyncMode, prio: i32) -> Self

Asynchronously fsync a file.

impl<'a> Source<AioRead<'a>>

pub fn read_at( fd: BorrowedFd<'a>, offs: u64, buf: &'a mut [u8], prio: i32 ) -> Self

Asynchronously read from a file.

impl<'a> Source<AioReadv<'a>>

pub fn readv_at( fd: BorrowedFd<'a>, offs: u64, bufs: &mut [IoSliceMut<'a>], prio: i32 ) -> Self

Asynchronously read from a file to a scatter/gather list of buffers.

Requires FreeBSD 13.0 or later.

impl<'a> Source<AioWrite<'a>>

pub fn write_at(fd: BorrowedFd<'a>, offs: u64, buf: &'a [u8], prio: i32) -> Self

Asynchronously write to a file.

impl<'a> Source<AioWritev<'a>>

pub fn writev_at( fd: BorrowedFd<'a>, offs: u64, bufs: &[IoSlice<'a>], prio: i32 ) -> Self

Asynchronously write to a file to a scatter/gather list of buffers.

Requires FreeBSD 13.0 or later.

Trait Implementations

impl<T: Debug> Debug for Source<T>

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

Formats the value using the given formatter.

impl<T: Aio> Source for Source<T>

fn register( &mut self, registry: &Registry, token: Token, interests: Interest ) -> Result<()>

Register self with the given Registry instance.

fn reregister( &mut self, registry: &Registry, token: Token, interests: Interest ) -> Result<()>

Re-register self with the given Registry instance.

fn deregister(&mut self, _registry: &Registry) -> Result<()>

Deregister self from the given Registry instance.

impl<T: Aio> SourceApi for Source<T>

type Output = <T as Aio>::Output

Return type of SourceApi::aio_return.

fn aio_return(self: Pin<&mut Self>) -> Result<Self::Output>

Read the final result of the operation

fn cancel(self: Pin<&mut Self>) -> Result<AioCancelStat>

Ask the operating system to cancel the operation

fn error(self: Pin<&mut Self>) -> Result<()>

Retrieve the status of an in-progress or complete operation.

fn in_progress(&self) -> bool

Does this operation currently have any in-kernel state?

fn submit(self: Pin<&mut Self>) -> Result<()>

Actually start the I/O operation.