runite 0.1.0

An event-loop-per-thread async runtime built on io_uring (Linux), kqueue (macOS), and IOCP (Windows)
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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

//! Logical networking operations shared between the public API and Linux backend.

use crate::sys::handle::RawSock;
use std::net::{Shutdown, SocketAddr};

// `Socket`/`Bind`/`Listen` are constructed only by the Unix backends and the
// Unix-domain-socket layer; the Windows backend reaches its socket/bind/listen
// helpers directly.
#[cfg_attr(windows, allow(dead_code))]
#[derive(Debug)]
pub enum NetOp {
    Socket {
        domain: i32,
        socket_type: i32,
        protocol: i32,
        flags: u32,
    },
    Connect {
        fd: RawSock,
        addr: SocketAddr,
    },
    Bind {
        fd: RawSock,
        addr: SocketAddr,
    },
    Listen {
        fd: RawSock,
        backlog: i32,
    },
    Accept {
        fd: RawSock,
    },
    Send {
        fd: RawSock,
        data: Vec<u8>,
        flags: i32,
    },
    SendTo {
        fd: RawSock,
        target: SocketAddr,
        data: Vec<u8>,
        flags: i32,
    },
    Recv {
        fd: RawSock,
        len: usize,
        flags: i32,
    },
    RecvFrom {
        fd: RawSock,
        len: usize,
        flags: i32,
    },
    Shutdown {
        fd: RawSock,
        how: Shutdown,
    },
}

#[derive(Clone, Debug)]
pub struct AcceptedSocket {
    pub fd: RawSock,
    pub peer_addr: SocketAddr,
}

#[derive(Clone, Debug)]
pub struct ReceivedDatagram {
    pub data: Vec<u8>,
    pub peer_addr: SocketAddr,
}