slings 0.1.4

A small async runtime based on io-uring for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use std::future::Future;
use std::io;
use std::os::unix::io::RawFd;
use std::pin::Pin;
use std::task::{Context, Poll};

use io_uring::{opcode, types};

use crate::driver::Action;

pub(crate) struct Write;

impl Action<Write> {
    pub(crate) fn write(fd: RawFd, buf: &[u8]) -> io::Result<Action<Write>> {
        let ptr = buf.as_ptr();
        let len = buf.len() as u32;
        let entry = opcode::Write::new(types::Fd(fd), ptr, len).build();
        Action::submit(Write, entry)
    }

    pub(crate) fn poll_write(&mut self, cx: &mut Context<'_>) -> Poll<io::Result<usize>> {
        let complete = ready!(Pin::new(self).poll(cx));
        let n = complete.result? as usize;
        Poll::Ready(Ok(n))
    }
}