voidio 0.1.12

VOID I/O - High-performance Cross-platform I/O for Rust.
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
71
72
73
74

use super::sys;

const C_INT_SIZE: i32 = std::mem::size_of::<std::os::raw::c_int>() as i32;

pub trait SocketOption {
    type ValueType;

    fn level() -> i32;
    fn name() -> i32;
    fn len() -> i32 {
        C_INT_SIZE
    }
}

macro_rules! socket_option {
    ($name:ident, $value_type:ty, $level:expr, $name_value:expr) => {
        #[derive(Debug)]
        pub struct $name;

        impl SocketOption for $name {
            type ValueType = $value_type;

            fn level() -> i32 {
                $level
            }

            fn name() -> i32 {
                $name_value
            }
        }
    };

    ($name:ident, $value_type:ty, $level:expr, $name_value:expr, $len:expr) => {
        #[derive(Debug)]
        pub struct $name;

        impl SocketOption for $name {
            type ValueType = $value_type;

            fn level() -> i32 {
                $level
            }

            fn name() -> i32 {
                $name_value
            }

            fn len() -> i32 {
                $len
            }
        }
    };
}

socket_option!(SoReuseAddr, bool, sys::SOL_SOCKET, sys::SO_REUSEADDR);
socket_option!(SoRecvBufSize, usize, sys::SOL_SOCKET, sys::SO_RCVBUF);
socket_option!(SoSendBufSize, i32, sys::SOL_SOCKET, sys::SO_SNDBUF);
socket_option!(SoRecvTimeout, std::time::Duration, sys::SOL_SOCKET, sys::SO_RCVTIMEO, std::mem::size_of::<sys::TimeVal>() as i32);
socket_option!(SoSendTimeout, std::time::Duration, sys::SOL_SOCKET, sys::SO_SNDTIMEO, std::mem::size_of::<sys::TimeVal>() as i32);
socket_option!(TcpNoDelay, bool, sys::IPPROTO_TCP, sys::TCP_NODELAY);

#[derive(Debug)]
pub enum SocketOptions {
    ReuseAddr(SoReuseAddr),
    RecvBufSize(SoRecvBufSize),
    SendBufSize(SoSendBufSize),
    RecvTimeout(SoRecvTimeout),
    SendTimeout(SoSendTimeout),
}

#[derive(Debug)]
pub enum TcpOptions {
    NoDelay(TcpNoDelay),
}