use super::*;
use core::cell::Cell;
use core::convert::TryInto;
pub unsafe trait VTableMetaDropInPlace: VTableMeta {
unsafe fn drop_in_place(vtable: &Self::VTable, ptr: *mut u8) -> vrc::Layout;
unsafe fn dealloc(vtable: &Self::VTable, ptr: *mut u8, layout: vrc::Layout);
}
pub struct Dyn(());
#[repr(C)]
#[derive(Clone, Copy)]
pub struct Layout {
pub size: usize,
pub align: usize,
}
impl From<core::alloc::Layout> for Layout {
fn from(layout: core::alloc::Layout) -> Self {
Self { size: layout.size(), align: layout.align() }
}
}
impl core::convert::TryFrom<Layout> for core::alloc::Layout {
type Error = core::alloc::LayoutErr;
fn try_from(value: Layout) -> Result<Self, Self::Error> {
Self::from_size_align(value.size, value.align)
}
}
#[repr(C)]
struct VRcInner<'vt, VTable: VTableMeta, X> {
vtable: &'vt VTable::VTable,
strong_ref: Cell<u32>,
weak_ref: Cell<u32>,
data_offset: u16,
data: X,
}
impl<'vt, VTable: VTableMeta, X> VRcInner<'vt, VTable, X> {
fn data_ptr(&self) -> *const X {
let ptr = self as *const Self as *const u8;
unsafe { ptr.add(self.data_offset as usize) as *const X }
}
fn as_ref(&self) -> &X {
let ptr = self as *const Self as *const u8;
unsafe { &*(ptr.add(self.data_offset as usize) as *const X) }
}
}
#[repr(transparent)]
pub struct VRc<VTable: VTableMetaDropInPlace + 'static, X = Dyn> {
inner: NonNull<VRcInner<'static, VTable, X>>,
}
impl<VTable: VTableMetaDropInPlace + 'static, X> Drop for VRc<VTable, X> {
fn drop(&mut self) {
unsafe {
let inner = self.inner.as_ref();
inner.strong_ref.set(inner.strong_ref.get() - 1);
if inner.strong_ref.get() == 0 {
let data = inner.data_ptr() as *const _ as *const u8 as *mut u8;
let mut layout = VTable::drop_in_place(inner.vtable, data);
layout = core::alloc::Layout::new::<VRcInner<VTable, ()>>()
.extend(layout.try_into().unwrap())
.unwrap()
.0
.pad_to_align()
.into();
inner.weak_ref.set(inner.weak_ref.get() - 1);
if inner.weak_ref.get() == 0 {
let vtable = inner.vtable;
VTable::dealloc(vtable, self.inner.cast().as_ptr(), layout);
} else {
self.inner.cast::<VRcInner<VTable, Layout>>().as_mut().data = layout;
}
}
}
}
}
impl<VTable: VTableMetaDropInPlace, X: HasStaticVTable<VTable>> VRc<VTable, X> {
pub fn new(data: X) -> Self {
let layout = core::alloc::Layout::new::<VRcInner<VTable, X>>().pad_to_align();
let layout_with_layout = core::alloc::Layout::new::<VRcInner<VTable, Layout>>();
let layout = core::alloc::Layout::from_size_align(
layout.size().max(layout_with_layout.size()),
layout.align().max(layout_with_layout.align()),
)
.unwrap();
let mem = unsafe { std::alloc::alloc(layout) as *mut VRcInner<VTable, X> };
let inner = NonNull::new(mem).unwrap();
assert!(!mem.is_null());
unsafe {
mem.write(VRcInner {
vtable: X::static_vtable(),
strong_ref: Cell::new(1),
weak_ref: Cell::new(1), data_offset: 0,
data,
});
(*mem).data_offset =
(&(*mem).data as *const _ as usize - mem as *const _ as usize) as u16;
VRc { inner }
}
}
pub fn into_dyn(this: Self) -> VRc<VTable, Dyn>
where
Self: 'static,
{
unsafe { core::mem::transmute(this) }
}
}
impl<VTable: VTableMetaDropInPlace, X> VRc<VTable, X> {
pub fn as_pin_ref(&self) -> Pin<&X> {
unsafe { Pin::new_unchecked(&*self) }
}
pub fn borrow(this: &Self) -> VRef<'_, VTable> {
unsafe {
let inner = this.inner.cast::<VRcInner<VTable, u8>>();
VRef::from_raw(
NonNull::from(inner.as_ref().vtable),
NonNull::from(&*inner.as_ref().data_ptr()),
)
}
}
pub fn borrow_pin<'b>(this: &'b Self) -> Pin<VRef<'b, VTable>> {
unsafe { Pin::new_unchecked(Self::borrow(this)) }
}
pub fn downgrade(this: &Self) -> VWeak<VTable, X> {
let inner = unsafe { this.inner.as_ref() };
inner.weak_ref.set(inner.weak_ref.get() + 1);
VWeak { inner: Some(this.inner) }
}
pub fn strong_count(this: &Self) -> usize {
unsafe { this.inner.as_ref().strong_ref.get() as usize }
}
pub fn ptr_eq(this: &Self, other: &Self) -> bool {
this.inner == other.inner
}
}
impl<VTable: VTableMetaDropInPlace + 'static, X> Clone for VRc<VTable, X> {
fn clone(&self) -> Self {
let inner = unsafe { self.inner.as_ref() };
inner.strong_ref.set(inner.strong_ref.get() + 1);
Self { inner: self.inner }
}
}
impl<VTable: VTableMetaDropInPlace, X > Deref for VRc<VTable, X> {
type Target = X;
fn deref(&self) -> &Self::Target {
let inner = unsafe { self.inner.as_ref() };
inner.as_ref()
}
}
#[repr(transparent)]
pub struct VWeak<VTable: VTableMetaDropInPlace + 'static, X = Dyn> {
inner: Option<NonNull<VRcInner<'static, VTable, X>>>,
}
impl<VTable: VTableMetaDropInPlace + 'static, X> Default for VWeak<VTable, X> {
fn default() -> Self {
Self { inner: None }
}
}
impl<VTable: VTableMetaDropInPlace + 'static, X> Clone for VWeak<VTable, X> {
fn clone(&self) -> Self {
if let Some(inner) = self.inner {
let inner = unsafe { inner.as_ref() };
inner.weak_ref.set(inner.weak_ref.get() + 1);
}
VWeak { inner: self.inner }
}
}
impl<T: VTableMetaDropInPlace + 'static, X> Drop for VWeak<T, X> {
fn drop(&mut self) {
if let Some(i) = self.inner {
let inner = unsafe { i.as_ref() };
inner.weak_ref.set(inner.weak_ref.get() - 1);
if inner.weak_ref.get() == 0 {
let vtable = inner.vtable;
unsafe {
let layout = i.cast::<VRcInner<T, Layout>>().as_ref().data;
T::dealloc(vtable, i.cast().as_ptr(), layout);
}
}
}
}
}
impl<VTable: VTableMetaDropInPlace + 'static, X> VWeak<VTable, X> {
pub fn upgrade(&self) -> Option<VRc<VTable, X>> {
if let Some(i) = self.inner {
let inner = unsafe { i.as_ref() };
if inner.strong_ref.get() == 0 {
None
} else {
inner.strong_ref.set(inner.strong_ref.get() + 1);
Some(VRc { inner: i })
}
} else {
None
}
}
}
impl<VTable: VTableMetaDropInPlace + 'static, X: HasStaticVTable<VTable> + 'static>
VWeak<VTable, X>
{
pub fn into_dyn(self) -> VWeak<VTable, Dyn> {
unsafe { core::mem::transmute(self) }
}
}