wasmer 7.1.0

High-performance WebAssembly runtime
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104

//! Data types, functions and traits for `sys` runtime's `Tag` implementation.
use std::any::Any;

use wasmer_types::{TagType, Type};
use wasmer_vm::{StoreHandle, StoreId};

use crate::{
    AsStoreMut, AsStoreRef, BackendTag, Tag, Value,
    sys::vm::{VMExceptionObj, VMExceptionRef},
};

#[derive(Debug, Clone, PartialEq, Eq)]
/// A WebAssembly `exnref` in the `sys` runtime.
pub(crate) struct Exception {
    exnref: wasmer_vm::VMExceptionRef,
}

impl Exception {
    /// Creates a new exception with the given tag and payload, and also creates
    /// a reference to it, returning the reference.
    #[allow(irrefutable_let_patterns)]
    pub fn new(store: &mut impl AsStoreMut, tag: &crate::sys::tag::Tag, payload: &[Value]) -> Self {
        if !tag.is_from_store(store) {
            panic!("cannot create Exception with Tag from another Store");
        }

        let store_objects = store.as_store_ref().objects().as_sys();
        let store_id = store_objects.id();

        let tag_ty = tag.handle.get(store_objects).signature.params();

        if tag_ty.len() != payload.len() {
            panic!("payload length mismatch");
        }

        let values = payload
            .iter()
            .enumerate()
            .map(|(i, v)| {
                if v.ty() != tag_ty[i] {
                    panic!("payload type mismatch");
                }
                v.as_raw(store)
            })
            .collect::<Vec<_>>()
            .into_boxed_slice();

        let ctx = store.objects_mut().as_sys_mut();
        let exception = wasmer_vm::VMExceptionObj::new(tag.handle.internal_handle(), values);
        let exn_handle = wasmer_vm::StoreHandle::new(ctx, exception);
        let exnref = wasmer_vm::VMExceptionRef(exn_handle);

        Self { exnref }
    }

    pub fn exnref(&self) -> wasmer_vm::VMExceptionRef {
        self.exnref.clone()
    }

    pub fn from_exnref(exnref: wasmer_vm::VMExceptionRef) -> Self {
        Self { exnref }
    }

    pub fn is_from_store(&self, store: &impl AsStoreRef) -> bool {
        self.exnref.0.store_id() == store.as_store_ref().objects().id()
    }

    pub fn tag(&self, store: &impl AsStoreRef) -> crate::sys::tag::Tag {
        if !self.is_from_store(store) {
            panic!("Exception is from another Store");
        }
        let ctx = store.as_store_ref().objects().as_sys();
        let exception = self.exnref.0.get(ctx);
        let tag_handle = exception.tag();
        crate::sys::tag::Tag {
            handle: unsafe { StoreHandle::from_internal(ctx.id(), tag_handle) },
        }
    }

    pub fn payload(&self, store: &mut impl AsStoreMut) -> Vec<Value> {
        if !self.is_from_store(store) {
            panic!("Exception is from another Store");
        }
        let ctx = store.as_store_ref().objects().as_sys();
        let exception = self.exnref.0.get(ctx);
        let params_ty = exception.tag().get(ctx).signature.params().to_vec();
        let payload_ptr = exception.payload();

        assert_eq!(params_ty.len(), payload_ptr.len());

        params_ty
            .iter()
            .zip(unsafe { payload_ptr.as_ref().iter() })
            .map(|(ty, raw)| unsafe { Value::from_raw(store, *ty, *raw) })
            .collect()
    }
}

#[cfg(feature = "artifact-size")]
impl loupe::MemoryUsage for Exception {
    fn size_of_val(&self, tracker: &mut dyn loupe::MemoryUsageTracker) -> usize {
        std::mem::size_of::<Self>()
    }
}