blaze-rs 1.0.3

A Rustified OpenCL Experience
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69

use super::{consumer::Consumer, Event};
use crate::prelude::Result;
use futures::{future::FusedFuture, Future, FutureExt};
use opencl_sys::*;
use std::{
    ffi::c_void,
    task::{Poll, Waker},
};
use utils_atomics::{
    flag::mpmc::{AsyncFlag, AsyncSubscribe},
    FillQueue,
};

/// Future for [`join_async`](super::Event::join_async).
#[cfg_attr(docsrs, doc(cfg(feature = "futures")))]
#[derive(Debug, Clone)]
pub struct EventWait<C> {
    inner: Option<Event<C>>,
    sub: AsyncSubscribe,
}

impl<C: Unpin + Consumer> EventWait<C> {
    #[inline(always)]
    pub fn new(inner: Event<C>) -> Result<Self> {
        let (flag, sub) = utils_atomics::flag::mpmc::async_flag();
        unsafe {
            inner.on_complete_raw(wake_future, flag.into_raw() as *mut _)?;
        }

        return Ok(Self {
            inner: Some(inner),
            sub,
        });
    }
}

impl<C: Unpin + Consumer> Future for EventWait<C> {
    type Output = Result<C::Output>;

    #[inline(always)]
    fn poll(
        mut self: std::pin::Pin<&mut Self>,
        cx: &mut std::task::Context<'_>,
    ) -> std::task::Poll<Self::Output> {
        let this = &mut *self;
        if this.sub.poll_unpin(cx).is_ready() {
            let event = this.inner.take().unwrap();
            return Poll::Ready(event.status().and_then(|_| unsafe { event.consume() }));
        }

        return Poll::Pending;
    }
}

impl<C: Unpin + Consumer> FusedFuture for EventWait<C> {
    #[inline(always)]
    fn is_terminated(&self) -> bool {
        self.inner.is_none()
    }
}

#[doc(hidden)]
unsafe extern "C" fn wake_future(
    _event: cl_event,
    _event_command_status: cl_int,
    user_data: *mut c_void,
) {
    let _ = AsyncFlag::from_raw(user_data as *const FillQueue<Waker>);
}