stdin_nonblock.rs

/// Set `stdin` to non-blocking mode.
pub fn set_stdin_nonblocking() {
    use nix::fcntl::{fcntl, FcntlArg, OFlag};

    let mut stdin_flags: OFlag = match fcntl(libc::STDIN_FILENO, FcntlArg::F_GETFL) {
        Err(err) => {
            panic!("Unable to read stdin flags: {:?}", err);
        }
        Ok(flags) => match OFlag::from_bits(flags) {
            None => panic!("Can't parse stdin flags: {:#?}", flags),
            Some(flags) => flags,
        },
    };

    stdin_flags.set(OFlag::O_NONBLOCK, true);

    match fcntl(libc::STDIN_FILENO, FcntlArg::F_SETFL(stdin_flags)) {
        Err(err) => {
            panic!("Can't set stdin flags: {:?}", err);
        }
        Ok(_) => {}
    }
}