Struct IOEvent 

pub struct IOEvent<C: CbArgs> {
    pub action: IOAction,
    pub offset: i64,
    pub fd: RawFd,
    /* private fields */
}

Fields

action: IOAction

offset: i64

fd: RawFd

Implementations

impl<C: CbArgs> IOEvent<C>

pub fn new(fd: RawFd, buf: Buffer, action: IOAction, offset: i64) -> Self

For IOAction::Read / IOAction::Write

pub fn new_no_buf(fd: RawFd, action: IOAction, offset: i64, len: u64) -> Self

For IOAction::Alloc / IOAction::Fsync

pub fn set_fd(&mut self, fd: RawFd)

pub fn set_args(&mut self, args: C)

Set callback for IOEvent, might be closure or a custom struct

pub fn get_size(&self) -> u64

pub fn get_write_result(self) -> Result<(), Errno>

pub fn get_result(&self) -> Result<usize, Errno>

Get the result of the IO operation (bytes read/written or error). Returns the number of bytes successfully transferred.

pub fn get_read_result(self) -> Result<Buffer, Errno>

Get the buffer from a read operation. Note: The buffer length is NOT modified. Use get_result() to get actual bytes read.

pub fn callback<F, B>( self: Box<Self>, check_short_read: F, cb: B, ) -> Result<(), Box<Self>>

where F: FnOnce(u64) -> bool, B: Fn(C, i64, Result<Option<Buffer>, Errno>),

For writing custom callback workers

Callback worker should always call this function on receiving IOEvent from Driver

parameter: check_short_read(offset: u64) should be checking the offset exceed file end. If check_short_read() return true, the callback function will return Err(IOEvent) for I/O resubmit.

NOTE: you should always use a weak reference in check_short_read closure and re-submission.

pub fn callback_unchecked<B>(self, cb: B)

where B: Fn(C, i64, Result<Option<Buffer>, Errno>),

Perform callback on the IOEvent when cannot re-submit for short i/o

Trait Implementations

impl<C: CbArgs> Debug for IOEvent<C>

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

Formats the value using the given formatter.