Struct nix::sys::aio::AioWritev

#[repr(transparent)]
pub struct AioWritev<'a> { /* private fields */ }

Available on crate feature aio only.

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

References

aio_writev

Examples

const wbuf0: &[u8] = b"abcdef";
const wbuf1: &[u8] = b"123456";
let len = wbuf0.len() + wbuf1.len();
let wbufs = [IoSlice::new(wbuf0), IoSlice::new(wbuf1)];
let mut f = tempfile().unwrap();
let mut aiow = Box::pin(
   AioWritev::new(
       f.as_raw_fd(),
       2,   //offset
       &wbufs,
       0,   //priority
       SigevNotify::SigevNone
   )
);
aiow.as_mut().submit().unwrap();
while (aiow.as_mut().error() == Err(Errno::EINPROGRESS)) {
   thread::sleep(time::Duration::from_millis(10));
}
assert_eq!(aiow.as_mut().aio_return().unwrap(), len);

Implementations

impl<'a> AioWritev<'a>

pub fn iovlen(&self) -> usize

Returns the number of buffers the operation will read into.

pub fn new(
    fd: RawFd,
    offs: off_t,
    bufs: &[IoSlice<'a>],
    prio: i32,
    sigev_notify: SigevNotify
) -> Self

Construct a new AioWritev.

Arguments

• fd: File descriptor to write to
• offs: File offset
• bufs: A scatter/gather list of memory buffers. They must outlive the AioWritev.
• prio: If POSIX Prioritized IO is supported, then the operation will be prioritized at the process’s priority level minus prio
• sigev_notify: Determines how you will be notified of event completion.

pub fn offset(&self) -> off_t

Returns the file offset of the operation.

Trait Implementations

impl<'a> Aio for AioWritev<'a>

type Output = usize

The return type of Aio::aio_return.

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

Cancels an outstanding AIO request.

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

Retrieve error status of an asynchronous operation.

fn fd(&self) -> RawFd

Returns the underlying file descriptor associated with the operation.

fn in_progress(&self) -> bool

Does this operation currently have any in-kernel state?

fn priority(&self) -> i32

Returns the priority of the AioCb

fn set_sigev_notify(&mut self, sev: SigevNotify)

Update the notification settings for an existing AIO operation that has not yet been submitted.

fn sigevent(&self) -> SigEvent

Returns the SigEvent that will be used for notification.

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

Retrieve return status of an asynchronous operation.

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

Actually start the I/O operation.

impl<'a> AsMut<aiocb> for AioWritev<'a>

fn as_mut(&mut self) -> &mut aiocb

Converts this type into a mutable reference of the (usually inferred) input type.

impl<'a> AsRef<aiocb> for AioWritev<'a>

fn as_ref(&self) -> &aiocb

Converts this type into a shared reference of the (usually inferred) input type.

impl<'a> Debug for AioWritev<'a>

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

Formats the value using the given formatter.