1 //! An `Instance` contains all the runtime state used by execution of a
2 //! wasm module (except its callstack and register state). An
3 //! `InstanceHandle` is a reference-counting handle for an `Instance`.
4 
5 use crate::OpaqueRootScope;
6 use crate::code::ModuleWithCode;
7 use crate::module::ModuleRegistry;
8 use crate::prelude::*;
9 use crate::runtime::vm::const_expr::{ConstEvalContext, ConstExprEvaluator};
10 use crate::runtime::vm::export::{Export, ExportMemory};
11 use crate::runtime::vm::memory::{Memory, RuntimeMemoryCreator};
12 use crate::runtime::vm::table::{Table, TableElementType};
13 use crate::runtime::vm::vmcontext::{
14     VMBuiltinFunctionsArray, VMContext, VMFuncRef, VMFunctionImport, VMGlobalDefinition,
15     VMGlobalImport, VMMemoryDefinition, VMMemoryImport, VMOpaqueContext, VMStoreContext,
16     VMTableDefinition, VMTableImport, VMTagDefinition, VMTagImport,
17 };
18 use crate::runtime::vm::{
19     GcStore, HostResult, Imports, ModuleRuntimeInfo, SendSyncPtr, VMGlobalKind, VMStore,
20     VMStoreRawPtr, VmPtr, VmSafe, WasmFault, catch_unwind_and_record_trap,
21 };
22 use crate::store::{
23     Asyncness, InstanceId, StoreId, StoreInstanceId, StoreOpaque, StoreResourceLimiter,
24 };
25 use crate::vm::VMWasmCallFunction;
26 use alloc::sync::Arc;
27 use core::alloc::Layout;
28 use core::marker;
29 use core::ops::Range;
30 use core::pin::Pin;
31 use core::ptr::NonNull;
32 #[cfg(target_has_atomic = "64")]
33 use core::sync::atomic::AtomicU64;
34 use core::{mem, ptr};
35 #[cfg(feature = "gc")]
36 use wasmtime_environ::ModuleInternedTypeIndex;
37 use wasmtime_environ::{
38     DataIndex, DefinedGlobalIndex, DefinedMemoryIndex, DefinedTableIndex, DefinedTagIndex,
39     ElemIndex, EntityIndex, EntityRef, EntitySet, FuncIndex, GlobalIndex, HostPtr, MemoryIndex,
40     PrimaryMap, PtrSize, TableIndex, TableInitialValue, TableSegmentElements, TagIndex, Trap,
41     VMCONTEXT_MAGIC, VMOffsets, VMSharedTypeIndex, packed_option::ReservedValue,
42 };
43 #[cfg(feature = "wmemcheck")]
44 use wasmtime_wmemcheck::Wmemcheck;
45 
46 mod allocator;
47 pub use allocator::*;
48 
49 /// A type that roughly corresponds to a WebAssembly instance, but is also used
50 /// for host-defined objects.
51 ///
52 /// Instances here can correspond to actual instantiated modules, but it's also
53 /// used ubiquitously for host-defined objects. For example creating a
54 /// host-defined memory will have a `module` that looks like it exports a single
55 /// memory (and similar for other constructs).
56 ///
57 /// This `Instance` type is used as a ubiquitous representation for WebAssembly
58 /// values, whether or not they were created on the host or through a module.
59 ///
60 /// # Ownership
61 ///
62 /// This structure is never allocated directly but is instead managed through
63 /// an `InstanceHandle`. This structure ends with a `VMContext` which has a
64 /// dynamic size corresponding to the `module` configured within. Memory
65 /// management of this structure is always done through `InstanceHandle` as the
66 /// sole owner of an instance.
67 ///
68 /// # `Instance` and `Pin`
69 ///
70 /// Given an instance it is accompanied with trailing memory for the
71 /// appropriate `VMContext`. The `Instance` also holds `runtime_info` and other
72 /// information pointing to relevant offsets for the `VMContext`. Thus it is
73 /// not sound to mutate `runtime_info` after an instance is created. More
74 /// generally it's also not safe to "swap" instances, for example given two
75 /// `&mut Instance` values it's not sound to swap them as then the `VMContext`
76 /// values are inaccurately described.
77 ///
78 /// To encapsulate this guarantee this type is only ever mutated through Rust's
79 /// `Pin` type. All mutable methods here take `self: Pin<&mut Self>` which
80 /// statically disallows safe access to `&mut Instance`. There are assorted
81 /// "projection methods" to go from `Pin<&mut Instance>` to `&mut T` for
82 /// individual fields, for example `memories_mut`. More methods can be added as
83 /// necessary or methods may also be added to project multiple fields at a time
84 /// if necessary to. The precise ergonomics around getting mutable access to
85 /// some fields (but notably not `runtime_info`) is probably going to evolve
86 /// over time.
87 ///
88 /// Note that is is not sound to basically ever pass around `&mut Instance`.
89 /// That should always instead be `Pin<&mut Instance>`. All usage of
90 /// `Pin::new_unchecked` should be here in this module in just a few `unsafe`
91 /// locations and it's recommended to use existing helpers if you can.
92 #[repr(C)] // ensure that the vmctx field is last.
93 pub struct Instance {
94     /// The index, within a `Store` that this instance lives at
95     id: InstanceId,
96 
97     /// The runtime info (corresponding to the "compiled module"
98     /// abstraction in higher layers) that is retained and needed for
99     /// lazy initialization. This provides access to the underlying
100     /// Wasm module entities, the compiled JIT code, metadata about
101     /// functions, lazy initialization state, etc.
102     //
103     // SAFETY: this field cannot be overwritten after an instance is created. It
104     // must contain this exact same value for the entire lifetime of this
105     // instance. This enables borrowing the info's `Module` and this instance at
106     // the same time (instance mutably, module not). Additionally it enables
107     // borrowing a store mutably at the same time as a contained instance.
108     runtime_info: ModuleRuntimeInfo,
109 
110     /// WebAssembly linear memory data.
111     ///
112     /// This is where all runtime information about defined linear memories in
113     /// this module lives.
114     ///
115     /// The `MemoryAllocationIndex` was given from our `InstanceAllocator` and
116     /// must be given back to the instance allocator when deallocating each
117     /// memory.
118     memories: PrimaryMap<DefinedMemoryIndex, (MemoryAllocationIndex, Memory)>,
119 
120     /// WebAssembly table data.
121     ///
122     /// Like memories, this is only for defined tables in the module and
123     /// contains all of their runtime state.
124     ///
125     /// The `TableAllocationIndex` was given from our `InstanceAllocator` and
126     /// must be given back to the instance allocator when deallocating each
127     /// table.
128     tables: PrimaryMap<DefinedTableIndex, (TableAllocationIndex, Table)>,
129 
130     /// Stores the dropped passive element segments in this instantiation by index.
131     /// If the index is present in the set, the segment has been dropped.
132     dropped_elements: EntitySet<ElemIndex>,
133 
134     /// Stores the dropped passive data segments in this instantiation by index.
135     /// If the index is present in the set, the segment has been dropped.
136     dropped_data: EntitySet<DataIndex>,
137 
138     // TODO: add support for multiple memories; `wmemcheck_state` corresponds to
139     // memory 0.
140     #[cfg(feature = "wmemcheck")]
141     pub(crate) wmemcheck_state: Option<Wmemcheck>,
142 
143     /// Self-pointer back to `Store<T>` and its functions. Not present for
144     /// the brief time that `Store<T>` is itself being created. Also not
145     /// present for some niche uses that are disconnected from stores (e.g.
146     /// cross-thread stuff used in `InstancePre`)
147     store: Option<VMStoreRawPtr>,
148 
149     /// Additional context used by compiled wasm code. This field is last, and
150     /// represents a dynamically-sized array that extends beyond the nominal
151     /// end of the struct (similar to a flexible array member).
152     vmctx: OwnedVMContext<VMContext>,
153 }
154 
155 impl Instance {
156     /// Create an instance at the given memory address.
157     ///
158     /// It is assumed the memory was properly aligned and the
159     /// allocation was `alloc_size` in bytes.
160     ///
161     /// # Safety
162     ///
163     /// The `req.imports` field must be appropriately sized/typed for the module
164     /// being allocated according to `req.runtime_info`. Additionally `memories`
165     /// and `tables` must have been allocated for `req.store`.
166     unsafe fn new(
167         req: InstanceAllocationRequest,
168         memories: PrimaryMap<DefinedMemoryIndex, (MemoryAllocationIndex, Memory)>,
169         tables: PrimaryMap<DefinedTableIndex, (TableAllocationIndex, Table)>,
170     ) -> InstanceHandle {
171         let module = req.runtime_info.env_module();
172         let memory_tys = &module.memories;
173         let dropped_elements = EntitySet::with_capacity(module.passive_elements.len());
174         let dropped_data = EntitySet::with_capacity(module.passive_data_map.len());
175 
176         #[cfg(feature = "wmemcheck")]
177         let wmemcheck_state = if req.store.engine().config().wmemcheck {
178             let size = memory_tys
179                 .iter()
180                 .next()
181                 .map(|memory| memory.1.limits.min)
182                 .unwrap_or(0)
183                 * 64
184                 * 1024;
185             Some(Wmemcheck::new(size.try_into().unwrap()))
186         } else {
187             None
188         };
189         #[cfg(not(feature = "wmemcheck"))]
190         let _ = memory_tys;
191 
192         let mut ret = OwnedInstance::new(Instance {
193             id: req.id,
194             runtime_info: req.runtime_info.clone(),
195             memories,
196             tables,
197             dropped_elements,
198             dropped_data,
199             #[cfg(feature = "wmemcheck")]
200             wmemcheck_state,
201             store: None,
202             vmctx: OwnedVMContext::new(),
203         });
204 
205         // SAFETY: this vmctx was allocated with the same layout above, so it
206         // should be safe to initialize with the same values here.
207         unsafe {
208             ret.get_mut().initialize_vmctx(req.store, req.imports);
209         }
210         ret
211     }
212 
213     /// Converts a raw `VMContext` pointer into a raw `Instance` pointer.
214     ///
215     /// # Safety
216     ///
217     /// Calling this function safely requires that `vmctx` is a valid allocation
218     /// of a `VMContext` which is derived from `Instance::new`. To safely
219     /// convert the returned raw pointer into a safe instance pointer callers
220     /// will also want to uphold guarantees such as:
221     ///
222     /// * The instance should not be in use elsewhere. For example you can't
223     ///   call this function twice, turn both raw pointers into safe pointers,
224     ///   and then use both safe pointers.
225     /// * There should be no other active mutable borrow to any other instance
226     ///   within the same store. Note that this is not restricted to just this
227     ///   instance pointer, but to all instances in a store. Instances can
228     ///   safely traverse to other instances "laterally" meaning that a mutable
229     ///   borrow on one is a mutable borrow on all.
230     /// * There should be no active mutable borrow on the store accessible at
231     ///   the same time the instance is turned. Instances are owned by a store
232     ///   and a store can be used to acquire a safe instance borrow at any time.
233     /// * The lifetime of the usage of the instance should not be unnecessarily
234     ///   long, for example it cannot be `'static`.
235     ///
236     /// Other entrypoints exist for converting from a raw `VMContext` to a safe
237     /// pointer such as:
238     ///
239     /// * `Instance::enter_host_from_wasm`
240     /// * `Instance::sibling_vmctx{,_mut}`
241     ///
242     /// These place further restrictions on the API signature to satisfy some of
243     /// the above points.
244     #[inline]
245     pub(crate) unsafe fn from_vmctx(vmctx: NonNull<VMContext>) -> NonNull<Instance> {
246         // SAFETY: The validity of `byte_sub` relies on `vmctx` being a valid
247         // allocation.
248         unsafe {
249             vmctx
250                 .byte_sub(mem::size_of::<Instance>())
251                 .cast::<Instance>()
252         }
253     }
254 
255     /// Encapsulated entrypoint to the host from WebAssembly, converting a raw
256     /// `VMContext` pointer into a `VMStore` plus an `InstanceId`.
257     ///
258     /// This is an entrypoint for core wasm entering back into the host. This is
259     /// used for both host functions and libcalls for example. This will execute
260     /// the closure `f` with safer Internal types than a raw `VMContext`
261     /// pointer.
262     ///
263     /// The closure `f` will have its errors caught, handled, and translated to
264     /// an ABI-safe return value to give back to wasm. This includes both normal
265     /// errors such as traps as well as panics.
266     ///
267     /// # Safety
268     ///
269     /// Callers must ensure that `vmctx` is a valid allocation and is safe to
270     /// dereference at this time. That's generally only true when it's a
271     /// wasm-provided value and this is the first function called after entering
272     /// the host. Otherwise this could unsafely alias the store with a mutable
273     /// pointer, for example.
274     #[inline]
275     pub(crate) unsafe fn enter_host_from_wasm<R>(
276         vmctx: NonNull<VMContext>,
277         f: impl FnOnce(&mut dyn VMStore, InstanceId) -> R,
278     ) -> R::Abi
279     where
280         R: HostResult,
281     {
282         // SAFETY: It's a contract of this function that `vmctx` is a valid
283         // pointer with neither the store nor other instances actively in use
284         // when this is called, so it should be safe to acquire a mutable
285         // pointer to the store and read the instance pointer.
286         let (store, instance) = unsafe {
287             let instance = Instance::from_vmctx(vmctx);
288             let instance = instance.as_ref();
289             let store = &mut *instance.store.unwrap().0.as_ptr();
290             (store, instance.id)
291         };
292 
293         // Thread the `store` and `instance` through panic/trap infrastructure
294         // back into `f`.
295         catch_unwind_and_record_trap(store, |store| f(store, instance))
296     }
297 
298     /// Converts the provided `*mut VMContext` to an `Instance` pointer and
299     /// returns it with the same lifetime as `self`.
300     ///
301     /// This function can be used when traversing a `VMContext` to reach into
302     /// the context needed for imports, optionally.
303     ///
304     /// # Safety
305     ///
306     /// This function requires that the `vmctx` pointer is indeed valid and
307     /// from the store that `self` belongs to.
308     #[inline]
309     unsafe fn sibling_vmctx<'a>(&'a self, vmctx: NonNull<VMContext>) -> &'a Instance {
310         // SAFETY: it's a contract of this function itself that `vmctx` is a
311         // valid pointer. Additionally with `self` being a
312         let ptr = unsafe { Instance::from_vmctx(vmctx) };
313         // SAFETY: it's a contract of this function itself that `vmctx` is a
314         // valid pointer to dereference. Additionally the lifetime of the return
315         // value is constrained to be the same as `self` to avoid granting a
316         // too-long lifetime.
317         unsafe { ptr.as_ref() }
318     }
319 
320     /// Same as [`Self::sibling_vmctx`], but the mutable version.
321     ///
322     /// # Safety
323     ///
324     /// This function requires that the `vmctx` pointer is indeed valid and
325     /// from the store that `self` belongs to.
326     ///
327     /// (Note that it is *NOT* required that `vmctx` be distinct from this
328     /// instance's `vmctx`, or that usage of the resulting instance is limited
329     /// to its defined items! The returned borrow has the same lifetime as
330     /// `self`, which means that this instance cannot be used while the
331     /// resulting instance is in use, and we therefore do not need to worry
332     /// about mutable aliasing between this instance and the resulting
333     /// instance.)
334     #[inline]
335     unsafe fn sibling_vmctx_mut<'a>(
336         self: Pin<&'a mut Self>,
337         vmctx: NonNull<VMContext>,
338     ) -> Pin<&'a mut Instance> {
339         // SAFETY: it's a contract of this function itself that `vmctx` is a
340         // valid pointer such that this pointer arithmetic is valid.
341         let mut ptr = unsafe { Instance::from_vmctx(vmctx) };
342 
343         // SAFETY: it's a contract of this function itself that `vmctx` is a
344         // valid pointer to dereference. Additionally the lifetime of the return
345         // value is constrained to be the same as `self` to avoid granting a
346         // too-long lifetime. Finally mutable references to an instance are
347         // always through `Pin`, so it's safe to create a pin-pointer here.
348         unsafe { Pin::new_unchecked(ptr.as_mut()) }
349     }
350 
351     pub(crate) fn env_module(&self) -> &Arc<wasmtime_environ::Module> {
352         self.runtime_info.env_module()
353     }
354 
355     pub(crate) fn runtime_module(&self) -> Option<&crate::Module> {
356         match &self.runtime_info {
357             ModuleRuntimeInfo::Module(m) => Some(m),
358             ModuleRuntimeInfo::Bare(_) => None,
359         }
360     }
361 
362     /// Translate a module-level interned type index into an engine-level
363     /// interned type index.
364     #[cfg(feature = "gc")]
365     pub fn engine_type_index(&self, module_index: ModuleInternedTypeIndex) -> VMSharedTypeIndex {
366         self.runtime_info.engine_type_index(module_index)
367     }
368 
369     #[inline]
370     fn offsets(&self) -> &VMOffsets<HostPtr> {
371         self.runtime_info.offsets()
372     }
373 
374     /// Return the indexed `VMFunctionImport`.
375     fn imported_function(&self, index: FuncIndex) -> &VMFunctionImport {
376         unsafe { self.vmctx_plus_offset(self.offsets().vmctx_vmfunction_import(index)) }
377     }
378 
379     /// Return the index `VMTableImport`.
380     fn imported_table(&self, index: TableIndex) -> &VMTableImport {
381         unsafe { self.vmctx_plus_offset(self.offsets().vmctx_vmtable_import(index)) }
382     }
383 
384     /// Return the indexed `VMMemoryImport`.
385     fn imported_memory(&self, index: MemoryIndex) -> &VMMemoryImport {
386         unsafe { self.vmctx_plus_offset(self.offsets().vmctx_vmmemory_import(index)) }
387     }
388 
389     /// Return the indexed `VMGlobalImport`.
390     fn imported_global(&self, index: GlobalIndex) -> &VMGlobalImport {
391         unsafe { self.vmctx_plus_offset(self.offsets().vmctx_vmglobal_import(index)) }
392     }
393 
394     /// Return the indexed `VMTagImport`.
395     fn imported_tag(&self, index: TagIndex) -> &VMTagImport {
396         unsafe { self.vmctx_plus_offset(self.offsets().vmctx_vmtag_import(index)) }
397     }
398 
399     /// Return the indexed `VMTagDefinition`.
400     pub fn tag_ptr(&self, index: DefinedTagIndex) -> NonNull<VMTagDefinition> {
401         unsafe { self.vmctx_plus_offset_raw(self.offsets().vmctx_vmtag_definition(index)) }
402     }
403 
404     /// Return the indexed `VMTableDefinition`.
405     pub fn table(&self, index: DefinedTableIndex) -> VMTableDefinition {
406         unsafe { self.table_ptr(index).read() }
407     }
408 
409     /// Updates the value for a defined table to `VMTableDefinition`.
410     fn set_table(self: Pin<&mut Self>, index: DefinedTableIndex, table: VMTableDefinition) {
411         unsafe {
412             self.table_ptr(index).write(table);
413         }
414     }
415 
416     /// Return a pointer to the `index`'th table within this instance, stored
417     /// in vmctx memory.
418     pub fn table_ptr(&self, index: DefinedTableIndex) -> NonNull<VMTableDefinition> {
419         unsafe { self.vmctx_plus_offset_raw(self.offsets().vmctx_vmtable_definition(index)) }
420     }
421 
422     /// Get a locally defined or imported memory.
423     pub(crate) fn get_memory(&self, index: MemoryIndex) -> VMMemoryDefinition {
424         if let Some(defined_index) = self.env_module().defined_memory_index(index) {
425             self.memory(defined_index)
426         } else {
427             let import = self.imported_memory(index);
428             unsafe { VMMemoryDefinition::load(import.from.as_ptr()) }
429         }
430     }
431 
432     /// Return the indexed `VMMemoryDefinition`, loaded from vmctx memory
433     /// already.
434     #[inline]
435     pub fn memory(&self, index: DefinedMemoryIndex) -> VMMemoryDefinition {
436         unsafe { VMMemoryDefinition::load(self.memory_ptr(index).as_ptr()) }
437     }
438 
439     /// Set the indexed memory to `VMMemoryDefinition`.
440     fn set_memory(&self, index: DefinedMemoryIndex, mem: VMMemoryDefinition) {
441         unsafe {
442             self.memory_ptr(index).write(mem);
443         }
444     }
445 
446     /// Return the address of the specified memory at `index` within this vmctx.
447     ///
448     /// Note that the returned pointer resides in wasm-code-readable-memory in
449     /// the vmctx.
450     #[inline]
451     pub fn memory_ptr(&self, index: DefinedMemoryIndex) -> NonNull<VMMemoryDefinition> {
452         unsafe {
453             self.vmctx_plus_offset::<VmPtr<_>>(self.offsets().vmctx_vmmemory_pointer(index))
454                 .as_non_null()
455         }
456     }
457 
458     /// Return the indexed `VMGlobalDefinition`.
459     pub fn global_ptr(&self, index: DefinedGlobalIndex) -> NonNull<VMGlobalDefinition> {
460         unsafe { self.vmctx_plus_offset_raw(self.offsets().vmctx_vmglobal_definition(index)) }
461     }
462 
463     /// Get all globals within this instance.
464     ///
465     /// Returns both import and defined globals.
466     ///
467     /// Returns both exported and non-exported globals.
468     ///
469     /// Gives access to the full globals space.
470     pub fn all_globals(
471         &self,
472         store: StoreId,
473     ) -> impl ExactSizeIterator<Item = (GlobalIndex, crate::Global)> + '_ {
474         let module = self.env_module();
475         module
476             .globals
477             .keys()
478             .map(move |idx| (idx, self.get_exported_global(store, idx)))
479     }
480 
481     /// Get the globals defined in this instance (not imported).
482     pub fn defined_globals(
483         &self,
484         store: StoreId,
485     ) -> impl ExactSizeIterator<Item = (DefinedGlobalIndex, crate::Global)> + '_ {
486         let module = self.env_module();
487         self.all_globals(store)
488             .skip(module.num_imported_globals)
489             .map(move |(i, global)| (module.defined_global_index(i).unwrap(), global))
490     }
491 
492     /// Return a pointer to the interrupts structure
493     #[inline]
494     pub fn vm_store_context(&self) -> NonNull<Option<VmPtr<VMStoreContext>>> {
495         unsafe { self.vmctx_plus_offset_raw(self.offsets().ptr.vmctx_store_context()) }
496     }
497 
498     /// Return a pointer to the global epoch counter used by this instance.
499     #[cfg(target_has_atomic = "64")]
500     pub fn epoch_ptr(self: Pin<&mut Self>) -> &mut Option<VmPtr<AtomicU64>> {
501         let offset = self.offsets().ptr.vmctx_epoch_ptr();
502         unsafe { self.vmctx_plus_offset_mut(offset) }
503     }
504 
505     /// Return a pointer to the collector-specific heap data.
506     pub fn gc_heap_data(self: Pin<&mut Self>) -> &mut Option<VmPtr<u8>> {
507         let offset = self.offsets().ptr.vmctx_gc_heap_data();
508         unsafe { self.vmctx_plus_offset_mut(offset) }
509     }
510 
511     pub(crate) unsafe fn set_store(mut self: Pin<&mut Self>, store: &StoreOpaque) {
512         // FIXME: should be more targeted ideally with the `unsafe` than just
513         // throwing this entire function in a large `unsafe` block.
514         unsafe {
515             *self.as_mut().store_mut() = Some(VMStoreRawPtr(store.traitobj()));
516             self.vm_store_context()
517                 .write(Some(store.vm_store_context_ptr().into()));
518             #[cfg(target_has_atomic = "64")]
519             {
520                 *self.as_mut().epoch_ptr() =
521                     Some(NonNull::from(store.engine().epoch_counter()).into());
522             }
523 
524             if self.env_module().needs_gc_heap {
525                 self.as_mut().set_gc_heap(Some(store.unwrap_gc_store()));
526             } else {
527                 self.as_mut().set_gc_heap(None);
528             }
529         }
530     }
531 
532     unsafe fn set_gc_heap(self: Pin<&mut Self>, gc_store: Option<&GcStore>) {
533         if let Some(gc_store) = gc_store {
534             *self.gc_heap_data() = Some(unsafe { gc_store.gc_heap.vmctx_gc_heap_data().into() });
535         } else {
536             *self.gc_heap_data() = None;
537         }
538     }
539 
540     /// Return a reference to the vmctx used by compiled wasm code.
541     #[inline]
542     pub fn vmctx(&self) -> NonNull<VMContext> {
543         InstanceLayout::vmctx(self)
544     }
545 
546     /// Lookup a function by index.
547     ///
548     /// # Panics
549     ///
550     /// Panics if `index` is out of bounds for this instance.
551     ///
552     /// # Safety
553     ///
554     /// The `store` parameter must be the store that owns this instance and the
555     /// functions that this instance can reference.
556     pub unsafe fn get_exported_func(
557         self: Pin<&mut Self>,
558         registry: &ModuleRegistry,
559         store: StoreId,
560         index: FuncIndex,
561     ) -> crate::Func {
562         let func_ref = self.get_func_ref(registry, index).unwrap();
563 
564         // SAFETY: the validity of `func_ref` is guaranteed by the validity of
565         // `self`, and the contract that `store` must own `func_ref` is a
566         // contract of this function itself.
567         unsafe { crate::Func::from_vm_func_ref(store, func_ref) }
568     }
569 
570     /// Lookup a table by index.
571     ///
572     /// # Panics
573     ///
574     /// Panics if `index` is out of bounds for this instance.
575     pub fn get_exported_table(&self, store: StoreId, index: TableIndex) -> crate::Table {
576         let (id, def_index) = if let Some(def_index) = self.env_module().defined_table_index(index)
577         {
578             (self.id, def_index)
579         } else {
580             let import = self.imported_table(index);
581             // SAFETY: validity of this `Instance` guarantees validity of the
582             // `vmctx` pointer being read here to find the transitive
583             // `InstanceId` that the import is associated with.
584             let id = unsafe { self.sibling_vmctx(import.vmctx.as_non_null()).id };
585             (id, import.index)
586         };
587         crate::Table::from_raw(StoreInstanceId::new(store, id), def_index)
588     }
589 
590     /// Lookup a memory by index.
591     ///
592     /// # Panics
593     ///
594     /// Panics if `index` is out-of-bounds for this instance.
595     #[cfg_attr(
596         not(feature = "threads"),
597         expect(unused_variables, reason = "definitions cfg'd to dummy",)
598     )]
599     pub fn get_exported_memory(&self, store: StoreId, index: MemoryIndex) -> ExportMemory {
600         let module = self.env_module();
601         if module.memories[index].shared {
602             let (memory, import) =
603                 if let Some(def_index) = self.env_module().defined_memory_index(index) {
604                     (
605                         self.get_defined_memory(def_index),
606                         self.get_defined_memory_vmimport(def_index),
607                     )
608                 } else {
609                     let import = self.imported_memory(index);
610                     // SAFETY: validity of this `Instance` guarantees validity of
611                     // the `vmctx` pointer being read here to find the transitive
612                     // `InstanceId` that the import is associated with.
613                     let instance = unsafe { self.sibling_vmctx(import.vmctx.as_non_null()) };
614                     (instance.get_defined_memory(import.index), *import)
615                 };
616 
617             let vm = memory.as_shared_memory().unwrap().clone();
618             ExportMemory::Shared(vm, import)
619         } else {
620             let (id, def_index) =
621                 if let Some(def_index) = self.env_module().defined_memory_index(index) {
622                     (self.id, def_index)
623                 } else {
624                     let import = self.imported_memory(index);
625                     // SAFETY: validity of this `Instance` guarantees validity of the
626                     // `vmctx` pointer being read here to find the transitive
627                     // `InstanceId` that the import is associated with.
628                     let id = unsafe { self.sibling_vmctx(import.vmctx.as_non_null()).id };
629                     (id, import.index)
630                 };
631 
632             // SAFETY: `from_raw` requires that the memory is not shared, which
633             // was tested above in this if/else.
634             let store_id = StoreInstanceId::new(store, id);
635             ExportMemory::Unshared(unsafe { crate::Memory::from_raw(store_id, def_index) })
636         }
637     }
638 
639     /// Lookup a global by index.
640     ///
641     /// # Panics
642     ///
643     /// Panics if `index` is out-of-bounds for this instance.
644     pub(crate) fn get_exported_global(&self, store: StoreId, index: GlobalIndex) -> crate::Global {
645         // If this global is defined within this instance, then that's easy to
646         // calculate the `Global`.
647         if let Some(def_index) = self.env_module().defined_global_index(index) {
648             let instance = StoreInstanceId::new(store, self.id);
649             return crate::Global::from_core(instance, def_index);
650         }
651 
652         // For imported globals it's required to match on the `kind` to
653         // determine which `Global` constructor is going to be invoked.
654         let import = self.imported_global(index);
655         match import.kind {
656             VMGlobalKind::Host(index) => crate::Global::from_host(store, index),
657             VMGlobalKind::Instance(index) => {
658                 // SAFETY: validity of this `&Instance` means validity of its
659                 // imports meaning we can read the id of the vmctx within.
660                 let id = unsafe {
661                     let vmctx = VMContext::from_opaque(import.vmctx.unwrap().as_non_null());
662                     self.sibling_vmctx(vmctx).id
663                 };
664                 crate::Global::from_core(StoreInstanceId::new(store, id), index)
665             }
666             #[cfg(feature = "component-model")]
667             VMGlobalKind::ComponentFlags(index) => {
668                 // SAFETY: validity of this `&Instance` means validity of its
669                 // imports meaning we can read the id of the vmctx within.
670                 let id = unsafe {
671                     let vmctx = super::component::VMComponentContext::from_opaque(
672                         import.vmctx.unwrap().as_non_null(),
673                     );
674                     super::component::ComponentInstance::vmctx_instance_id(vmctx)
675                 };
676                 crate::Global::from_component_flags(
677                     crate::component::store::StoreComponentInstanceId::new(store, id),
678                     index,
679                 )
680             }
681             #[cfg(feature = "component-model")]
682             VMGlobalKind::TaskMayBlock => {
683                 // SAFETY: validity of this `&Instance` means validity of its
684                 // imports meaning we can read the id of the vmctx within.
685                 let id = unsafe {
686                     let vmctx = super::component::VMComponentContext::from_opaque(
687                         import.vmctx.unwrap().as_non_null(),
688                     );
689                     super::component::ComponentInstance::vmctx_instance_id(vmctx)
690                 };
691                 crate::Global::from_task_may_block(
692                     crate::component::store::StoreComponentInstanceId::new(store, id),
693                 )
694             }
695         }
696     }
697 
698     /// Get an exported tag by index.
699     ///
700     /// # Panics
701     ///
702     /// Panics if the index is out-of-range.
703     pub fn get_exported_tag(&self, store: StoreId, index: TagIndex) -> crate::Tag {
704         let (id, def_index) = if let Some(def_index) = self.env_module().defined_tag_index(index) {
705             (self.id, def_index)
706         } else {
707             let import = self.imported_tag(index);
708             // SAFETY: validity of this `Instance` guarantees validity of the
709             // `vmctx` pointer being read here to find the transitive
710             // `InstanceId` that the import is associated with.
711             let id = unsafe { self.sibling_vmctx(import.vmctx.as_non_null()).id };
712             (id, import.index)
713         };
714         crate::Tag::from_raw(StoreInstanceId::new(store, id), def_index)
715     }
716 
717     /// Return an iterator over the exports of this instance.
718     ///
719     /// Specifically, it provides access to the key-value pairs, where the keys
720     /// are export names, and the values are export declarations which can be
721     /// resolved `lookup_by_declaration`.
722     pub fn exports(&self) -> wasmparser::collections::index_map::Iter<'_, String, EntityIndex> {
723         self.env_module().exports.iter()
724     }
725 
726     /// Grow memory by the specified amount of pages.
727     ///
728     /// Returns `None` if memory can't be grown by the specified amount
729     /// of pages. Returns `Some` with the old size in bytes if growth was
730     /// successful.
731     pub(crate) async fn memory_grow(
732         mut self: Pin<&mut Self>,
733         limiter: Option<&mut StoreResourceLimiter<'_>>,
734         idx: DefinedMemoryIndex,
735         delta: u64,
736     ) -> Result<Option<usize>, Error> {
737         let memory = &mut self.as_mut().memories_mut()[idx].1;
738 
739         // SAFETY: this is the safe wrapper around `Memory::grow` because it
740         // automatically updates the `VMMemoryDefinition` in this instance after
741         // a growth operation below.
742         let result = unsafe { memory.grow(delta, limiter).await };
743 
744         // Update the state used by a non-shared Wasm memory in case the base
745         // pointer and/or the length changed.
746         if memory.as_shared_memory().is_none() {
747             let vmmemory = memory.vmmemory();
748             self.set_memory(idx, vmmemory);
749         }
750 
751         result
752     }
753 
754     pub(crate) fn table_element_type(
755         self: Pin<&mut Self>,
756         table_index: TableIndex,
757     ) -> TableElementType {
758         self.get_table(table_index).element_type()
759     }
760 
761     /// Performs a grow operation on the `table_index` specified using `grow`.
762     ///
763     /// This will handle updating the VMTableDefinition internally as necessary.
764     pub(crate) async fn defined_table_grow(
765         mut self: Pin<&mut Self>,
766         table_index: DefinedTableIndex,
767         grow: impl AsyncFnOnce(&mut Table) -> Result<Option<usize>>,
768     ) -> Result<Option<usize>> {
769         let table = self.as_mut().get_defined_table(table_index);
770         let result = grow(table).await;
771         let element = table.vmtable();
772         self.set_table(table_index, element);
773         result
774     }
775 
776     fn alloc_layout(offsets: &VMOffsets<HostPtr>) -> Layout {
777         let size = mem::size_of::<Self>()
778             .checked_add(usize::try_from(offsets.size_of_vmctx()).unwrap())
779             .unwrap();
780         let align = mem::align_of::<Self>();
781         Layout::from_size_align(size, align).unwrap()
782     }
783 
784     fn type_ids_array(&self) -> NonNull<VmPtr<VMSharedTypeIndex>> {
785         unsafe { self.vmctx_plus_offset_raw(self.offsets().ptr.vmctx_type_ids_array()) }
786     }
787 
788     /// Construct a new VMFuncRef for the given function
789     /// (imported or defined in this module) and store into the given
790     /// location. Used during lazy initialization.
791     ///
792     /// Note that our current lazy-init scheme actually calls this every
793     /// time the funcref pointer is fetched; this turns out to be better
794     /// than tracking state related to whether it's been initialized
795     /// before, because resetting that state on (re)instantiation is
796     /// very expensive if there are many funcrefs.
797     ///
798     /// # Safety
799     ///
800     /// This functions requires that `into` is a valid pointer.
801     unsafe fn construct_func_ref(
802         self: Pin<&mut Self>,
803         registry: &ModuleRegistry,
804         index: FuncIndex,
805         type_index: VMSharedTypeIndex,
806         into: *mut VMFuncRef,
807     ) {
808         let module_with_code = ModuleWithCode::in_store(
809             registry,
810             self.runtime_module()
811                 .expect("funcref impossible in fake module"),
812         )
813         .expect("module not in store");
814 
815         let func_ref = if let Some(def_index) = self.env_module().defined_func_index(index) {
816             VMFuncRef {
817                 array_call: NonNull::from(
818                     module_with_code
819                         .array_to_wasm_trampoline(def_index)
820                         .expect("should have array-to-Wasm trampoline for escaping function"),
821                 )
822                 .cast()
823                 .into(),
824                 wasm_call: Some(
825                     NonNull::new(
826                         module_with_code
827                             .finished_function(def_index)
828                             .as_ptr()
829                             .cast::<VMWasmCallFunction>()
830                             .cast_mut(),
831                     )
832                     .unwrap()
833                     .into(),
834                 ),
835                 vmctx: VMOpaqueContext::from_vmcontext(self.vmctx()).into(),
836                 type_index,
837             }
838         } else {
839             let import = self.imported_function(index);
840             VMFuncRef {
841                 array_call: import.array_call,
842                 wasm_call: Some(import.wasm_call),
843                 vmctx: import.vmctx,
844                 type_index,
845             }
846         };
847 
848         // SAFETY: the unsafe contract here is forwarded to callers of this
849         // function.
850         unsafe {
851             ptr::write(into, func_ref);
852         }
853     }
854 
855     /// Get a `&VMFuncRef` for the given `FuncIndex`.
856     ///
857     /// Returns `None` if the index is the reserved index value.
858     ///
859     /// The returned reference is a stable reference that won't be moved and can
860     /// be passed into JIT code.
861     pub(crate) fn get_func_ref(
862         self: Pin<&mut Self>,
863         registry: &ModuleRegistry,
864         index: FuncIndex,
865     ) -> Option<NonNull<VMFuncRef>> {
866         if index == FuncIndex::reserved_value() {
867             return None;
868         }
869 
870         // For now, we eagerly initialize an funcref struct in-place
871         // whenever asked for a reference to it. This is mostly
872         // fine, because in practice each funcref is unlikely to be
873         // requested more than a few times: once-ish for funcref
874         // tables used for call_indirect (the usual compilation
875         // strategy places each function in the table at most once),
876         // and once or a few times when fetching exports via API.
877         // Note that for any case driven by table accesses, the lazy
878         // table init behaves like a higher-level cache layer that
879         // protects this initialization from happening multiple
880         // times, via that particular table at least.
881         //
882         // When `ref.func` becomes more commonly used or if we
883         // otherwise see a use-case where this becomes a hotpath,
884         // we can reconsider by using some state to track
885         // "uninitialized" explicitly, for example by zeroing the
886         // funcrefs (perhaps together with other
887         // zeroed-at-instantiate-time state) or using a separate
888         // is-initialized bitmap.
889         //
890         // We arrived at this design because zeroing memory is
891         // expensive, so it's better for instantiation performance
892         // if we don't have to track "is-initialized" state at
893         // all!
894         let func = &self.env_module().functions[index];
895         let sig = func.signature.unwrap_engine_type_index();
896 
897         // SAFETY: the offset calculated here should be correct with
898         // `self.offsets`
899         let func_ref = unsafe {
900             self.vmctx_plus_offset_raw::<VMFuncRef>(self.offsets().vmctx_func_ref(func.func_ref))
901         };
902 
903         // SAFETY: the `func_ref` ptr should be valid as it's within our
904         // `VMContext` area.
905         unsafe {
906             self.construct_func_ref(registry, index, sig, func_ref.as_ptr());
907         }
908 
909         Some(func_ref)
910     }
911 
912     /// Get the passive elements segment at the given index.
913     ///
914     /// Returns an empty segment if the index is out of bounds or if the segment
915     /// has been dropped.
916     ///
917     /// The `storage` parameter should always be `None`; it is a bit of a hack
918     /// to work around lifetime issues.
919     pub(crate) fn passive_element_segment<'a>(
920         &self,
921         storage: &'a mut Option<(Arc<wasmtime_environ::Module>, TableSegmentElements)>,
922         elem_index: ElemIndex,
923     ) -> &'a TableSegmentElements {
924         debug_assert!(storage.is_none());
925         *storage = Some((
926             // TODO: this `clone()` shouldn't be necessary but is used for now to
927             // inform `rustc` that the lifetime of the elements here are
928             // disconnected from the lifetime of `self`.
929             self.env_module().clone(),
930             // NB: fall back to an expressions-based list of elements which
931             // doesn't have static type information (as opposed to
932             // `TableSegmentElements::Functions`) since we don't know what type
933             // is needed in the caller's context. Let the type be inferred by
934             // how they use the segment.
935             TableSegmentElements::Expressions(Box::new([])),
936         ));
937         let (module, empty) = storage.as_ref().unwrap();
938 
939         match module.passive_elements_map.get(&elem_index) {
940             Some(index) if !self.dropped_elements.contains(elem_index) => {
941                 &module.passive_elements[*index]
942             }
943             _ => empty,
944         }
945     }
946 
947     /// The `table.init` operation: initializes a portion of a table with a
948     /// passive element.
949     ///
950     /// # Errors
951     ///
952     /// Returns a `Trap` error when the range within the table is out of bounds
953     /// or the range within the passive element is out of bounds.
954     pub(crate) async fn table_init(
955         store: &mut StoreOpaque,
956         limiter: Option<&mut StoreResourceLimiter<'_>>,
957         asyncness: Asyncness,
958         instance: InstanceId,
959         table_index: TableIndex,
960         elem_index: ElemIndex,
961         dst: u64,
962         src: u64,
963         len: u64,
964     ) -> Result<()> {
965         let mut storage = None;
966         let elements = store
967             .instance(instance)
968             .passive_element_segment(&mut storage, elem_index);
969         let mut const_evaluator = ConstExprEvaluator::default();
970         Self::table_init_segment(
971             store,
972             limiter,
973             asyncness,
974             instance,
975             &mut const_evaluator,
976             table_index,
977             elements,
978             dst,
979             src,
980             len,
981         )
982         .await
983     }
984 
985     pub(crate) async fn table_init_segment(
986         store: &mut StoreOpaque,
987         mut limiter: Option<&mut StoreResourceLimiter<'_>>,
988         asyncness: Asyncness,
989         elements_instance_id: InstanceId,
990         const_evaluator: &mut ConstExprEvaluator,
991         table_index: TableIndex,
992         elements: &TableSegmentElements,
993         dst: u64,
994         src: u64,
995         len: u64,
996     ) -> Result<()> {
997         // https://webassembly.github.io/bulk-memory-operations/core/exec/instructions.html#exec-table-init
998 
999         let store_id = store.id();
1000         let elements_instance = store.instance_mut(elements_instance_id);
1001         let table = elements_instance.get_exported_table(store_id, table_index);
1002         let table_size = table._size(store);
1003 
1004         // Perform a bounds check on the table being written to. This is done by
1005         // ensuring that `dst + len <= table.size()` via checked arithmetic.
1006         //
1007         // Note that the bounds check for the element segment happens below when
1008         // the original segment is sliced via `src` and `len`.
1009         table_size
1010             .checked_sub(dst)
1011             .and_then(|i| i.checked_sub(len))
1012             .ok_or(Trap::TableOutOfBounds)?;
1013 
1014         let src = usize::try_from(src).map_err(|_| Trap::TableOutOfBounds)?;
1015         let len = usize::try_from(len).map_err(|_| Trap::TableOutOfBounds)?;
1016 
1017         let positions = dst..dst + u64::try_from(len).unwrap();
1018         match elements {
1019             TableSegmentElements::Functions(funcs) => {
1020                 let elements = funcs
1021                     .get(src..)
1022                     .and_then(|s| s.get(..len))
1023                     .ok_or(Trap::TableOutOfBounds)?;
1024                 for (i, func_idx) in positions.zip(elements) {
1025                     let (instance, registry) =
1026                         store.instance_and_module_registry_mut(elements_instance_id);
1027                     // SAFETY: the `store_id` passed to `get_exported_func` is
1028                     // indeed the store that owns the function.
1029                     let func = unsafe { instance.get_exported_func(registry, store_id, *func_idx) };
1030                     table.set_(store, i, func.into()).unwrap();
1031                 }
1032             }
1033             TableSegmentElements::Expressions(exprs) => {
1034                 let mut store = OpaqueRootScope::new(store);
1035                 let exprs = exprs
1036                     .get(src..)
1037                     .and_then(|s| s.get(..len))
1038                     .ok_or(Trap::TableOutOfBounds)?;
1039                 let mut context = ConstEvalContext::new(elements_instance_id, asyncness);
1040                 for (i, expr) in positions.zip(exprs) {
1041                     let element = const_evaluator
1042                         .eval(&mut store, limiter.as_deref_mut(), &mut context, expr)
1043                         .await?;
1044                     table.set_(&mut store, i, element.ref_().unwrap()).unwrap();
1045                 }
1046             }
1047         }
1048 
1049         Ok(())
1050     }
1051 
1052     /// Drop an element.
1053     pub(crate) fn elem_drop(self: Pin<&mut Self>, elem_index: ElemIndex) {
1054         // https://webassembly.github.io/reference-types/core/exec/instructions.html#exec-elem-drop
1055 
1056         self.dropped_elements_mut().insert(elem_index);
1057 
1058         // Note that we don't check that we actually removed a segment because
1059         // dropping a non-passive segment is a no-op (not a trap).
1060     }
1061 
1062     /// Get a locally-defined memory.
1063     pub fn get_defined_memory_mut(self: Pin<&mut Self>, index: DefinedMemoryIndex) -> &mut Memory {
1064         &mut self.memories_mut()[index].1
1065     }
1066 
1067     /// Get a locally-defined memory.
1068     pub fn get_defined_memory(&self, index: DefinedMemoryIndex) -> &Memory {
1069         &self.memories[index].1
1070     }
1071 
1072     pub fn get_defined_memory_vmimport(&self, index: DefinedMemoryIndex) -> VMMemoryImport {
1073         crate::runtime::vm::VMMemoryImport {
1074             from: self.memory_ptr(index).into(),
1075             vmctx: self.vmctx().into(),
1076             index,
1077         }
1078     }
1079 
1080     /// Do a `memory.copy`
1081     ///
1082     /// # Errors
1083     ///
1084     /// Returns a `Trap` error when the source or destination ranges are out of
1085     /// bounds.
1086     pub(crate) fn memory_copy(
1087         self: Pin<&mut Self>,
1088         dst_index: MemoryIndex,
1089         dst: u64,
1090         src_index: MemoryIndex,
1091         src: u64,
1092         len: u64,
1093     ) -> Result<(), Trap> {
1094         // https://webassembly.github.io/reference-types/core/exec/instructions.html#exec-memory-copy
1095 
1096         let src_mem = self.get_memory(src_index);
1097         let dst_mem = self.get_memory(dst_index);
1098 
1099         let src = self.validate_inbounds(src_mem.current_length(), src, len)?;
1100         let dst = self.validate_inbounds(dst_mem.current_length(), dst, len)?;
1101         let len = usize::try_from(len).unwrap();
1102 
1103         // Bounds and casts are checked above, by this point we know that
1104         // everything is safe.
1105         unsafe {
1106             let dst = dst_mem.base.as_ptr().add(dst);
1107             let src = src_mem.base.as_ptr().add(src);
1108             // FIXME audit whether this is safe in the presence of shared memory
1109             // (https://github.com/bytecodealliance/wasmtime/issues/4203).
1110             ptr::copy(src, dst, len);
1111         }
1112 
1113         Ok(())
1114     }
1115 
1116     fn validate_inbounds(&self, max: usize, ptr: u64, len: u64) -> Result<usize, Trap> {
1117         let oob = || Trap::MemoryOutOfBounds;
1118         let end = ptr
1119             .checked_add(len)
1120             .and_then(|i| usize::try_from(i).ok())
1121             .ok_or_else(oob)?;
1122         if end > max {
1123             Err(oob())
1124         } else {
1125             Ok(ptr.try_into().unwrap())
1126         }
1127     }
1128 
1129     /// Perform the `memory.fill` operation on a locally defined memory.
1130     ///
1131     /// # Errors
1132     ///
1133     /// Returns a `Trap` error if the memory range is out of bounds.
1134     pub(crate) fn memory_fill(
1135         self: Pin<&mut Self>,
1136         memory_index: DefinedMemoryIndex,
1137         dst: u64,
1138         val: u8,
1139         len: u64,
1140     ) -> Result<(), Trap> {
1141         let memory_index = self.env_module().memory_index(memory_index);
1142         let memory = self.get_memory(memory_index);
1143         let dst = self.validate_inbounds(memory.current_length(), dst, len)?;
1144         let len = usize::try_from(len).unwrap();
1145 
1146         // Bounds and casts are checked above, by this point we know that
1147         // everything is safe.
1148         unsafe {
1149             let dst = memory.base.as_ptr().add(dst);
1150             // FIXME audit whether this is safe in the presence of shared memory
1151             // (https://github.com/bytecodealliance/wasmtime/issues/4203).
1152             ptr::write_bytes(dst, val, len);
1153         }
1154 
1155         Ok(())
1156     }
1157 
1158     /// Get the internal storage range of a particular Wasm data segment.
1159     pub(crate) fn wasm_data_range(&self, index: DataIndex) -> Range<u32> {
1160         match self.env_module().passive_data_map.get(&index) {
1161             Some(range) if !self.dropped_data.contains(index) => range.clone(),
1162             _ => 0..0,
1163         }
1164     }
1165 
1166     /// Given an internal storage range of a Wasm data segment (or subset of a
1167     /// Wasm data segment), get the data's raw bytes.
1168     pub(crate) fn wasm_data(&self, range: Range<u32>) -> &[u8] {
1169         let start = usize::try_from(range.start).unwrap();
1170         let end = usize::try_from(range.end).unwrap();
1171         &self.runtime_info.wasm_data()[start..end]
1172     }
1173 
1174     /// Performs the `memory.init` operation.
1175     ///
1176     /// # Errors
1177     ///
1178     /// Returns a `Trap` error if the destination range is out of this module's
1179     /// memory's bounds or if the source range is outside the data segment's
1180     /// bounds.
1181     pub(crate) fn memory_init(
1182         self: Pin<&mut Self>,
1183         memory_index: MemoryIndex,
1184         data_index: DataIndex,
1185         dst: u64,
1186         src: u32,
1187         len: u32,
1188     ) -> Result<(), Trap> {
1189         let range = self.wasm_data_range(data_index);
1190         self.memory_init_segment(memory_index, range, dst, src, len)
1191     }
1192 
1193     pub(crate) fn memory_init_segment(
1194         self: Pin<&mut Self>,
1195         memory_index: MemoryIndex,
1196         range: Range<u32>,
1197         dst: u64,
1198         src: u32,
1199         len: u32,
1200     ) -> Result<(), Trap> {
1201         // https://webassembly.github.io/bulk-memory-operations/core/exec/instructions.html#exec-memory-init
1202 
1203         let memory = self.get_memory(memory_index);
1204         let data = self.wasm_data(range);
1205         let dst = self.validate_inbounds(memory.current_length(), dst, len.into())?;
1206         let src = self.validate_inbounds(data.len(), src.into(), len.into())?;
1207         let len = len as usize;
1208 
1209         unsafe {
1210             let src_start = data.as_ptr().add(src);
1211             let dst_start = memory.base.as_ptr().add(dst);
1212             // FIXME audit whether this is safe in the presence of shared memory
1213             // (https://github.com/bytecodealliance/wasmtime/issues/4203).
1214             ptr::copy_nonoverlapping(src_start, dst_start, len);
1215         }
1216 
1217         Ok(())
1218     }
1219 
1220     /// Drop the given data segment, truncating its length to zero.
1221     pub(crate) fn data_drop(self: Pin<&mut Self>, data_index: DataIndex) {
1222         self.dropped_data_mut().insert(data_index);
1223 
1224         // Note that we don't check that we actually removed a segment because
1225         // dropping a non-passive segment is a no-op (not a trap).
1226     }
1227 
1228     /// Get a table by index regardless of whether it is locally-defined
1229     /// or an imported, foreign table. Ensure that the given range of
1230     /// elements in the table is lazily initialized.  We define this
1231     /// operation all-in-one for safety, to ensure the lazy-init
1232     /// happens.
1233     ///
1234     /// Takes an `Iterator` for the index-range to lazy-initialize,
1235     /// for flexibility. This can be a range, single item, or empty
1236     /// sequence, for example. The iterator should return indices in
1237     /// increasing order, so that the break-at-out-of-bounds behavior
1238     /// works correctly.
1239     pub(crate) fn get_table_with_lazy_init(
1240         self: Pin<&mut Self>,
1241         registry: &ModuleRegistry,
1242         table_index: TableIndex,
1243         range: impl Iterator<Item = u64>,
1244     ) -> &mut Table {
1245         let (idx, instance) = self.defined_table_index_and_instance(table_index);
1246         instance.get_defined_table_with_lazy_init(registry, idx, range)
1247     }
1248 
1249     /// Gets the raw runtime table data structure owned by this instance
1250     /// given the provided `idx`.
1251     ///
1252     /// The `range` specified is eagerly initialized for funcref tables.
1253     pub fn get_defined_table_with_lazy_init(
1254         mut self: Pin<&mut Self>,
1255         registry: &ModuleRegistry,
1256         idx: DefinedTableIndex,
1257         range: impl IntoIterator<Item = u64>,
1258     ) -> &mut Table {
1259         let elt_ty = self.tables[idx].1.element_type();
1260 
1261         if elt_ty == TableElementType::Func {
1262             for i in range {
1263                 match self.tables[idx].1.get_func_maybe_init(i) {
1264                     // Uninitialized table element.
1265                     Ok(None) => {}
1266                     // Initialized table element, move on to the next.
1267                     Ok(Some(_)) => continue,
1268                     // Out-of-bounds; caller will handle by likely
1269                     // throwing a trap. No work to do to lazy-init
1270                     // beyond the end.
1271                     Err(_) => break,
1272                 };
1273 
1274                 // The table element `i` is uninitialized and is now being
1275                 // initialized. This must imply that a `precompiled` list of
1276                 // function indices is available for this table. The precompiled
1277                 // list is extracted and then it is consulted with `i` to
1278                 // determine the function that is going to be initialized. Note
1279                 // that `i` may be outside the limits of the static
1280                 // initialization so it's a fallible `get` instead of an index.
1281                 let module = self.env_module();
1282                 let precomputed = match &module.table_initialization.initial_values[idx] {
1283                     TableInitialValue::Null { precomputed } => precomputed,
1284                     TableInitialValue::Expr(_) => unreachable!(),
1285                 };
1286                 // Panicking here helps catch bugs rather than silently truncating by accident.
1287                 let func_index = precomputed.get(usize::try_from(i).unwrap()).cloned();
1288                 let func_ref = func_index
1289                     .and_then(|func_index| self.as_mut().get_func_ref(registry, func_index));
1290                 self.as_mut().tables_mut()[idx]
1291                     .1
1292                     .set_func(i, func_ref)
1293                     .expect("Table type should match and index should be in-bounds");
1294             }
1295         }
1296 
1297         self.get_defined_table(idx)
1298     }
1299 
1300     /// Get a table by index regardless of whether it is locally-defined or an
1301     /// imported, foreign table.
1302     pub(crate) fn get_table(self: Pin<&mut Self>, table_index: TableIndex) -> &mut Table {
1303         let (idx, instance) = self.defined_table_index_and_instance(table_index);
1304         instance.get_defined_table(idx)
1305     }
1306 
1307     /// Get a locally-defined table.
1308     pub(crate) fn get_defined_table(self: Pin<&mut Self>, index: DefinedTableIndex) -> &mut Table {
1309         &mut self.tables_mut()[index].1
1310     }
1311 
1312     pub(crate) fn defined_table_index_and_instance<'a>(
1313         self: Pin<&'a mut Self>,
1314         index: TableIndex,
1315     ) -> (DefinedTableIndex, Pin<&'a mut Instance>) {
1316         if let Some(defined_table_index) = self.env_module().defined_table_index(index) {
1317             (defined_table_index, self)
1318         } else {
1319             let import = self.imported_table(index);
1320             let index = import.index;
1321             let vmctx = import.vmctx.as_non_null();
1322             // SAFETY: the validity of `self` means that the reachable instances
1323             // should also all be owned by the same store and fully initialized,
1324             // so it's safe to laterally move from a mutable borrow of this
1325             // instance to a mutable borrow of a sibling instance.
1326             let foreign_instance = unsafe { self.sibling_vmctx_mut(vmctx) };
1327             (index, foreign_instance)
1328         }
1329     }
1330 
1331     /// Same as `self.runtime_info.env_module()` but additionally returns the
1332     /// `Pin<&mut Self>` with the same original lifetime.
1333     pub fn module_and_self(self: Pin<&mut Self>) -> (&wasmtime_environ::Module, Pin<&mut Self>) {
1334         // SAFETY: this function is projecting both `&Module` and the same
1335         // pointer both connected to the same lifetime. This is safe because
1336         // it's a contract of `Pin<&mut Self>` that the `runtime_info` field is
1337         // never written, meaning it's effectively unsafe to have `&mut Module`
1338         // projected from `Pin<&mut Self>`. Consequently it's safe to have a
1339         // read-only view of the field while still retaining mutable access to
1340         // all other fields.
1341         let module = self.runtime_info.env_module();
1342         let module = &raw const *module;
1343         let module = unsafe { &*module };
1344         (module, self)
1345     }
1346 
1347     /// Initialize the VMContext data associated with this Instance.
1348     ///
1349     /// The `VMContext` memory is assumed to be uninitialized; any field
1350     /// that we need in a certain state will be explicitly written by this
1351     /// function.
1352     unsafe fn initialize_vmctx(self: Pin<&mut Self>, store: &StoreOpaque, imports: Imports) {
1353         let (module, mut instance) = self.module_and_self();
1354 
1355         // SAFETY: the type of the magic field is indeed `u32` and this function
1356         // is initializing its value.
1357         unsafe {
1358             let offsets = instance.runtime_info.offsets();
1359             instance
1360                 .vmctx_plus_offset_raw::<u32>(offsets.ptr.vmctx_magic())
1361                 .write(VMCONTEXT_MAGIC);
1362         }
1363 
1364         // SAFETY: it's up to the caller to provide a valid store pointer here.
1365         unsafe {
1366             instance.as_mut().set_store(store);
1367         }
1368 
1369         // Initialize shared types
1370         //
1371         // SAFETY: validity of the vmctx means it should be safe to write to it
1372         // here.
1373         unsafe {
1374             let types = NonNull::from(instance.runtime_info.type_ids());
1375             instance.type_ids_array().write(types.cast().into());
1376         }
1377 
1378         // Initialize the built-in functions
1379         //
1380         // SAFETY: the type of the builtin functions field is indeed a pointer
1381         // and the pointer being filled in here, plus the vmctx is valid to
1382         // write to during initialization.
1383         unsafe {
1384             static BUILTINS: VMBuiltinFunctionsArray = VMBuiltinFunctionsArray::INIT;
1385             let ptr = BUILTINS.expose_provenance();
1386             let offsets = instance.runtime_info.offsets();
1387             instance
1388                 .vmctx_plus_offset_raw(offsets.ptr.vmctx_builtin_functions())
1389                 .write(VmPtr::from(ptr));
1390         }
1391 
1392         // Initialize the imports
1393         //
1394         // SAFETY: the vmctx is safe to initialize during this function and
1395         // validity of each item itself is a contract the caller must uphold.
1396         debug_assert_eq!(imports.functions.len(), module.num_imported_funcs);
1397         unsafe {
1398             let offsets = instance.runtime_info.offsets();
1399             ptr::copy_nonoverlapping(
1400                 imports.functions.as_ptr(),
1401                 instance
1402                     .vmctx_plus_offset_raw(offsets.vmctx_imported_functions_begin())
1403                     .as_ptr(),
1404                 imports.functions.len(),
1405             );
1406             debug_assert_eq!(imports.tables.len(), module.num_imported_tables);
1407             ptr::copy_nonoverlapping(
1408                 imports.tables.as_ptr(),
1409                 instance
1410                     .vmctx_plus_offset_raw(offsets.vmctx_imported_tables_begin())
1411                     .as_ptr(),
1412                 imports.tables.len(),
1413             );
1414             debug_assert_eq!(imports.memories.len(), module.num_imported_memories);
1415             ptr::copy_nonoverlapping(
1416                 imports.memories.as_ptr(),
1417                 instance
1418                     .vmctx_plus_offset_raw(offsets.vmctx_imported_memories_begin())
1419                     .as_ptr(),
1420                 imports.memories.len(),
1421             );
1422             debug_assert_eq!(imports.globals.len(), module.num_imported_globals);
1423             ptr::copy_nonoverlapping(
1424                 imports.globals.as_ptr(),
1425                 instance
1426                     .vmctx_plus_offset_raw(offsets.vmctx_imported_globals_begin())
1427                     .as_ptr(),
1428                 imports.globals.len(),
1429             );
1430             debug_assert_eq!(imports.tags.len(), module.num_imported_tags);
1431             ptr::copy_nonoverlapping(
1432                 imports.tags.as_ptr(),
1433                 instance
1434                     .vmctx_plus_offset_raw(offsets.vmctx_imported_tags_begin())
1435                     .as_ptr(),
1436                 imports.tags.len(),
1437             );
1438         }
1439 
1440         // N.B.: there is no need to initialize the funcrefs array because we
1441         // eagerly construct each element in it whenever asked for a reference
1442         // to that element. In other words, there is no state needed to track
1443         // the lazy-init, so we don't need to initialize any state now.
1444 
1445         // Initialize the defined tables
1446         //
1447         // SAFETY: it's safe to initialize these tables during initialization
1448         // here and the various types of pointers and such here should all be
1449         // valid.
1450         unsafe {
1451             let offsets = instance.runtime_info.offsets();
1452             let mut ptr = instance.vmctx_plus_offset_raw(offsets.vmctx_tables_begin());
1453             let tables = instance.as_mut().tables_mut();
1454             for i in 0..module.num_defined_tables() {
1455                 ptr.write(tables[DefinedTableIndex::new(i)].1.vmtable());
1456                 ptr = ptr.add(1);
1457             }
1458         }
1459 
1460         // Initialize the defined memories. This fills in both the
1461         // `defined_memories` table and the `owned_memories` table at the same
1462         // time. Entries in `defined_memories` hold a pointer to a definition
1463         // (all memories) whereas the `owned_memories` hold the actual
1464         // definitions of memories owned (not shared) in the module.
1465         //
1466         // SAFETY: it's safe to initialize these memories during initialization
1467         // here and the various types of pointers and such here should all be
1468         // valid.
1469         unsafe {
1470             let offsets = instance.runtime_info.offsets();
1471             let mut ptr = instance.vmctx_plus_offset_raw(offsets.vmctx_memories_begin());
1472             let mut owned_ptr =
1473                 instance.vmctx_plus_offset_raw(offsets.vmctx_owned_memories_begin());
1474             let memories = instance.as_mut().memories_mut();
1475             for i in 0..module.num_defined_memories() {
1476                 let defined_memory_index = DefinedMemoryIndex::new(i);
1477                 let memory_index = module.memory_index(defined_memory_index);
1478                 if module.memories[memory_index].shared {
1479                     let def_ptr = memories[defined_memory_index]
1480                         .1
1481                         .as_shared_memory()
1482                         .unwrap()
1483                         .vmmemory_ptr();
1484                     ptr.write(VmPtr::from(def_ptr));
1485                 } else {
1486                     owned_ptr.write(memories[defined_memory_index].1.vmmemory());
1487                     ptr.write(VmPtr::from(owned_ptr));
1488                     owned_ptr = owned_ptr.add(1);
1489                 }
1490                 ptr = ptr.add(1);
1491             }
1492         }
1493 
1494         // Zero-initialize the globals so that nothing is uninitialized memory
1495         // after this function returns. The globals are actually initialized
1496         // with their const expression initializers after the instance is fully
1497         // allocated.
1498         //
1499         // SAFETY: it's safe to initialize globals during initialization
1500         // here. Note that while the value being written is not valid for all
1501         // types of globals it's initializing the memory to zero instead of
1502         // being in an undefined state. So it's still unsafe to access globals
1503         // after this, but if it's read then it'd hopefully crash faster than
1504         // leaving this undefined.
1505         unsafe {
1506             for (index, _init) in module.global_initializers.iter() {
1507                 instance.global_ptr(index).write(VMGlobalDefinition::new());
1508             }
1509         }
1510 
1511         // Initialize the defined tags
1512         //
1513         // SAFETY: it's safe to initialize these tags during initialization
1514         // here and the various types of pointers and such here should all be
1515         // valid.
1516         unsafe {
1517             let offsets = instance.runtime_info.offsets();
1518             let mut ptr = instance.vmctx_plus_offset_raw(offsets.vmctx_tags_begin());
1519             for i in 0..module.num_defined_tags() {
1520                 let defined_index = DefinedTagIndex::new(i);
1521                 let tag_index = module.tag_index(defined_index);
1522                 let tag = module.tags[tag_index];
1523                 ptr.write(VMTagDefinition::new(
1524                     tag.signature.unwrap_engine_type_index(),
1525                 ));
1526                 ptr = ptr.add(1);
1527             }
1528         }
1529     }
1530 
1531     /// Attempts to convert from the host `addr` specified to a WebAssembly
1532     /// based address recorded in `WasmFault`.
1533     ///
1534     /// This method will check all linear memories that this instance contains
1535     /// to see if any of them contain `addr`. If one does then `Some` is
1536     /// returned with metadata about the wasm fault. Otherwise `None` is
1537     /// returned and `addr` doesn't belong to this instance.
1538     pub fn wasm_fault(&self, addr: usize) -> Option<WasmFault> {
1539         let mut fault = None;
1540         for (_, (_, memory)) in self.memories.iter() {
1541             let accessible = memory.wasm_accessible();
1542             if accessible.start <= addr && addr < accessible.end {
1543                 // All linear memories should be disjoint so assert that no
1544                 // prior fault has been found.
1545                 assert!(fault.is_none());
1546                 fault = Some(WasmFault {
1547                     memory_size: memory.byte_size(),
1548                     wasm_address: u64::try_from(addr - accessible.start).unwrap(),
1549                 });
1550             }
1551         }
1552         fault
1553     }
1554 
1555     /// Returns the id, within this instance's store, that it's assigned.
1556     pub fn id(&self) -> InstanceId {
1557         self.id
1558     }
1559 
1560     /// Get all memories within this instance.
1561     ///
1562     /// Returns both import and defined memories.
1563     ///
1564     /// Returns both exported and non-exported memories.
1565     ///
1566     /// Gives access to the full memories space.
1567     pub fn all_memories(
1568         &self,
1569         store: StoreId,
1570     ) -> impl ExactSizeIterator<Item = (MemoryIndex, ExportMemory)> + '_ {
1571         self.env_module()
1572             .memories
1573             .iter()
1574             .map(move |(i, _)| (i, self.get_exported_memory(store, i)))
1575     }
1576 
1577     /// Return the memories defined in this instance (not imported).
1578     pub fn defined_memories<'a>(
1579         &'a self,
1580         store: StoreId,
1581     ) -> impl ExactSizeIterator<Item = ExportMemory> + 'a {
1582         let num_imported = self.env_module().num_imported_memories;
1583         self.all_memories(store)
1584             .skip(num_imported)
1585             .map(|(_i, memory)| memory)
1586     }
1587 
1588     /// Lookup an item with the given index.
1589     ///
1590     /// # Panics
1591     ///
1592     /// Panics if `export` is not valid for this instance.
1593     ///
1594     /// # Safety
1595     ///
1596     /// This function requires that `store` is the correct store which owns this
1597     /// instance.
1598     pub unsafe fn get_export_by_index_mut(
1599         self: Pin<&mut Self>,
1600         registry: &ModuleRegistry,
1601         store: StoreId,
1602         export: EntityIndex,
1603     ) -> Export {
1604         match export {
1605             // SAFETY: the contract of `store` owning the this instance is a
1606             // safety requirement of this function itself.
1607             EntityIndex::Function(i) => {
1608                 Export::Function(unsafe { self.get_exported_func(registry, store, i) })
1609             }
1610             EntityIndex::Global(i) => Export::Global(self.get_exported_global(store, i)),
1611             EntityIndex::Table(i) => Export::Table(self.get_exported_table(store, i)),
1612             EntityIndex::Memory(i) => match self.get_exported_memory(store, i) {
1613                 ExportMemory::Unshared(m) => Export::Memory(m),
1614                 ExportMemory::Shared(m, i) => Export::SharedMemory(m, i),
1615             },
1616             EntityIndex::Tag(i) => Export::Tag(self.get_exported_tag(store, i)),
1617         }
1618     }
1619 
1620     fn store_mut(self: Pin<&mut Self>) -> &mut Option<VMStoreRawPtr> {
1621         // SAFETY: this is a pin-projection to get a mutable reference to an
1622         // internal field and is safe so long as the `&mut Self` temporarily
1623         // created is not overwritten, which it isn't here.
1624         unsafe { &mut self.get_unchecked_mut().store }
1625     }
1626 
1627     fn dropped_elements_mut(self: Pin<&mut Self>) -> &mut EntitySet<ElemIndex> {
1628         // SAFETY: see `store_mut` above.
1629         unsafe { &mut self.get_unchecked_mut().dropped_elements }
1630     }
1631 
1632     fn dropped_data_mut(self: Pin<&mut Self>) -> &mut EntitySet<DataIndex> {
1633         // SAFETY: see `store_mut` above.
1634         unsafe { &mut self.get_unchecked_mut().dropped_data }
1635     }
1636 
1637     fn memories_mut(
1638         self: Pin<&mut Self>,
1639     ) -> &mut PrimaryMap<DefinedMemoryIndex, (MemoryAllocationIndex, Memory)> {
1640         // SAFETY: see `store_mut` above.
1641         unsafe { &mut self.get_unchecked_mut().memories }
1642     }
1643 
1644     pub(crate) fn tables_mut(
1645         self: Pin<&mut Self>,
1646     ) -> &mut PrimaryMap<DefinedTableIndex, (TableAllocationIndex, Table)> {
1647         // SAFETY: see `store_mut` above.
1648         unsafe { &mut self.get_unchecked_mut().tables }
1649     }
1650 
1651     #[cfg(feature = "wmemcheck")]
1652     pub(super) fn wmemcheck_state_mut(self: Pin<&mut Self>) -> &mut Option<Wmemcheck> {
1653         // SAFETY: see `store_mut` above.
1654         unsafe { &mut self.get_unchecked_mut().wmemcheck_state }
1655     }
1656 }
1657 
1658 // SAFETY: `layout` should describe this accurately and `OwnedVMContext` is the
1659 // last field of `ComponentInstance`.
1660 unsafe impl InstanceLayout for Instance {
1661     const INIT_ZEROED: bool = false;
1662     type VMContext = VMContext;
1663 
1664     fn layout(&self) -> Layout {
1665         Self::alloc_layout(self.runtime_info.offsets())
1666     }
1667 
1668     fn owned_vmctx(&self) -> &OwnedVMContext<VMContext> {
1669         &self.vmctx
1670     }
1671 
1672     fn owned_vmctx_mut(&mut self) -> &mut OwnedVMContext<VMContext> {
1673         &mut self.vmctx
1674     }
1675 }
1676 
1677 pub type InstanceHandle = OwnedInstance<Instance>;
1678 
1679 /// A handle holding an `Instance` of a WebAssembly module.
1680 ///
1681 /// This structure is an owning handle of the `instance` contained internally.
1682 /// When this value goes out of scope it will deallocate the `Instance` and all
1683 /// memory associated with it.
1684 ///
1685 /// Note that this lives within a `StoreOpaque` on a list of instances that a
1686 /// store is keeping alive.
1687 #[derive(Debug)]
1688 #[repr(transparent)] // guarantee this is a zero-cost wrapper
1689 pub struct OwnedInstance<T: InstanceLayout> {
1690     /// The raw pointer to the instance that was allocated.
1691     ///
1692     /// Note that this is not equivalent to `Box<Instance>` because the
1693     /// allocation here has a `VMContext` trailing after it. Thus the custom
1694     /// destructor to invoke the `dealloc` function with the appropriate
1695     /// layout.
1696     instance: SendSyncPtr<T>,
1697     _marker: marker::PhantomData<Box<(T, OwnedVMContext<T::VMContext>)>>,
1698 }
1699 
1700 /// Structure that must be placed at the end of a type implementing
1701 /// `InstanceLayout`.
1702 #[repr(align(16))] // match the alignment of VMContext
1703 pub struct OwnedVMContext<T> {
1704     /// A pointer to the `vmctx` field at the end of the `structure`.
1705     ///
1706     /// If you're looking at this a reasonable question would be "why do we need
1707     /// a pointer to ourselves?" because after all the pointer's value is
1708     /// trivially derivable from any `&Instance` pointer. The rationale for this
1709     /// field's existence is subtle, but it's required for correctness. The
1710     /// short version is "this makes miri happy".
1711     ///
1712     /// The long version of why this field exists is that the rules that MIRI
1713     /// uses to ensure pointers are used correctly have various conditions on
1714     /// them depend on how pointers are used. More specifically if `*mut T` is
1715     /// derived from `&mut T`, then that invalidates all prior pointers drived
1716     /// from the `&mut T`. This means that while we liberally want to re-acquire
1717     /// a `*mut VMContext` throughout the implementation of `Instance` the
1718     /// trivial way, a function `fn vmctx(Pin<&mut Instance>) -> *mut VMContext`
1719     /// would effectively invalidate all prior `*mut VMContext` pointers
1720     /// acquired. The purpose of this field is to serve as a sort of
1721     /// source-of-truth for where `*mut VMContext` pointers come from.
1722     ///
1723     /// This field is initialized when the `Instance` is created with the
1724     /// original allocation's pointer. That means that the provenance of this
1725     /// pointer contains the entire allocation (both instance and `VMContext`).
1726     /// This provenance bit is then "carried through" where `fn vmctx` will base
1727     /// all returned pointers on this pointer itself. This provides the means of
1728     /// never invalidating this pointer throughout MIRI and additionally being
1729     /// able to still temporarily have `Pin<&mut Instance>` methods and such.
1730     ///
1731     /// It's important to note, though, that this is not here purely for MIRI.
1732     /// The careful construction of the `fn vmctx` method has ramifications on
1733     /// the LLVM IR generated, for example. A historical CVE on Wasmtime,
1734     /// GHSA-ch89-5g45-qwc7, was caused due to relying on undefined behavior. By
1735     /// deriving VMContext pointers from this pointer it specifically hints to
1736     /// LLVM that trickery is afoot and it properly informs `noalias` and such
1737     /// annotations and analysis. More-or-less this pointer is actually loaded
1738     /// in LLVM IR which helps defeat otherwise present aliasing optimizations,
1739     /// which we want, since writes to this should basically never be optimized
1740     /// out.
1741     ///
1742     /// As a final note it's worth pointing out that the machine code generated
1743     /// for accessing `fn vmctx` is still as one would expect. This member isn't
1744     /// actually ever loaded at runtime (or at least shouldn't be). Perhaps in
1745     /// the future if the memory consumption of this field is a problem we could
1746     /// shrink it slightly, but for now one extra pointer per wasm instance
1747     /// seems not too bad.
1748     vmctx_self_reference: SendSyncPtr<T>,
1749 
1750     /// This field ensures that going from `Pin<&mut T>` to `&mut T` is not a
1751     /// safe operation.
1752     _marker: core::marker::PhantomPinned,
1753 }
1754 
1755 impl<T> OwnedVMContext<T> {
1756     /// Creates a new blank vmctx to place at the end of an instance.
1757     pub fn new() -> OwnedVMContext<T> {
1758         OwnedVMContext {
1759             vmctx_self_reference: SendSyncPtr::new(NonNull::dangling()),
1760             _marker: core::marker::PhantomPinned,
1761         }
1762     }
1763 }
1764 
1765 /// Helper trait to plumb both core instances and component instances into
1766 /// `OwnedInstance` below.
1767 ///
1768 /// # Safety
1769 ///
1770 /// This trait requires `layout` to correctly describe `Self` and appropriately
1771 /// allocate space for `Self::VMContext` afterwards. Additionally the field
1772 /// returned by `owned_vmctx()` must be the last field in the structure.
1773 pub unsafe trait InstanceLayout {
1774     /// Whether or not to allocate this instance with `alloc_zeroed` or `alloc`.
1775     const INIT_ZEROED: bool;
1776 
1777     /// The trailing `VMContext` type at the end of this instance.
1778     type VMContext;
1779 
1780     /// The memory layout to use to allocate and deallocate this instance.
1781     fn layout(&self) -> Layout;
1782 
1783     fn owned_vmctx(&self) -> &OwnedVMContext<Self::VMContext>;
1784     fn owned_vmctx_mut(&mut self) -> &mut OwnedVMContext<Self::VMContext>;
1785 
1786     /// Returns the `vmctx_self_reference` set above.
1787     #[inline]
1788     fn vmctx(&self) -> NonNull<Self::VMContext> {
1789         // The definition of this method is subtle but intentional. The goal
1790         // here is that effectively this should return `&mut self.vmctx`, but
1791         // it's not quite so simple. Some more documentation is available on the
1792         // `vmctx_self_reference` field, but the general idea is that we're
1793         // creating a pointer to return with proper provenance. Provenance is
1794         // still in the works in Rust at the time of this writing but the load
1795         // of the `self.vmctx_self_reference` field is important here as it
1796         // affects how LLVM thinks about aliasing with respect to the returned
1797         // pointer.
1798         //
1799         // The intention of this method is to codegen to machine code as `&mut
1800         // self.vmctx`, however. While it doesn't show up like this in LLVM IR
1801         // (there's an actual load of the field) it does look like that by the
1802         // time the backend runs. (that's magic to me, the backend removing
1803         // loads...)
1804         let owned_vmctx = self.owned_vmctx();
1805         let owned_vmctx_raw = NonNull::from(owned_vmctx);
1806         // SAFETY: it's part of the contract of `InstanceLayout` and the usage
1807         // with `OwnedInstance` that this indeed points to the vmctx.
1808         let addr = unsafe { owned_vmctx_raw.add(1) };
1809         owned_vmctx
1810             .vmctx_self_reference
1811             .as_non_null()
1812             .with_addr(addr.addr())
1813     }
1814 
1815     /// Helper function to access various locations offset from our `*mut
1816     /// VMContext` object.
1817     ///
1818     /// Note that this method takes `&self` as an argument but returns
1819     /// `NonNull<T>` which is frequently used to mutate said memory. This is an
1820     /// intentional design decision where the safety of the modification of
1821     /// memory is placed as a burden onto the caller. The implementation of this
1822     /// method explicitly does not require `&mut self` to acquire mutable
1823     /// provenance to update the `VMContext` region. Instead all pointers into
1824     /// the `VMContext` area have provenance/permissions to write.
1825     ///
1826     /// Also note though that care must be taken to ensure that reads/writes of
1827     /// memory must only happen where appropriate, for example a non-atomic
1828     /// write (as most are) should never happen concurrently with another read
1829     /// or write. It's generally on the burden of the caller to adhere to this.
1830     ///
1831     /// Also of note is that most of the time the usage of this method falls
1832     /// into one of:
1833     ///
1834     /// * Something in the VMContext is being read or written. In that case use
1835     ///   `vmctx_plus_offset` or `vmctx_plus_offset_mut` if possible due to
1836     ///   that having a safer lifetime.
1837     ///
1838     /// * A pointer is being created to pass to other VM* data structures. In
1839     ///   that situation the lifetime of all VM data structures are typically
1840     ///   tied to the `Store<T>` which is what provides the guarantees around
1841     ///   concurrency/etc.
1842     ///
1843     /// There's quite a lot of unsafety riding on this method, especially
1844     /// related to the ascription `T` of the byte `offset`. It's hoped that in
1845     /// the future we're able to settle on an in theory safer design.
1846     ///
1847     /// # Safety
1848     ///
1849     /// This method is unsafe because the `offset` must be within bounds of the
1850     /// `VMContext` object trailing this instance. Additionally `T` must be a
1851     /// valid ascription of the value that resides at that location.
1852     unsafe fn vmctx_plus_offset_raw<T: VmSafe>(&self, offset: impl Into<u32>) -> NonNull<T> {
1853         // SAFETY: the safety requirements of `byte_add` are forwarded to this
1854         // method's caller.
1855         unsafe {
1856             self.vmctx()
1857                 .byte_add(usize::try_from(offset.into()).unwrap())
1858                 .cast()
1859         }
1860     }
1861 
1862     /// Helper above `vmctx_plus_offset_raw` which transfers the lifetime of
1863     /// `&self` to the returned reference `&T`.
1864     ///
1865     /// # Safety
1866     ///
1867     /// See the safety documentation of `vmctx_plus_offset_raw`.
1868     unsafe fn vmctx_plus_offset<T: VmSafe>(&self, offset: impl Into<u32>) -> &T {
1869         // SAFETY: this method has the same safety requirements as
1870         // `vmctx_plus_offset_raw`.
1871         unsafe { self.vmctx_plus_offset_raw(offset).as_ref() }
1872     }
1873 
1874     /// Helper above `vmctx_plus_offset_raw` which transfers the lifetime of
1875     /// `&mut self` to the returned reference `&mut T`.
1876     ///
1877     /// # Safety
1878     ///
1879     /// See the safety documentation of `vmctx_plus_offset_raw`.
1880     unsafe fn vmctx_plus_offset_mut<T: VmSafe>(
1881         self: Pin<&mut Self>,
1882         offset: impl Into<u32>,
1883     ) -> &mut T {
1884         // SAFETY: this method has the same safety requirements as
1885         // `vmctx_plus_offset_raw`.
1886         unsafe { self.vmctx_plus_offset_raw(offset).as_mut() }
1887     }
1888 }
1889 
1890 impl<T: InstanceLayout> OwnedInstance<T> {
1891     /// Allocates a new `OwnedInstance` and places `instance` inside of it.
1892     ///
1893     /// This will `instance`
1894     pub(super) fn new(mut instance: T) -> OwnedInstance<T> {
1895         let layout = instance.layout();
1896         debug_assert!(layout.size() >= size_of_val(&instance));
1897         debug_assert!(layout.align() >= align_of_val(&instance));
1898 
1899         // SAFETY: it's up to us to assert that `layout` has a non-zero size,
1900         // which is asserted here.
1901         let ptr = unsafe {
1902             assert!(layout.size() > 0);
1903             if T::INIT_ZEROED {
1904                 alloc::alloc::alloc_zeroed(layout)
1905             } else {
1906                 alloc::alloc::alloc(layout)
1907             }
1908         };
1909         if ptr.is_null() {
1910             alloc::alloc::handle_alloc_error(layout);
1911         }
1912         let instance_ptr = NonNull::new(ptr.cast::<T>()).unwrap();
1913 
1914         // SAFETY: it's part of the unsafe contract of `InstanceLayout` that the
1915         // `add` here is appropriate for the layout allocated.
1916         let vmctx_self_reference = unsafe { instance_ptr.add(1).cast() };
1917         instance.owned_vmctx_mut().vmctx_self_reference = vmctx_self_reference.into();
1918 
1919         // SAFETY: we allocated above and it's an unsafe contract of
1920         // `InstanceLayout` that the layout is suitable for writing the
1921         // instance.
1922         unsafe {
1923             instance_ptr.write(instance);
1924         }
1925 
1926         let ret = OwnedInstance {
1927             instance: SendSyncPtr::new(instance_ptr),
1928             _marker: marker::PhantomData,
1929         };
1930 
1931         // Double-check various vmctx calculations are correct.
1932         debug_assert_eq!(
1933             vmctx_self_reference.addr(),
1934             // SAFETY: `InstanceLayout` should guarantee it's safe to add 1 to
1935             // the last field to get a pointer to 1-byte-past-the-end of an
1936             // object, which should be valid.
1937             unsafe { NonNull::from(ret.get().owned_vmctx()).add(1).addr() }
1938         );
1939         debug_assert_eq!(vmctx_self_reference.addr(), ret.get().vmctx().addr());
1940 
1941         ret
1942     }
1943 
1944     /// Gets the raw underlying `&Instance` from this handle.
1945     pub fn get(&self) -> &T {
1946         // SAFETY: this is an owned instance handle that retains exclusive
1947         // ownership of the `Instance` inside. With `&self` given we know
1948         // this pointer is valid valid and the returned lifetime is connected
1949         // to `self` so that should also be valid.
1950         unsafe { self.instance.as_non_null().as_ref() }
1951     }
1952 
1953     /// Same as [`Self::get`] except for mutability.
1954     pub fn get_mut(&mut self) -> Pin<&mut T> {
1955         // SAFETY: The lifetime concerns here are the same as `get` above.
1956         // Otherwise `new_unchecked` is used here to uphold the contract that
1957         // instances are always pinned in memory.
1958         unsafe { Pin::new_unchecked(self.instance.as_non_null().as_mut()) }
1959     }
1960 }
1961 
1962 impl<T: InstanceLayout> Drop for OwnedInstance<T> {
1963     fn drop(&mut self) {
1964         unsafe {
1965             let layout = self.get().layout();
1966             ptr::drop_in_place(self.instance.as_ptr());
1967             alloc::alloc::dealloc(self.instance.as_ptr().cast(), layout);
1968         }
1969     }
1970 }
1971