moirai-pal 0.7.0

Platform Abstraction Layer for Moirai async I/O operations
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

//! The [`Reactor`] trait surface for [`WsaPollReactor`].

use std::io;
use std::time::Duration;

use crate::reactor::registration::PlatformUpdateFailure;
use crate::{Event, Interest, RawFd, Reactor};

use super::types::{WsaPollReactor, lock_mutex};

impl Reactor for WsaPollReactor {
    fn register_fd(&self, fd: RawFd, interest: Interest) -> io::Result<()> {
        self.replace_registration(fd, interest)
            .map_err(PlatformUpdateFailure::into_error)
    }

    fn unregister_fd(&self, fd: RawFd) -> io::Result<()> {
        lock_mutex(&self.registrations).remove(fd as usize);
        Ok(())
    }

    fn poll_events(&self, timeout: Option<Duration>) -> io::Result<Vec<Event>> {
        self.poll_events_with(timeout, |event, _generation, _invalidated| event)
    }

    fn wake(&self) -> io::Result<()> {
        self.wake.send_to(&[1u8], self.wake_addr).map(|_| ())
    }
}