hinix 0.1.0

// hinix/examples/eventfd.rs
//

extern crate hinix;

use std::thread;
use std::sync::Arc;
use std::time::{Duration};
use std::os::unix::io::AsRawFd;
use hinix::eventfd::{EventFd, EfdFlags};

type Result<T> = hinix::Result<T>;

fn main() -> Result<()> {
    let evtfd = EventFd::new(0, EfdFlags::empty())?;
    println!("Got it as: {:?}", evtfd.as_raw_fd());

    let evtfd = Arc::new(evtfd);
    let threvtfd = Arc::clone(&evtfd);

    thread::spawn(move || {
        for i in 1..11 {
            thread::sleep(Duration::from_millis(1000));
            println!("Signaling the event [{}]...", i);
            threvtfd.write(i).expect("Failed writing to the event");;
        }

        thread::sleep(Duration::from_millis(100));
        threvtfd.write(42).expect("Failed writing to the event");;
    });

    loop {
        println!("Waiting on the event...");
        let n = evtfd.read()?;
        if n == 42 { break; }
        println!("Got the event: {}", n);
    }

    println!("Done");
    Ok(())
}