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