may_waiter 0.1.1

#[cfg_attr(test, macro_use)]
extern crate may;

use std::sync::atomic::Ordering;
use std::time::Duration;
use std::{fmt, io};

use may::coroutine;
use may::sync::{AtomicOption, Blocker};

mod waiter_map;

// ineternal waiter implementation
struct Waiter<T> {
    blocker: Blocker,
    rsp: AtomicOption<T>,
}

impl<T> Waiter<T> {
    fn new() -> Self {
        Waiter {
            blocker: Blocker::new(false),
            rsp: AtomicOption::none(),
        }
    }

    fn set_rsp(&self, rsp: T) {
        // set the response
        self.rsp.swap(rsp, Ordering::Release);
        // wake up the blocker
        self.blocker.unpark();
    }

    fn cancel_wait(&self) {
        // wake up the blocker without rsp
        self.blocker.unpark()
    }

    fn wait_rsp<D: Into<Option<Duration>>>(&self, timeout: D) -> io::Result<T> {
        use coroutine::ParkError;
        use io::{Error, ErrorKind};

        match self.blocker.park(timeout.into()) {
            Ok(_) => self
                .rsp
                .take(Ordering::Acquire)
                .ok_or_else(|| Error::new(io::ErrorKind::NotFound, "wait rsp cancelled")),
            Err(ParkError::Timeout) => Err(Error::new(ErrorKind::TimedOut, "wait rsp timeout")),
            Err(ParkError::Canceled) => {
                coroutine::trigger_cancel_panic();
            }
        }
    }
}

impl<T> fmt::Debug for Waiter<T> {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        write!(f, "Waiter{{ ... }}")
    }
}

impl<T> Default for Waiter<T> {
    fn default() -> Self {
        Waiter::new()
    }
}

pub use waiter_map::{WaiterGuard, WaiterMap};