Struct IOEvent 

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

Fields

action: IOAction

offset: i64

fd: RawFd

Implementations

impl<C: IOCallback> IOEvent<C>

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

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

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

pub fn set_callback(&mut self, cb: 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>( self: Box<Self>, check_short_read: F, ) -> Result<(), Box<Self>>

where F: FnOnce(u64) -> bool,

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(self, to_fix_short_io: bool)

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

Arguments

• to_fix_short_io: should always be true, fix the buffer len of short I/O

Safety

Only for callback worker does not re-submit when short I/O. Buffer::len() will changed to actual I/O copied size during callback.

Trait Implementations

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

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

Formats the value using the given formatter.