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}