use std::marker::PhantomData; use std::mem::ManuallyDrop; use std::ops::Deref; use std::sync::Arc; use std::task::{RawWaker, RawWakerVTable, Waker}; /// Simplfied waking interface based on Arcs pub(crate) trait Wake: Send + Sync { /// Wake by value fn wake(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 = &**wake as *const _ as *const (); 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 inc_ref_count(data: *const ()) { // Retain Arc, but don't touch refcount by wrapping in ManuallyDrop let arc = ManuallyDrop::new(Arc::::from_raw(data as *const T)); // Now increase refcount, but don't drop new refcount either let arc_clone: ManuallyDrop<_> = arc.clone(); // Drop explicitly to avoid clippy warnings drop(arc); drop(arc_clone); } unsafe fn clone_arc_raw(data: *const ()) -> RawWaker { inc_ref_count::(data); RawWaker::new(data, waker_vtable::()) } unsafe fn wake_arc_raw(data: *const ()) { let arc: Arc = 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 let arc = ManuallyDrop::new(Arc::::from_raw(data as *const T)); Wake::wake_by_ref(&arc); } unsafe fn drop_arc_raw(data: *const ()) { drop(Arc::::from_raw(data as *const T)) }