wasmtime/runtime/
instance.rs

1use crate::linker::{Definition, DefinitionType};
2use crate::prelude::*;
3use crate::runtime::vm::{
4    self, Imports, ModuleRuntimeInfo, VMFuncRef, VMFunctionImport, VMGlobalImport, VMMemoryImport,
5    VMOpaqueContext, VMTableImport, VMTagImport,
6};
7use crate::store::{AllocateInstanceKind, InstanceId, StoreInstanceId, StoreOpaque};
8use crate::types::matching;
9use crate::{
10    AsContextMut, Engine, Export, Extern, Func, Global, Memory, Module, ModuleExport, SharedMemory,
11    StoreContext, StoreContextMut, Table, Tag, TypedFunc,
12};
13use alloc::sync::Arc;
14use core::ptr::NonNull;
15use wasmparser::WasmFeatures;
16use wasmtime_environ::{
17    EntityIndex, EntityType, FuncIndex, GlobalIndex, MemoryIndex, PrimaryMap, TableIndex, TagIndex,
18    TypeTrace,
19};
20
21/// An instantiated WebAssembly module.
22///
23/// This type represents the instantiation of a [`Module`]. Once instantiated
24/// you can access the [`exports`](Instance::exports) which are of type
25/// [`Extern`] and provide the ability to call functions, set globals, read
26/// memory, etc. When interacting with any wasm code you'll want to make an
27/// [`Instance`] to call any code or execute anything.
28///
29/// Instances are owned by a [`Store`](crate::Store) which is passed in at
30/// creation time. It's recommended to create instances with
31/// [`Linker::instantiate`](crate::Linker::instantiate) or similar
32/// [`Linker`](crate::Linker) methods, but a more low-level constructor is also
33/// available as [`Instance::new`].
34#[derive(Copy, Clone, Debug)]
35#[repr(C)]
36pub struct Instance {
37    id: StoreInstanceId,
38}
39
40// Double-check that the C representation in `instance.h` matches our in-Rust
41// representation here in terms of size/alignment/etc.
42const _: () = {
43    #[repr(C)]
44    struct C(u64, usize);
45    assert!(core::mem::size_of::<C>() == core::mem::size_of::<Instance>());
46    assert!(core::mem::align_of::<C>() == core::mem::align_of::<Instance>());
47    assert!(core::mem::offset_of!(Instance, id) == 0);
48};
49
50impl Instance {
51    /// Creates a new [`Instance`] from the previously compiled [`Module`] and
52    /// list of `imports` specified.
53    ///
54    /// This method instantiates the `module` provided with the `imports`,
55    /// following the procedure in the [core specification][inst] to
56    /// instantiate. Instantiation can fail for a number of reasons (many
57    /// specified below), but if successful the `start` function will be
58    /// automatically run (if specified in the `module`) and then the
59    /// [`Instance`] will be returned.
60    ///
61    /// Per the WebAssembly spec, instantiation includes running the module's
62    /// start function, if it has one (not to be confused with the `_start`
63    /// function, which is not run).
64    ///
65    /// Note that this is a low-level function that just performs an
66    /// instantiation. See the [`Linker`](crate::Linker) struct for an API which
67    /// provides a convenient way to link imports and provides automatic Command
68    /// and Reactor behavior.
69    ///
70    /// ## Providing Imports
71    ///
72    /// The entries in the list of `imports` are intended to correspond 1:1
73    /// with the list of imports returned by [`Module::imports`]. Before
74    /// calling [`Instance::new`] you'll want to inspect the return value of
75    /// [`Module::imports`] and, for each import type, create an [`Extern`]
76    /// which corresponds to that type.  These [`Extern`] values are all then
77    /// collected into a list and passed to this function.
78    ///
79    /// Note that this function is intentionally relatively low level. For an
80    /// easier time passing imports by doing name-based resolution it's
81    /// recommended to instead use the [`Linker`](crate::Linker) type.
82    ///
83    /// ## Errors
84    ///
85    /// This function can fail for a number of reasons, including, but not
86    /// limited to:
87    ///
88    /// * The number of `imports` provided doesn't match the number of imports
89    ///   returned by the `module`'s [`Module::imports`] method.
90    /// * The type of any [`Extern`] doesn't match the corresponding
91    ///   [`ExternType`] entry that it maps to.
92    /// * The `start` function in the instance, if present, traps.
93    /// * Module/instance resource limits are exceeded.
94    ///
95    /// When instantiation fails it's recommended to inspect the return value to
96    /// see why it failed, or bubble it upwards. If you'd like to specifically
97    /// check for trap errors, you can use `error.downcast::<Trap>()`. For more
98    /// about error handling see the [`Trap`] documentation.
99    ///
100    /// [`Trap`]: crate::Trap
101    ///
102    /// # Panics
103    ///
104    /// This function will panic if called with a store associated with a
105    /// [`asynchronous config`](crate::Config::async_support). This function
106    /// will also panic if any [`Extern`] supplied is not owned by `store`.
107    ///
108    /// [inst]: https://webassembly.github.io/spec/core/exec/modules.html#exec-instantiation
109    /// [`ExternType`]: crate::ExternType
110    pub fn new(
111        mut store: impl AsContextMut,
112        module: &Module,
113        imports: &[Extern],
114    ) -> Result<Instance> {
115        let mut store = store.as_context_mut();
116        let imports = Instance::typecheck_externs(store.0, module, imports)?;
117        // Note that the unsafety here should be satisfied by the call to
118        // `typecheck_externs` above which satisfies the condition that all
119        // the imports are valid for this module.
120        unsafe { Instance::new_started(&mut store, module, imports.as_ref()) }
121    }
122
123    /// Same as [`Instance::new`], except for usage in [asynchronous stores].
124    ///
125    /// For more details about this function see the documentation on
126    /// [`Instance::new`]. The only difference between these two methods is that
127    /// this one will asynchronously invoke the wasm start function in case it
128    /// calls any imported function which is an asynchronous host function (e.g.
129    /// created with [`Func::new_async`](crate::Func::new_async).
130    ///
131    /// # Panics
132    ///
133    /// This function will panic if called with a store associated with a
134    /// [`synchronous config`](crate::Config::new). This is only compatible with
135    /// stores associated with an [`asynchronous
136    /// config`](crate::Config::async_support).
137    ///
138    /// This function will also panic, like [`Instance::new`], if any [`Extern`]
139    /// specified does not belong to `store`.
140    #[cfg(feature = "async")]
141    pub async fn new_async(
142        mut store: impl AsContextMut<Data: Send>,
143        module: &Module,
144        imports: &[Extern],
145    ) -> Result<Instance> {
146        let mut store = store.as_context_mut();
147        let imports = Instance::typecheck_externs(store.0, module, imports)?;
148        // See `new` for notes on this unsafety
149        unsafe { Instance::new_started_async(&mut store, module, imports.as_ref()).await }
150    }
151
152    fn typecheck_externs(
153        store: &mut StoreOpaque,
154        module: &Module,
155        imports: &[Extern],
156    ) -> Result<OwnedImports> {
157        for import in imports {
158            if !import.comes_from_same_store(store) {
159                bail!("cross-`Store` instantiation is not currently supported");
160            }
161        }
162
163        typecheck(module, imports, |cx, ty, item| {
164            let item = DefinitionType::from(store, item);
165            cx.definition(ty, &item)
166        })?;
167
168        // When pushing functions into `OwnedImports` it's required that their
169        // `wasm_call` fields are all filled out. This `module` is guaranteed
170        // to have any trampolines necessary for functions so register the
171        // module with the store and then attempt to fill out any outstanding
172        // holes.
173        //
174        // Note that under normal operation this shouldn't do much as the list
175        // of funcs-with-holes should generally be empty. As a result the
176        // process of filling this out is not super optimized at this point.
177        store.modules_mut().register_module(module);
178        let (funcrefs, modules) = store.func_refs_and_modules();
179        funcrefs.fill(modules);
180
181        let mut owned_imports = OwnedImports::new(module);
182        for import in imports {
183            owned_imports.push(import, store);
184        }
185        Ok(owned_imports)
186    }
187
188    /// Internal function to create an instance and run the start function.
189    ///
190    /// This function's unsafety is the same as `Instance::new_raw`.
191    pub(crate) unsafe fn new_started<T>(
192        store: &mut StoreContextMut<'_, T>,
193        module: &Module,
194        imports: Imports<'_>,
195    ) -> Result<Instance> {
196        assert!(
197            !store.0.async_support(),
198            "must use async instantiation when async support is enabled",
199        );
200        Self::new_started_impl(store, module, imports)
201    }
202
203    /// Internal function to create an instance and run the start function.
204    ///
205    /// ONLY CALL THIS IF YOU HAVE ALREADY CHECKED FOR ASYNCNESS AND HANDLED
206    /// THE FIBER NONSENSE
207    pub(crate) unsafe fn new_started_impl<T>(
208        store: &mut StoreContextMut<'_, T>,
209        module: &Module,
210        imports: Imports<'_>,
211    ) -> Result<Instance> {
212        let (instance, start) = Instance::new_raw(store.0, module, imports)?;
213        if let Some(start) = start {
214            instance.start_raw(store, start)?;
215        }
216        Ok(instance)
217    }
218
219    /// Internal function to create an instance and run the start function.
220    ///
221    /// This function's unsafety is the same as `Instance::new_raw`.
222    #[cfg(feature = "async")]
223    async unsafe fn new_started_async<T>(
224        store: &mut StoreContextMut<'_, T>,
225        module: &Module,
226        imports: Imports<'_>,
227    ) -> Result<Instance>
228    where
229        T: Send + 'static,
230    {
231        assert!(
232            store.0.async_support(),
233            "must use sync instantiation when async support is disabled",
234        );
235
236        store
237            .on_fiber(|store| Self::new_started_impl(store, module, imports))
238            .await?
239    }
240
241    /// Internal function to create an instance which doesn't have its `start`
242    /// function run yet.
243    ///
244    /// This is not intended to be exposed from Wasmtime, it's intended to
245    /// refactor out common code from `new_started` and `new_started_async`.
246    ///
247    /// Note that this step needs to be run on a fiber in async mode even
248    /// though it doesn't do any blocking work because an async resource
249    /// limiter may need to yield.
250    ///
251    /// # Unsafety
252    ///
253    /// This method is unsafe because it does not type-check the `imports`
254    /// provided. The `imports` provided must be suitable for the module
255    /// provided as well.
256    unsafe fn new_raw(
257        store: &mut StoreOpaque,
258        module: &Module,
259        imports: Imports<'_>,
260    ) -> Result<(Instance, Option<FuncIndex>)> {
261        if !Engine::same(store.engine(), module.engine()) {
262            bail!("cross-`Engine` instantiation is not currently supported");
263        }
264        store.bump_resource_counts(module)?;
265
266        // Allocate the GC heap, if necessary.
267        if module.env_module().needs_gc_heap {
268            let _ = store.gc_store_mut()?;
269        }
270
271        let compiled_module = module.compiled_module();
272
273        // Register the module just before instantiation to ensure we keep the module
274        // properly referenced while in use by the store.
275        let module_id = store.modules_mut().register_module(module);
276
277        // The first thing we do is issue an instance allocation request
278        // to the instance allocator. This, on success, will give us an
279        // instance handle.
280        let id = store.allocate_instance(
281            AllocateInstanceKind::Module(module_id),
282            &ModuleRuntimeInfo::Module(module.clone()),
283            imports,
284        )?;
285
286        // Additionally, before we start doing fallible instantiation, we
287        // do one more step which is to insert an `InstanceData`
288        // corresponding to this instance. This `InstanceData` can be used
289        // via `Caller::get_export` if our instance's state "leaks" into
290        // other instances, even if we don't return successfully from this
291        // function.
292        //
293        // We don't actually load all exports from the instance at this
294        // time, instead preferring to lazily load them as they're demanded.
295        // For module/instance exports, though, those aren't actually
296        // stored in the instance handle so we need to immediately handle
297        // those here.
298        let instance = Instance::from_wasmtime(id, store);
299
300        // Now that we've recorded all information we need to about this
301        // instance within a `Store` we can start performing fallible
302        // initialization. Note that we still defer the `start` function to
303        // later since that may need to run asynchronously.
304        //
305        // If this returns an error (or if the start function traps) then
306        // any other initialization which may have succeeded which placed
307        // items from this instance into other instances should be ok when
308        // those items are loaded and run we'll have all the metadata to
309        // look at them.
310        let bulk_memory = store
311            .engine()
312            .features()
313            .contains(WasmFeatures::BULK_MEMORY);
314
315        vm::initialize_instance(store, id, compiled_module.module(), bulk_memory)?;
316
317        Ok((instance, compiled_module.module().start_func))
318    }
319
320    pub(crate) fn from_wasmtime(id: InstanceId, store: &mut StoreOpaque) -> Instance {
321        Instance {
322            id: StoreInstanceId::new(store.id(), id),
323        }
324    }
325
326    fn start_raw<T>(&self, store: &mut StoreContextMut<'_, T>, start: FuncIndex) -> Result<()> {
327        // If a start function is present, invoke it. Make sure we use all the
328        // trap-handling configuration in `store` as well.
329        let instance = self.id.get_mut(store.0);
330        let f = instance.get_exported_func(start);
331        let caller_vmctx = instance.vmctx();
332        unsafe {
333            super::func::invoke_wasm_and_catch_traps(store, |_default_caller, vm| {
334                f.func_ref.as_ref().array_call(
335                    vm,
336                    VMOpaqueContext::from_vmcontext(caller_vmctx),
337                    NonNull::from(&mut []),
338                )
339            })?;
340        }
341        Ok(())
342    }
343
344    /// Get this instance's module.
345    pub fn module<'a, T: 'static>(&self, store: impl Into<StoreContext<'a, T>>) -> &'a Module {
346        self._module(store.into().0)
347    }
348
349    fn _module<'a>(&self, store: &'a StoreOpaque) -> &'a Module {
350        store.module_for_instance(self.id).unwrap()
351    }
352
353    /// Returns the list of exported items from this [`Instance`].
354    ///
355    /// # Panics
356    ///
357    /// Panics if `store` does not own this instance.
358    pub fn exports<'a, T: 'static>(
359        &'a self,
360        store: impl Into<StoreContextMut<'a, T>>,
361    ) -> impl ExactSizeIterator<Item = Export<'a>> + 'a {
362        self._exports(store.into().0)
363    }
364
365    fn _exports<'a>(
366        &'a self,
367        store: &'a mut StoreOpaque,
368    ) -> impl ExactSizeIterator<Item = Export<'a>> + 'a {
369        store[self.id]
370            .env_module()
371            .exports
372            .iter()
373            .map(|(name, entity)| Export::new(name, self._get_export(store, *entity)))
374    }
375
376    /// Looks up an exported [`Extern`] value by name.
377    ///
378    /// This method will search the module for an export named `name` and return
379    /// the value, if found.
380    ///
381    /// Returns `None` if there was no export named `name`.
382    ///
383    /// # Panics
384    ///
385    /// Panics if `store` does not own this instance.
386    ///
387    /// # Why does `get_export` take a mutable context?
388    ///
389    /// This method requires a mutable context because an instance's exports are
390    /// lazily populated, and we cache them as they are accessed. This makes
391    /// instantiating a module faster, but also means this method requires a
392    /// mutable context.
393    pub fn get_export(&self, mut store: impl AsContextMut, name: &str) -> Option<Extern> {
394        let store = store.as_context_mut().0;
395        let entity = *store[self.id].env_module().exports.get(name)?;
396        Some(self._get_export(store, entity))
397    }
398
399    /// Looks up an exported [`Extern`] value by a [`ModuleExport`] value.
400    ///
401    /// This is similar to [`Instance::get_export`] but uses a [`ModuleExport`] value to avoid
402    /// string lookups where possible. [`ModuleExport`]s can be obtained by calling
403    /// [`Module::get_export_index`] on the [`Module`] that this instance was instantiated with.
404    ///
405    /// This method will search the module for an export with a matching entity index and return
406    /// the value, if found.
407    ///
408    /// Returns `None` if there was no export with a matching entity index.
409    /// # Panics
410    ///
411    /// Panics if `store` does not own this instance.
412    pub fn get_module_export(
413        &self,
414        mut store: impl AsContextMut,
415        export: &ModuleExport,
416    ) -> Option<Extern> {
417        let store = store.as_context_mut().0;
418
419        // Verify the `ModuleExport` matches the module used in this instance.
420        if self._module(store).id() != export.module {
421            return None;
422        }
423
424        Some(self._get_export(store, export.entity))
425    }
426
427    fn _get_export(&self, store: &StoreOpaque, entity: EntityIndex) -> Extern {
428        let export = store[self.id].get_export_by_index(entity);
429        unsafe { Extern::from_wasmtime_export(export, store) }
430    }
431
432    /// Looks up an exported [`Func`] value by name.
433    ///
434    /// Returns `None` if there was no export named `name`, or if there was but
435    /// it wasn't a function.
436    ///
437    /// # Panics
438    ///
439    /// Panics if `store` does not own this instance.
440    pub fn get_func(&self, store: impl AsContextMut, name: &str) -> Option<Func> {
441        self.get_export(store, name)?.into_func()
442    }
443
444    /// Looks up an exported [`Func`] value by name and with its type.
445    ///
446    /// This function is a convenience wrapper over [`Instance::get_func`] and
447    /// [`Func::typed`]. For more information see the linked documentation.
448    ///
449    /// Returns an error if `name` isn't a function export or if the export's
450    /// type did not match `Params` or `Results`
451    ///
452    /// # Panics
453    ///
454    /// Panics if `store` does not own this instance.
455    pub fn get_typed_func<Params, Results>(
456        &self,
457        mut store: impl AsContextMut,
458        name: &str,
459    ) -> Result<TypedFunc<Params, Results>>
460    where
461        Params: crate::WasmParams,
462        Results: crate::WasmResults,
463    {
464        let f = self
465            .get_export(store.as_context_mut(), name)
466            .and_then(|f| f.into_func())
467            .ok_or_else(|| anyhow!("failed to find function export `{}`", name))?;
468        Ok(f.typed::<Params, Results>(store)
469            .with_context(|| format!("failed to convert function `{name}` to given type"))?)
470    }
471
472    /// Looks up an exported [`Table`] value by name.
473    ///
474    /// Returns `None` if there was no export named `name`, or if there was but
475    /// it wasn't a table.
476    ///
477    /// # Panics
478    ///
479    /// Panics if `store` does not own this instance.
480    pub fn get_table(&self, store: impl AsContextMut, name: &str) -> Option<Table> {
481        self.get_export(store, name)?.into_table()
482    }
483
484    /// Looks up an exported [`Memory`] value by name.
485    ///
486    /// Returns `None` if there was no export named `name`, or if there was but
487    /// it wasn't a memory.
488    ///
489    /// # Panics
490    ///
491    /// Panics if `store` does not own this instance.
492    pub fn get_memory(&self, store: impl AsContextMut, name: &str) -> Option<Memory> {
493        self.get_export(store, name)?.into_memory()
494    }
495
496    /// Looks up an exported [`SharedMemory`] value by name.
497    ///
498    /// Returns `None` if there was no export named `name`, or if there was but
499    /// it wasn't a shared memory.
500    ///
501    /// # Panics
502    ///
503    /// Panics if `store` does not own this instance.
504    pub fn get_shared_memory(
505        &self,
506        mut store: impl AsContextMut,
507        name: &str,
508    ) -> Option<SharedMemory> {
509        let mut store = store.as_context_mut();
510        self.get_export(&mut store, name)?.into_shared_memory()
511    }
512
513    /// Looks up an exported [`Global`] value by name.
514    ///
515    /// Returns `None` if there was no export named `name`, or if there was but
516    /// it wasn't a global.
517    ///
518    /// # Panics
519    ///
520    /// Panics if `store` does not own this instance.
521    pub fn get_global(&self, store: impl AsContextMut, name: &str) -> Option<Global> {
522        self.get_export(store, name)?.into_global()
523    }
524
525    /// Looks up a tag [`Tag`] by name.
526    ///
527    /// Returns `None` if there was no export named `name`, or if there was but
528    /// it wasn't a tag.
529    ///
530    /// # Panics
531    ///
532    /// Panics if `store` does not own this instance.
533    pub fn get_tag(&self, store: impl AsContextMut, name: &str) -> Option<Tag> {
534        self.get_export(store, name)?.into_tag()
535    }
536
537    #[cfg(feature = "component-model")]
538    pub(crate) fn id(&self) -> InstanceId {
539        self.id.instance()
540    }
541
542    /// Get all globals within this instance.
543    ///
544    /// Returns both import and defined globals.
545    ///
546    /// Returns both exported and non-exported globals.
547    ///
548    /// Gives access to the full globals space.
549    #[cfg(feature = "coredump")]
550    pub(crate) fn all_globals<'a>(
551        &'a self,
552        store: &'a mut StoreOpaque,
553    ) -> impl ExactSizeIterator<Item = (GlobalIndex, Global)> + 'a {
554        store[self.id]
555            .all_globals()
556            .collect::<Vec<_>>()
557            .into_iter()
558            .map(|(i, g)| (i, unsafe { Global::from_wasmtime_global(g, store) }))
559    }
560
561    /// Get all memories within this instance.
562    ///
563    /// Returns both import and defined memories.
564    ///
565    /// Returns both exported and non-exported memories.
566    ///
567    /// Gives access to the full memories space.
568    #[cfg(feature = "coredump")]
569    pub(crate) fn all_memories<'a>(
570        &'a self,
571        store: &'a mut StoreOpaque,
572    ) -> impl ExactSizeIterator<Item = (MemoryIndex, Memory)> + 'a {
573        store[self.id]
574            .all_memories()
575            .collect::<Vec<_>>()
576            .into_iter()
577            .map(|(i, m)| (i, unsafe { Memory::from_wasmtime_memory(m, store) }))
578    }
579}
580
581pub(crate) struct OwnedImports {
582    functions: PrimaryMap<FuncIndex, VMFunctionImport>,
583    tables: PrimaryMap<TableIndex, VMTableImport>,
584    memories: PrimaryMap<MemoryIndex, VMMemoryImport>,
585    globals: PrimaryMap<GlobalIndex, VMGlobalImport>,
586    tags: PrimaryMap<TagIndex, VMTagImport>,
587}
588
589impl OwnedImports {
590    fn new(module: &Module) -> OwnedImports {
591        let mut ret = OwnedImports::empty();
592        ret.reserve(module);
593        return ret;
594    }
595
596    pub(crate) fn empty() -> OwnedImports {
597        OwnedImports {
598            functions: PrimaryMap::new(),
599            tables: PrimaryMap::new(),
600            memories: PrimaryMap::new(),
601            globals: PrimaryMap::new(),
602            tags: PrimaryMap::new(),
603        }
604    }
605
606    pub(crate) fn reserve(&mut self, module: &Module) {
607        let raw = module.compiled_module().module();
608        self.functions.reserve(raw.num_imported_funcs);
609        self.tables.reserve(raw.num_imported_tables);
610        self.memories.reserve(raw.num_imported_memories);
611        self.globals.reserve(raw.num_imported_globals);
612        self.tags.reserve(raw.num_imported_tags);
613    }
614
615    #[cfg(feature = "component-model")]
616    pub(crate) fn clear(&mut self) {
617        self.functions.clear();
618        self.tables.clear();
619        self.memories.clear();
620        self.globals.clear();
621        self.tags.clear();
622    }
623
624    fn push(&mut self, item: &Extern, store: &mut StoreOpaque) {
625        match item {
626            Extern::Func(i) => {
627                self.functions.push(i.vmimport(store));
628            }
629            Extern::Global(i) => {
630                self.globals.push(i.vmimport(store));
631            }
632            Extern::Table(i) => {
633                self.tables.push(i.vmimport(store));
634            }
635            Extern::Memory(i) => {
636                self.memories.push(i.vmimport(store));
637            }
638            Extern::SharedMemory(i) => {
639                self.memories.push(i.vmimport(store));
640            }
641            Extern::Tag(i) => {
642                self.tags.push(i.vmimport(store));
643            }
644        }
645    }
646
647    /// Note that this is unsafe as the validity of `item` is not verified and
648    /// it contains a bunch of raw pointers.
649    #[cfg(feature = "component-model")]
650    pub(crate) unsafe fn push_export(&mut self, item: &crate::runtime::vm::Export) {
651        match item {
652            crate::runtime::vm::Export::Function(f) => {
653                let f = f.func_ref.as_ref();
654                self.functions.push(VMFunctionImport {
655                    wasm_call: f.wasm_call.unwrap(),
656                    array_call: f.array_call,
657                    vmctx: f.vmctx,
658                });
659            }
660            crate::runtime::vm::Export::Global(g) => {
661                self.globals.push(g.vmimport());
662            }
663            crate::runtime::vm::Export::Table(t) => {
664                self.tables.push(VMTableImport {
665                    from: t.definition.into(),
666                    vmctx: t.vmctx.into(),
667                    index: t.index,
668                });
669            }
670            crate::runtime::vm::Export::Memory(m) => {
671                self.memories.push(VMMemoryImport {
672                    from: m.definition.into(),
673                    vmctx: m.vmctx.into(),
674                    index: m.index,
675                });
676            }
677            crate::runtime::vm::Export::Tag(t) => {
678                self.tags.push(VMTagImport {
679                    from: t.definition.into(),
680                    vmctx: t.vmctx.into(),
681                    index: t.index,
682                });
683            }
684        }
685    }
686
687    pub(crate) fn as_ref(&self) -> Imports<'_> {
688        Imports {
689            tables: self.tables.values().as_slice(),
690            globals: self.globals.values().as_slice(),
691            memories: self.memories.values().as_slice(),
692            functions: self.functions.values().as_slice(),
693            tags: self.tags.values().as_slice(),
694        }
695    }
696}
697
698/// An instance, pre-instantiation, that is ready to be instantiated.
699///
700/// This structure represents an instance *just before* it was instantiated,
701/// after all type-checking and imports have been resolved. The only thing left
702/// to do for this instance is to actually run the process of instantiation.
703///
704/// Note that an `InstancePre` may not be tied to any particular [`Store`] if
705/// none of the imports it closed over are tied to any particular [`Store`].
706///
707/// This structure is created through the [`Linker::instantiate_pre`] method,
708/// which also has some more information and examples.
709///
710/// [`Store`]: crate::Store
711/// [`Linker::instantiate_pre`]: crate::Linker::instantiate_pre
712pub struct InstancePre<T> {
713    module: Module,
714
715    /// The items which this `InstancePre` use to instantiate the `module`
716    /// provided, passed to `Instance::new_started` after inserting them into a
717    /// `Store`.
718    ///
719    /// Note that this is stored as an `Arc<[T]>` to quickly move a strong
720    /// reference to everything internally into a `Store<T>` without having to
721    /// clone each individual item.
722    items: Arc<[Definition]>,
723
724    /// A count of `Definition::HostFunc` entries in `items` above to
725    /// preallocate space in a `Store` up front for all entries to be inserted.
726    host_funcs: usize,
727
728    /// The `VMFuncRef`s for the functions in `items` that do not
729    /// have a `wasm_call` trampoline. We pre-allocate and pre-patch these
730    /// `VMFuncRef`s so that we don't have to do it at
731    /// instantiation time.
732    ///
733    /// This is an `Arc<[T]>` for the same reason as `items`.
734    func_refs: Arc<[VMFuncRef]>,
735
736    _marker: core::marker::PhantomData<fn() -> T>,
737}
738
739/// InstancePre's clone does not require T: Clone
740impl<T> Clone for InstancePre<T> {
741    fn clone(&self) -> Self {
742        Self {
743            module: self.module.clone(),
744            items: self.items.clone(),
745            host_funcs: self.host_funcs,
746            func_refs: self.func_refs.clone(),
747            _marker: self._marker,
748        }
749    }
750}
751
752impl<T: 'static> InstancePre<T> {
753    /// Creates a new `InstancePre` which type-checks the `items` provided and
754    /// on success is ready to instantiate a new instance.
755    ///
756    /// # Unsafety
757    ///
758    /// This method is unsafe as the `T` of the `InstancePre<T>` is not
759    /// guaranteed to be the same as the `T` within the `Store`, the caller must
760    /// verify that.
761    pub(crate) unsafe fn new(module: &Module, items: Vec<Definition>) -> Result<InstancePre<T>> {
762        typecheck(module, &items, |cx, ty, item| cx.definition(ty, &item.ty()))?;
763
764        let mut func_refs = vec![];
765        let mut host_funcs = 0;
766        for item in &items {
767            match item {
768                Definition::Extern(_, _) => {}
769                Definition::HostFunc(f) => {
770                    host_funcs += 1;
771                    if f.func_ref().wasm_call.is_none() {
772                        // `f` needs its `VMFuncRef::wasm_call` patched with a
773                        // Wasm-to-native trampoline.
774                        debug_assert!(matches!(f.host_ctx(), crate::HostContext::Array(_)));
775                        func_refs.push(VMFuncRef {
776                            wasm_call: module
777                                .wasm_to_array_trampoline(f.sig_index())
778                                .map(|f| f.into()),
779                            ..*f.func_ref()
780                        });
781                    }
782                }
783            }
784        }
785
786        Ok(InstancePre {
787            module: module.clone(),
788            items: items.into(),
789            host_funcs,
790            func_refs: func_refs.into(),
791            _marker: core::marker::PhantomData,
792        })
793    }
794
795    /// Returns a reference to the module that this [`InstancePre`] will be
796    /// instantiating.
797    pub fn module(&self) -> &Module {
798        &self.module
799    }
800
801    /// Instantiates this instance, creating a new instance within the provided
802    /// `store`.
803    ///
804    /// This function will run the actual process of instantiation to
805    /// completion. This will use all of the previously-closed-over items as
806    /// imports to instantiate the module that this was originally created with.
807    ///
808    /// For more information about instantiation see [`Instance::new`].
809    ///
810    /// # Panics
811    ///
812    /// Panics if any import closed over by this [`InstancePre`] isn't owned by
813    /// `store`, or if `store` has async support enabled. Additionally this
814    /// function will panic if the `store` provided comes from a different
815    /// [`Engine`] than the [`InstancePre`] originally came from.
816    pub fn instantiate(&self, mut store: impl AsContextMut<Data = T>) -> Result<Instance> {
817        let mut store = store.as_context_mut();
818        let imports = pre_instantiate_raw(
819            &mut store.0,
820            &self.module,
821            &self.items,
822            self.host_funcs,
823            &self.func_refs,
824        )?;
825
826        // This unsafety should be handled by the type-checking performed by the
827        // constructor of `InstancePre` to assert that all the imports we're passing
828        // in match the module we're instantiating.
829        unsafe { Instance::new_started(&mut store, &self.module, imports.as_ref()) }
830    }
831
832    /// Creates a new instance, running the start function asynchronously
833    /// instead of inline.
834    ///
835    /// For more information about asynchronous instantiation see the
836    /// documentation on [`Instance::new_async`].
837    ///
838    /// # Panics
839    ///
840    /// Panics if any import closed over by this [`InstancePre`] isn't owned by
841    /// `store`, or if `store` does not have async support enabled.
842    #[cfg(feature = "async")]
843    pub async fn instantiate_async(
844        &self,
845        mut store: impl AsContextMut<Data: Send>,
846    ) -> Result<Instance> {
847        let mut store = store.as_context_mut();
848        let imports = pre_instantiate_raw(
849            &mut store.0,
850            &self.module,
851            &self.items,
852            self.host_funcs,
853            &self.func_refs,
854        )?;
855
856        // This unsafety should be handled by the type-checking performed by the
857        // constructor of `InstancePre` to assert that all the imports we're passing
858        // in match the module we're instantiating.
859        unsafe { Instance::new_started_async(&mut store, &self.module, imports.as_ref()).await }
860    }
861}
862
863/// Helper function shared between
864/// `InstancePre::{instantiate,instantiate_async}`
865///
866/// This is an out-of-line function to avoid the generic on `InstancePre` and
867/// get this compiled into the `wasmtime` crate to avoid having it monomorphized
868/// elsewhere.
869fn pre_instantiate_raw(
870    store: &mut StoreOpaque,
871    module: &Module,
872    items: &Arc<[Definition]>,
873    host_funcs: usize,
874    func_refs: &Arc<[VMFuncRef]>,
875) -> Result<OwnedImports> {
876    // Register this module and use it to fill out any funcref wasm_call holes
877    // we can. For more comments on this see `typecheck_externs`.
878    store.modules_mut().register_module(module);
879    let (funcrefs, modules) = store.func_refs_and_modules();
880    funcrefs.fill(modules);
881
882    if host_funcs > 0 {
883        // Any linker-defined function of the `Definition::HostFunc` variant
884        // will insert a function into the store automatically as part of
885        // instantiation, so reserve space here to make insertion more efficient
886        // as it won't have to realloc during the instantiation.
887        funcrefs.reserve_storage(host_funcs);
888
889        // The usage of `to_extern_store_rooted` requires that the items are
890        // rooted via another means, which happens here by cloning the list of
891        // items into the store once. This avoids cloning each individual item
892        // below.
893        funcrefs.push_instance_pre_definitions(items.clone());
894        funcrefs.push_instance_pre_func_refs(func_refs.clone());
895    }
896
897    let mut func_refs = func_refs.iter().map(|f| NonNull::from(f));
898    let mut imports = OwnedImports::new(module);
899    for import in items.iter() {
900        if !import.comes_from_same_store(store) {
901            bail!("cross-`Store` instantiation is not currently supported");
902        }
903        // This unsafety should be encapsulated in the constructor of
904        // `InstancePre` where the `T` of the original item should match the
905        // `T` of the store. Additionally the rooting necessary has happened
906        // above.
907        let item = match import {
908            Definition::Extern(e, _) => e.clone(),
909            Definition::HostFunc(func) => unsafe {
910                func.to_func_store_rooted(
911                    store,
912                    if func.func_ref().wasm_call.is_none() {
913                        Some(func_refs.next().unwrap())
914                    } else {
915                        None
916                    },
917                )
918                .into()
919            },
920        };
921        imports.push(&item, store);
922    }
923
924    Ok(imports)
925}
926
927fn typecheck<I>(
928    module: &Module,
929    import_args: &[I],
930    check: impl Fn(&matching::MatchCx<'_>, &EntityType, &I) -> Result<()>,
931) -> Result<()> {
932    let env_module = module.compiled_module().module();
933    let expected_len = env_module.imports().count();
934    let actual_len = import_args.len();
935    if expected_len != actual_len {
936        bail!("expected {expected_len} imports, found {actual_len}");
937    }
938    let cx = matching::MatchCx::new(module.engine());
939    for ((name, field, expected_ty), actual) in env_module.imports().zip(import_args) {
940        debug_assert!(expected_ty.is_canonicalized_for_runtime_usage());
941        check(&cx, &expected_ty, actual)
942            .with_context(|| format!("incompatible import type for `{name}::{field}`"))?;
943    }
944    Ok(())
945}