use crate::loom::sync::Arc; use std::marker::PhantomData; use std::mem::ManuallyDrop; use std::ops::Deref; use std::task::{RawWaker, RawWakerVTable, Waker}; /// Simplified waking interface based on Arcs. pub(crate) trait Wake: Send + Sync + Sized + 'static { /// Wake by value. fn wake(arc_self: Arc); /// Wake by reference. fn wake_by_ref(arc_self: &Arc); } /// A `Waker` that is only valid for a given lifetime. #[derive(Debug)] pub(crate) struct WakerRef<'a> { waker: ManuallyDrop, _p: PhantomData<&'a ()>, } impl Deref for WakerRef<'_> { type Target = Waker; fn deref(&self) -> &Waker { &self.waker } } /// Creates a reference to a `Waker` from a reference to `Arc`. pub(crate) fn waker_ref(wake: &Arc) -> WakerRef<'_> { let ptr = Arc::as_ptr(wake).cast::<()>(); let waker = unsafe { Waker::from_raw(RawWaker::new(ptr, waker_vtable::())) }; WakerRef { waker: ManuallyDrop::new(waker), _p: PhantomData, } } fn waker_vtable() -> &'static RawWakerVTable { &RawWakerVTable::new( clone_arc_raw::, wake_arc_raw::, wake_by_ref_arc_raw::, drop_arc_raw::, ) } unsafe fn clone_arc_raw(data: *const ()) -> RawWaker { // Safety: `data` was created from an `Arc::as_ptr` in function `waker_ref`. unsafe { Arc::::increment_strong_count(data as *const T); } RawWaker::new(data, waker_vtable::()) } unsafe fn wake_arc_raw(data: *const ()) { // Safety: `data` was created from an `Arc::as_ptr` in function `waker_ref`. let arc: Arc = unsafe { Arc::from_raw(data as *const T) }; Wake::wake(arc); } // used by `waker_ref` unsafe fn wake_by_ref_arc_raw(data: *const ()) { // Retain Arc, but don't touch refcount by wrapping in ManuallyDrop // Safety: `data` was created from an `Arc::as_ptr` in function `waker_ref`. let arc = ManuallyDrop::new(unsafe { Arc::::from_raw(data.cast()) }); Wake::wake_by_ref(&arc); } unsafe fn drop_arc_raw(data: *const ()) { // Safety: `data` was created from an `Arc::as_ptr` in function `waker_ref`. drop(unsafe { Arc::::from_raw(data.cast()) }); }