Struct Epoll

Source

pub struct Epoll { /* private fields */ }

Expand description

Epoll structure

Implementations§

Source §

impl Epoll

Source

pub fn create() -> Result<Epoll>

Create a new epoll instance

Examples found in repository ?

examples/example.rs (line 8)

7fn main() {
8    let mut epoll = Epoll::create().unwrap();
9    let mut listener = UnixListener::bind("test.sock").unwrap();
10    epoll.register(listener.as_raw_fd(), LISTENER, Interest::Both, Mode::Edge).unwrap();
11
12    loop {
13        let mut events = epoll.poll(Some(Duration::from_millis(2000))).unwrap();
14
15        for event in events.iter() {
16            // Handle the event, read from the socket
17            // respond to it etc
18            // Here you could also use the utility functions provided in copoll::event;
19            // example just breaks on first event
20            break;
21        }
22    }
23}

Source

pub fn poll(&mut self, timeout: Option<Duration>) -> Result<Events>

Poll the epoll instance for new events. Call this one on each iteration of your event loop

Examples found in repository ?

examples/example.rs (line 13)

7fn main() {
8    let mut epoll = Epoll::create().unwrap();
9    let mut listener = UnixListener::bind("test.sock").unwrap();
10    epoll.register(listener.as_raw_fd(), LISTENER, Interest::Both, Mode::Edge).unwrap();
11
12    loop {
13        let mut events = epoll.poll(Some(Duration::from_millis(2000))).unwrap();
14
15        for event in events.iter() {
16            // Handle the event, read from the socket
17            // respond to it etc
18            // Here you could also use the utility functions provided in copoll::event;
19            // example just breaks on first event
20            break;
21        }
22    }
23}

Source

pub fn register( &mut self, fd: RawFd, token: Token, interest: Interest, mode: Mode, ) -> Result<()>

Register a new file descriptor in the epoll instance

Examples found in repository ?

examples/example.rs (line 10)

7fn main() {
8    let mut epoll = Epoll::create().unwrap();
9    let mut listener = UnixListener::bind("test.sock").unwrap();
10    epoll.register(listener.as_raw_fd(), LISTENER, Interest::Both, Mode::Edge).unwrap();
11
12    loop {
13        let mut events = epoll.poll(Some(Duration::from_millis(2000))).unwrap();
14
15        for event in events.iter() {
16            // Handle the event, read from the socket
17            // respond to it etc
18            // Here you could also use the utility functions provided in copoll::event;
19            // example just breaks on first event
20            break;
21        }
22    }
23}