-
-
Notifications
You must be signed in to change notification settings - Fork 73
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
bb5974f
commit 0f5d148
Showing
15 changed files
with
261 additions
and
74 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,153 @@ | ||
| use crate::garbage_collector::GcPtr; | ||
| use crate::{Marshal, ReturnTypeReflection, Runtime}; | ||
| use abi::TypeInfo; | ||
| use memory::gc::{GcRuntime, HasIndirectionPtr}; | ||
| use memory::{ArrayMemoryLayout, ArrayType, CompositeType}; | ||
| use once_cell::sync::OnceCell; | ||
| use std::marker::PhantomData; | ||
| use std::ptr::NonNull; | ||
|
|
||
| /// Represents a Mun array pointer. | ||
| #[repr(transparent)] | ||
| #[derive(Clone)] | ||
| pub struct RawArray(GcPtr); | ||
|
|
||
| impl RawArray { | ||
| /// Returns a pointer to the array memory. | ||
| /// | ||
| /// # Safety | ||
| /// | ||
| /// Dereferencing might cause undefined behavior | ||
| pub unsafe fn get_ptr(&self) -> NonNull<u8> { | ||
| self.0.deref() | ||
| } | ||
| } | ||
|
|
||
| /// Type-agnostic wrapper for interoperability with a Mun array. This is merely a reference to the | ||
| /// Mun array, that will be garbage collected unless it is rooted. | ||
| #[derive(Clone)] | ||
| pub struct ArrayRef<'a, T: Marshal<'a>> { | ||
| raw: RawArray, | ||
| runtime: &'a Runtime, | ||
| _phantom: PhantomData<T>, | ||
| } | ||
|
|
||
| impl<'array, T: Marshal<'array> + 'array> ArrayRef<'array, T> { | ||
| /// Creates a `StructRef` that wraps a raw Mun struct. | ||
| fn new<'runtime>(raw: RawArray, runtime: &'runtime Runtime) -> Self | ||
| where | ||
| 'runtime: 'array, | ||
| { | ||
| Self { | ||
| raw, | ||
| runtime, | ||
| _phantom: Default::default(), | ||
| } | ||
| } | ||
|
|
||
| /// Consumes the `ArrayRef`, returning a raw Mun array. | ||
| pub fn into_raw(self) -> RawArray { | ||
| self.raw | ||
| } | ||
|
|
||
| /// Returns the number of elements stored in the array | ||
| pub fn len(&self) -> usize { | ||
| unsafe { | ||
| let value_ty = self.runtime.gc.ptr_type(self.raw.0); | ||
| let array_ty = value_ty | ||
| .as_array() | ||
| .expect("type of the array value must be an array"); | ||
| let value_ptr = self.raw.get_ptr(); | ||
| array_ty.retrieve_length(value_ptr) | ||
| } | ||
| } | ||
|
|
||
| /// Returns true if this array does not contain a single element. | ||
| pub fn is_empty(&self) -> bool { | ||
| self.len() == 0 | ||
| } | ||
|
|
||
| /// Returns the length of the array | ||
| pub fn capacity(&self) -> usize { | ||
| unsafe { | ||
| let value_ty = self.runtime.gc.ptr_type(self.raw.0); | ||
| let array_ty = value_ty | ||
| .as_array() | ||
| .expect("type of the array value must be an array"); | ||
| let value_ptr = self.raw.get_ptr(); | ||
| array_ty.retrieve_capacity(value_ptr) | ||
| } | ||
| } | ||
|
|
||
| /// Returns an iterator to iterate over the elements of the array. | ||
| pub fn iter(&self) -> impl Iterator<Item = T> + 'array | ||
| where | ||
| T: 'array, | ||
| { | ||
| let value_ty = self.runtime.gc.ptr_type(self.raw.0); | ||
| let array_ty = value_ty | ||
| .as_array() | ||
| .expect("type of the array value must be an array"); | ||
| let value_ptr = unsafe { self.raw.get_ptr() }; | ||
| let iter = unsafe { array_ty.elements(value_ptr) }; | ||
| let element_ty = unsafe { array_ty.element_type().into_inner().as_ref() }; | ||
| let runtime = self.runtime; | ||
| iter.map(move |element_ptr| { | ||
| T::marshal_from_ptr(element_ptr.cast(), runtime, Some(element_ty)) | ||
| }) | ||
| } | ||
| } | ||
|
|
||
| impl<'a, T: Marshal<'a> + ReturnTypeReflection> ReturnTypeReflection for ArrayRef<'a, T> { | ||
| fn type_guid() -> abi::Guid { | ||
| // TODO: Once `const_fn` lands, replace this with a const md5 hash | ||
| static GUID: OnceCell<abi::Guid> = OnceCell::new(); | ||
| *GUID.get_or_init(|| abi::Guid(md5::compute(<Self as ReturnTypeReflection>::type_name()).0)) | ||
| } | ||
|
|
||
| fn type_name() -> &'static str { | ||
| static NAME: OnceCell<String> = OnceCell::new(); | ||
| NAME.get_or_init(|| format!("[{}]", T::type_name())) | ||
| } | ||
|
|
||
| /// Returns true if this type equals the given type information | ||
| fn equals_type(type_info: &abi::TypeInfo) -> bool { | ||
| type_info | ||
| .as_array() | ||
| .map(|arr| T::equals_type(arr.element_type())) | ||
| .unwrap_or(false) | ||
| } | ||
| } | ||
|
|
||
| impl<'a, T: Marshal<'a> + 'a> Marshal<'a> for ArrayRef<'a, T> { | ||
| type MunType = RawArray; | ||
|
|
||
| fn marshal_from<'runtime>(value: Self::MunType, runtime: &'runtime Runtime) -> Self | ||
| where | ||
| Self: 'a, | ||
| 'runtime: 'a, | ||
| { | ||
| ArrayRef::new(value, runtime) | ||
| } | ||
|
|
||
| fn marshal_into(self) -> Self::MunType { | ||
| self.raw | ||
| } | ||
|
|
||
| fn marshal_from_ptr<'runtime>( | ||
| ptr: NonNull<Self::MunType>, | ||
| runtime: &'runtime Runtime, | ||
| _type_info: Option<&TypeInfo>, | ||
| ) -> Self | ||
| where | ||
| Self: 'a, | ||
| 'runtime: 'a, | ||
| { | ||
| let handle = unsafe { *ptr.cast::<GcPtr>().as_ptr() }; | ||
| ArrayRef::new(RawArray(handle), runtime) | ||
| } | ||
|
|
||
| fn marshal_to_ptr(value: Self, mut ptr: NonNull<Self::MunType>, _type_info: Option<&TypeInfo>) { | ||
| unsafe { *ptr.as_mut() = value.into_raw() }; | ||
| } | ||
| } |
Oops, something went wrong.