nex-sys 0.26.0

Provides network-related system function and call support for nex. Used for low-level system interactions.
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

use windows_sys::Win32::Networking::WinSock as ws;

pub const IFF_UP: u32 = ws::IFF_UP;
pub const IFF_BROADCAST: u32 = ws::IFF_BROADCAST;
pub const IFF_LOOPBACK: u32 = ws::IFF_LOOPBACK;
pub const IFF_POINTOPOINT: u32 = ws::IFF_POINTTOPOINT;
pub const IFF_MULTICAST: u32 = ws::IFF_MULTICAST;

pub type CSocket = ws::SOCKET;
pub type Buf = *const libc::c_void;
pub type MutBuf = *mut libc::c_char;
pub type BufLen = libc::c_int;
pub type CouldFail = libc::c_int;
pub type SockLen = libc::c_int;
pub type MutSockLen = *mut libc::c_int;
pub type SockAddr = ws::SOCKADDR;
pub type SockAddrIn = ws::SOCKADDR_IN;
pub type SockAddrIn6 = ws::SOCKADDR_IN6;
pub type SockAddrStorage = ws::SOCKADDR_STORAGE;
pub type SockAddrFamily = ws::ADDRESS_FAMILY;
pub type SockAddrFamily6 = ws::ADDRESS_FAMILY;
pub type InAddr = ws::IN_ADDR;
pub type In6Addr = ws::IN6_ADDR;

pub unsafe fn close(sock: CSocket) {
    unsafe {
        let _ = ws::closesocket(sock);
    }
}

pub unsafe fn sendto(
    socket: CSocket,
    buf: Buf,
    len: BufLen,
    flags: libc::c_int,
    to: *const SockAddr,
    tolen: SockLen,
) -> CouldFail {
    unsafe { ws::sendto(socket, buf as *const u8, len, flags, to, tolen) }
}

pub unsafe fn recvfrom(
    socket: CSocket,
    buf: MutBuf,
    len: BufLen,
    flags: libc::c_int,
    addr: *mut SockAddr,
    addrlen: *mut SockLen,
) -> CouldFail {
    unsafe { ws::recvfrom(socket, buf as *mut u8, len, flags, addr, addrlen) }
}

#[inline]
pub fn retry<F>(f: &mut F) -> libc::c_int
where
    F: FnMut() -> libc::c_int,
{
    loop {
        let ret = f();
        if ret != -1 || errno() as isize != ws::WSAEINTR as isize {
            return ret;
        }
    }
}

fn errno() -> i32 {
    std::io::Error::last_os_error().raw_os_error().unwrap_or(0)
}