use crate::{
VMExternObj, VMFunction, VMFunctionEnvironment, VMGlobal, VMInstance, VMMemory, VMTable,
};
use core::slice::Iter;
use std::{cell::UnsafeCell, fmt, marker::PhantomData, num::NonZeroUsize, ptr::NonNull};
use wasmer_types::StoreId;
pub trait StoreObject: Sized {
fn list(ctx: &StoreObjects) -> &Vec<Self>;
fn list_mut(ctx: &mut StoreObjects) -> &mut Vec<Self>;
}
macro_rules! impl_context_object {
($($field:ident => $ty:ty,)*) => {
$(
impl StoreObject for $ty {
fn list(ctx: &StoreObjects) -> &Vec<Self> {
&ctx.$field
}
fn list_mut(ctx: &mut StoreObjects) -> &mut Vec<Self> {
&mut ctx.$field
}
}
)*
};
}
impl_context_object! {
functions => VMFunction,
tables => VMTable,
globals => VMGlobal,
instances => VMInstance,
memories => VMMemory,
extern_objs => VMExternObj,
function_environments => VMFunctionEnvironment,
}
#[derive(Debug, Default)]
pub struct StoreObjects {
id: StoreId,
memories: Vec<VMMemory>,
tables: Vec<VMTable>,
globals: Vec<VMGlobal>,
functions: Vec<VMFunction>,
instances: Vec<VMInstance>,
extern_objs: Vec<VMExternObj>,
function_environments: Vec<VMFunctionEnvironment>,
}
impl StoreObjects {
pub fn id(&self) -> StoreId {
self.id
}
pub fn set_id(&mut self, id: StoreId) {
self.id = id;
}
pub fn get_2_mut<T: StoreObject>(
&mut self,
a: InternalStoreHandle<T>,
b: InternalStoreHandle<T>,
) -> (&mut T, &mut T) {
assert_ne!(a.index(), b.index());
let list = T::list_mut(self);
if a.index() < b.index() {
let (low, high) = list.split_at_mut(b.index());
(&mut low[a.index()], &mut high[0])
} else {
let (low, high) = list.split_at_mut(a.index());
(&mut high[0], &mut low[a.index()])
}
}
pub fn iter_globals(&self) -> Iter<VMGlobal> {
self.globals.iter()
}
pub fn as_u128_globals(&self) -> Vec<u128> {
self.iter_globals()
.map(|v| unsafe { v.vmglobal().as_ref().val.u128 })
.collect()
}
pub fn set_global_unchecked(&self, idx: usize, val: u128) {
assert!(idx < self.globals.len());
unsafe {
self.globals[idx].vmglobal().as_mut().val.u128 = val;
}
}
}
#[cfg_attr(feature = "artifact-size", derive(loupe::MemoryUsage))]
pub struct StoreHandle<T> {
id: StoreId,
internal: InternalStoreHandle<T>,
}
impl<T> Clone for StoreHandle<T> {
fn clone(&self) -> Self {
Self {
id: self.id,
internal: self.internal,
}
}
}
impl<T> std::hash::Hash for StoreHandle<T> {
fn hash<H: std::hash::Hasher>(&self, state: &mut H) {
self.id.hash(state);
self.internal.idx.hash(state);
}
}
impl<T: StoreObject> fmt::Debug for StoreHandle<T> {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
f.debug_struct("StoreHandle")
.field("id", &self.id)
.field("internal", &self.internal.index())
.finish()
}
}
impl<T: StoreObject> PartialEq for StoreHandle<T> {
fn eq(&self, other: &Self) -> bool {
self.id == other.id && self.internal == other.internal
}
}
impl<T: StoreObject> Eq for StoreHandle<T> {}
impl<T: StoreObject> StoreHandle<T> {
pub fn new(ctx: &mut StoreObjects, val: T) -> Self {
Self {
id: ctx.id,
internal: InternalStoreHandle::new(ctx, val),
}
}
pub fn get<'a>(&self, ctx: &'a StoreObjects) -> &'a T {
assert_eq!(self.id, ctx.id, "object used with the wrong context");
self.internal.get(ctx)
}
pub fn get_mut<'a>(&self, ctx: &'a mut StoreObjects) -> &'a mut T {
assert_eq!(self.id, ctx.id, "object used with the wrong context");
self.internal.get_mut(ctx)
}
pub fn internal_handle(&self) -> InternalStoreHandle<T> {
self.internal
}
pub fn store_id(&self) -> StoreId {
self.id
}
pub fn set_store_id(&mut self, id: StoreId) {
self.id = id;
}
pub unsafe fn from_internal(id: StoreId, internal: InternalStoreHandle<T>) -> Self {
Self { id, internal }
}
}
#[repr(transparent)]
pub struct InternalStoreHandle<T> {
idx: NonZeroUsize,
marker: PhantomData<fn() -> T>,
}
#[cfg(feature = "artifact-size")]
impl<T> loupe::MemoryUsage for InternalStoreHandle<T> {
fn size_of_val(&self, _tracker: &mut dyn loupe::MemoryUsageTracker) -> usize {
std::mem::size_of_val(&self)
}
}
impl<T> Clone for InternalStoreHandle<T> {
fn clone(&self) -> Self {
*self
}
}
impl<T> Copy for InternalStoreHandle<T> {}
impl<T> fmt::Debug for InternalStoreHandle<T> {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
f.debug_struct("InternalStoreHandle")
.field("idx", &self.idx)
.finish()
}
}
impl<T> PartialEq for InternalStoreHandle<T> {
fn eq(&self, other: &Self) -> bool {
self.idx == other.idx
}
}
impl<T> Eq for InternalStoreHandle<T> {}
impl<T: StoreObject> InternalStoreHandle<T> {
pub fn new(ctx: &mut StoreObjects, val: T) -> Self {
let list = T::list_mut(ctx);
let idx = NonZeroUsize::new(list.len() + 1).unwrap();
list.push(val);
Self {
idx,
marker: PhantomData,
}
}
pub fn get<'a>(&self, ctx: &'a StoreObjects) -> &'a T {
&T::list(ctx)[self.idx.get() - 1]
}
pub fn get_mut<'a>(&self, ctx: &'a mut StoreObjects) -> &'a mut T {
&mut T::list_mut(ctx)[self.idx.get() - 1]
}
pub(crate) fn index(&self) -> usize {
self.idx.get()
}
pub(crate) fn from_index(idx: usize) -> Option<Self> {
NonZeroUsize::new(idx).map(|idx| Self {
idx,
marker: PhantomData,
})
}
}
pub enum MaybeInstanceOwned<T> {
Host(Box<UnsafeCell<T>>),
Instance(NonNull<T>),
}
impl<T> MaybeInstanceOwned<T> {
pub fn as_ptr(&self) -> NonNull<T> {
match self {
Self::Host(p) => unsafe { NonNull::new_unchecked(p.get()) },
Self::Instance(p) => *p,
}
}
}
impl<T> std::fmt::Debug for MaybeInstanceOwned<T>
where
T: std::fmt::Debug,
{
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
match self {
Self::Host(p) => {
write!(f, "host(")?;
p.as_ref().fmt(f)?;
write!(f, ")")
}
Self::Instance(p) => {
write!(f, "instance(")?;
unsafe { p.as_ref().fmt(f)? };
write!(f, ")")
}
}
}
}