reactors 0.1.4

Performance-focused cross-platform asynchronous IO implementation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! Builtin [`Reactor`](crate::Reactor) implementation for io system
mod poller;
pub use poller::*;

pub mod file;
pub mod socket;

#[cfg(target_family = "unix")]
unsafe fn noblock(fd: i32) -> std::io::Result<()> {
    use libc::*;

    let flags = fcntl(fd, F_GETFL);

    if flags < 0 {
        return Err(std::io::Error::last_os_error());
    }

    if fcntl(fd, F_SETFL, flags | O_NONBLOCK) < 0 {
        return Err(std::io::Error::last_os_error());
    }

    Ok(())
}