Struct mio_aio::LioCb

pub struct LioCb<'a> { /* fields omitted */ }

Methods

impl<'a> LioCb<'a>

pub fn submit(&mut self) -> Result<(), LioError>

Submit an LioCb to the aio(4) subsystem.

If the return value is LioError::EAGAIN, then no operations were enqueued due to system resource limitations. The application should free up resources and try again. If the return value is LioError::EINCOMPLETE, then some operations were enqueued, but others were not, due to system resource limitations. The application should wait for notification that the enqueued operations are complete, then resubmit the others with resubmit. If the return value is LioError::EIO, then some operations have failed to enqueue, and cannot be resubmitted. The application should wait for notification that the enqueued operations are complete, then examine the result of each operation to determine the problem.

pub fn resubmit(&mut self) -> Result<(), LioError>

Resubmit an LioCb if it is incomplete.

If submit returns LioError::EINCOMPLETE, then some operations may not have been submitted. This method will collect status for any completed operations, then resubmit the others.

lio_listio

pub fn emplace_mut_slice(
    &mut self,
    fd: RawFd,
    offset: u64,
    buf: &'a mut [u8],
    prio: i32,
    opcode: LioOpcode
)

pub fn emplace_slice(
    &mut self,
    fd: RawFd,
    offset: u64,
    buf: &'a [u8],
    prio: i32,
    opcode: LioOpcode
)

pub fn into_results<F, R>(self, callback: F) -> R where
    F: FnOnce(Box<dyn Iterator<Item = LioResult> + 'a>) -> R, 

Consume an LioCb and collect its operations' results.

An iterator over all operations' results will be supplied to the callback function.

pub fn with_capacity(capacity: usize) -> LioCb<'a>

Trait Implementations

impl<'a> Debug for LioCb<'a>

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

Formats the value using the given formatter.

impl<'a> Evented for LioCb<'a>

fn register(
    &self,
    poll: &Poll,
    token: Token,
    events: Ready,
    _: PollOpt
) -> Result<()>

Register self with the given Poll instance.

fn reregister(
    &self,
    poll: &Poll,
    token: Token,
    events: Ready,
    opts: PollOpt
) -> Result<()>

Re-register self with the given Poll instance.

fn deregister(&self, _: &Poll) -> Result<()>

Deregister self from the given Poll instance