rust_asio 0.6.0

Asynchronous I/O library
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

use core::{Reactor, IntrFd};
use ffi::write;

use std::io;
use libc::{eventfd, EFD_CLOEXEC, EFD_NONBLOCK};

pub struct EventFdInterrupter {
    efd: IntrFd,
}

impl EventFdInterrupter {
    pub fn new() -> io::Result<Self> {
        let efd = libc_try!(eventfd(0, EFD_CLOEXEC | EFD_NONBLOCK));
        Ok(EventFdInterrupter {
            efd: IntrFd::new::<Self>(efd),
        })
    }

    pub fn startup(&self, ctx: &Reactor) {
        ctx.register_intr_fd(&self.efd)
    }

    pub fn cleanup(&self, ctx: &Reactor) {
        ctx.deregister_intr_fd(&self.efd)
    }

    pub fn interrupt(&self) {
        let buf = [1,0,0,0,0,0,0,0];
        libc_ign!(write(&self.efd, &buf));
    }
}