wasmtime/runtime/component/instance.rs
1use crate::component::func::HostFunc;
2use crate::component::matching::InstanceType;
3use crate::component::{
4 types::ComponentItem, Component, ComponentExportIndex, ComponentNamedList, Func, Lift, Lower,
5 ResourceType, TypedFunc,
6};
7use crate::instance::OwnedImports;
8use crate::linker::DefinitionType;
9use crate::prelude::*;
10use crate::runtime::vm::component::{ComponentInstance, OwnedComponentInstance};
11use crate::runtime::vm::{CompiledModuleId, VMFuncRef};
12use crate::store::{StoreOpaque, Stored};
13use crate::{AsContext, AsContextMut, Engine, Module, StoreContextMut};
14use alloc::sync::Arc;
15use core::marker;
16use core::ptr::NonNull;
17use wasmtime_environ::{component::*, EngineOrModuleTypeIndex};
18use wasmtime_environ::{EntityIndex, EntityType, Global, PrimaryMap, WasmValType};
19
20/// An instantiated component.
21///
22/// This type represents an instantiated [`Component`](super::Component).
23/// Instances have exports which can be accessed through functions such as
24/// [`Instance::get_func`] or [`Instance::get_export`]. Instances are owned by a
25/// [`Store`](crate::Store) and all methods require a handle to the store.
26///
27/// Component instances are created through
28/// [`Linker::instantiate`](super::Linker::instantiate) and its family of
29/// methods.
30///
31/// This type is similar to the core wasm version
32/// [`wasmtime::Instance`](crate::Instance) except that it represents an
33/// instantiated component instead of an instantiated module.
34#[derive(Copy, Clone)]
35pub struct Instance(pub(crate) Stored<Option<Box<InstanceData>>>);
36
37pub(crate) struct InstanceData {
38 instances: PrimaryMap<RuntimeInstanceIndex, crate::Instance>,
39
40 // NB: in the future if necessary it would be possible to avoid storing an
41 // entire `Component` here and instead storing only information such as:
42 //
43 // * Some reference to `Arc<ComponentTypes>`
44 // * Necessary references to closed-over modules which are exported from the
45 // component itself.
46 //
47 // Otherwise the full guts of this component should only ever be used during
48 // the instantiation of this instance, meaning that after instantiation much
49 // of the component can be thrown away (theoretically).
50 component: Component,
51
52 state: OwnedComponentInstance,
53
54 /// Arguments that this instance used to be instantiated.
55 ///
56 /// Strong references are stored to these arguments since pointers are saved
57 /// into the structures such as functions within the
58 /// `OwnedComponentInstance` but it's our job to keep them alive.
59 ///
60 /// One purpose of this storage is to enable embedders to drop a `Linker`,
61 /// for example, after a component is instantiated. In that situation if the
62 /// arguments weren't held here then they might be dropped, and structures
63 /// such as `.lowering()` which point back into the original function would
64 /// become stale and use-after-free conditions when used. By preserving the
65 /// entire list here though we're guaranteed that nothing is lost for the
66 /// duration of the lifetime of this instance.
67 imports: Arc<PrimaryMap<RuntimeImportIndex, RuntimeImport>>,
68}
69
70impl Instance {
71 /// Looks up an exported function by name within this [`Instance`].
72 ///
73 /// The `store` argument provided must be the store that this instance
74 /// lives within and the `name` argument is the lookup key by which to find
75 /// the exported function. If the function is found then `Some` is returned
76 /// and otherwise `None` is returned.
77 ///
78 /// The `name` here can be a string such as `&str` or it can be a
79 /// [`ComponentExportIndex`] which is loaded prior from a [`Component`].
80 ///
81 /// # Panics
82 ///
83 /// Panics if `store` does not own this instance.
84 ///
85 /// # Examples
86 ///
87 /// Looking up a function which is exported from the root of a component:
88 ///
89 /// ```
90 /// use wasmtime::{Engine, Store};
91 /// use wasmtime::component::{Component, Linker};
92 ///
93 /// # fn main() -> wasmtime::Result<()> {
94 /// let engine = Engine::default();
95 /// let component = Component::new(
96 /// &engine,
97 /// r#"
98 /// (component
99 /// (core module $m
100 /// (func (export "f"))
101 /// )
102 /// (core instance $i (instantiate $m))
103 /// (func (export "f")
104 /// (canon lift (core func $i "f")))
105 /// )
106 /// "#,
107 /// )?;
108 ///
109 /// // Look up the function by name
110 /// let mut store = Store::new(&engine, ());
111 /// let instance = Linker::new(&engine).instantiate(&mut store, &component)?;
112 /// let func = instance.get_func(&mut store, "f").unwrap();
113 ///
114 /// // The function can also be looked up by an index via a precomputed index.
115 /// let export = component.get_export_index(None, "f").unwrap();
116 /// let func = instance.get_func(&mut store, &export).unwrap();
117 /// # Ok(())
118 /// # }
119 /// ```
120 ///
121 /// Looking up a function which is exported from a nested instance:
122 ///
123 /// ```
124 /// use wasmtime::{Engine, Store};
125 /// use wasmtime::component::{Component, Linker};
126 ///
127 /// # fn main() -> wasmtime::Result<()> {
128 /// let engine = Engine::default();
129 /// let component = Component::new(
130 /// &engine,
131 /// r#"
132 /// (component
133 /// (core module $m
134 /// (func (export "f"))
135 /// )
136 /// (core instance $i (instantiate $m))
137 /// (func $f
138 /// (canon lift (core func $i "f")))
139 ///
140 /// (instance $i
141 /// (export "f" (func $f)))
142 /// (export "i" (instance $i))
143 /// )
144 /// "#,
145 /// )?;
146 ///
147 /// // First look up the exported instance, then use that to lookup the
148 /// // exported function.
149 /// let instance_index = component.get_export_index(None, "i").unwrap();
150 /// let func_index = component.get_export_index(Some(&instance_index), "f").unwrap();
151 ///
152 /// // Then use `func_index` at runtime.
153 /// let mut store = Store::new(&engine, ());
154 /// let instance = Linker::new(&engine).instantiate(&mut store, &component)?;
155 /// let func = instance.get_func(&mut store, &func_index).unwrap();
156 ///
157 /// // Alternatively the `instance` can be used directly in conjunction with
158 /// // the `get_export_index` method.
159 /// let instance_index = instance.get_export_index(&mut store, None, "i").unwrap();
160 /// let func_index = instance.get_export_index(&mut store, Some(&instance_index), "f").unwrap();
161 /// let func = instance.get_func(&mut store, &func_index).unwrap();
162 /// # Ok(())
163 /// # }
164 /// ```
165 pub fn get_func(
166 &self,
167 mut store: impl AsContextMut,
168 name: impl InstanceExportLookup,
169 ) -> Option<Func> {
170 let store = store.as_context_mut().0;
171 let data = store[self.0].take().unwrap();
172 let ret = name.lookup(&data.component).and_then(|index| {
173 match &data.component.env_component().export_items[index] {
174 Export::LiftedFunction { ty, func, options } => Some(Func::from_lifted_func(
175 store, self, &data, *ty, func, options,
176 )),
177 _ => None,
178 }
179 });
180 store[self.0] = Some(data);
181 ret
182 }
183
184 /// Looks up an exported [`Func`] value by name and with its type.
185 ///
186 /// This function is a convenience wrapper over [`Instance::get_func`] and
187 /// [`Func::typed`]. For more information see the linked documentation.
188 ///
189 /// Returns an error if `name` isn't a function export or if the export's
190 /// type did not match `Params` or `Results`
191 ///
192 /// # Panics
193 ///
194 /// Panics if `store` does not own this instance.
195 pub fn get_typed_func<Params, Results>(
196 &self,
197 mut store: impl AsContextMut,
198 name: impl InstanceExportLookup,
199 ) -> Result<TypedFunc<Params, Results>>
200 where
201 Params: ComponentNamedList + Lower,
202 Results: ComponentNamedList + Lift,
203 {
204 let f = self
205 .get_func(store.as_context_mut(), name)
206 .ok_or_else(|| anyhow!("failed to find function export"))?;
207 Ok(f.typed::<Params, Results>(store)
208 .with_context(|| format!("failed to convert function to given type"))?)
209 }
210
211 /// Looks up an exported module by name within this [`Instance`].
212 ///
213 /// The `store` argument provided must be the store that this instance
214 /// lives within and the `name` argument is the lookup key by which to find
215 /// the exported module. If the module is found then `Some` is returned
216 /// and otherwise `None` is returned.
217 ///
218 /// The `name` here can be a string such as `&str` or it can be a
219 /// [`ComponentExportIndex`] which is loaded prior from a [`Component`].
220 ///
221 /// For some examples see [`Instance::get_func`] for loading values from a
222 /// component.
223 ///
224 /// # Panics
225 ///
226 /// Panics if `store` does not own this instance.
227 pub fn get_module(
228 &self,
229 mut store: impl AsContextMut,
230 name: impl InstanceExportLookup,
231 ) -> Option<Module> {
232 let store = store.as_context_mut().0;
233 let (data, export, _) = self.lookup_export(store, name)?;
234 match export {
235 Export::ModuleStatic { index, .. } => {
236 Some(data.component.static_module(*index).clone())
237 }
238 Export::ModuleImport { import, .. } => match &data.imports[*import] {
239 RuntimeImport::Module(m) => Some(m.clone()),
240 _ => unreachable!(),
241 },
242 _ => None,
243 }
244 }
245
246 /// Looks up an exported resource type by name within this [`Instance`].
247 ///
248 /// The `store` argument provided must be the store that this instance
249 /// lives within and the `name` argument is the lookup key by which to find
250 /// the exported resource. If the resource is found then `Some` is returned
251 /// and otherwise `None` is returned.
252 ///
253 /// The `name` here can be a string such as `&str` or it can be a
254 /// [`ComponentExportIndex`] which is loaded prior from a [`Component`].
255 ///
256 /// For some examples see [`Instance::get_func`] for loading values from a
257 /// component.
258 ///
259 /// # Panics
260 ///
261 /// Panics if `store` does not own this instance.
262 pub fn get_resource(
263 &self,
264 mut store: impl AsContextMut,
265 name: impl InstanceExportLookup,
266 ) -> Option<ResourceType> {
267 let store = store.as_context_mut().0;
268 let (data, export, _) = self.lookup_export(store, name)?;
269 match export {
270 Export::Type(TypeDef::Resource(id)) => Some(data.ty().resource_type(*id)),
271 Export::Type(_)
272 | Export::LiftedFunction { .. }
273 | Export::ModuleStatic { .. }
274 | Export::ModuleImport { .. }
275 | Export::Instance { .. } => None,
276 }
277 }
278
279 /// A methods similar to [`Component::get_export`] except for this
280 /// instance.
281 ///
282 /// This method will lookup the `name` provided within the `instance`
283 /// provided and return a [`ComponentItem`] describing the export,
284 /// and [`ComponentExportIndex`] which can be passed other `get_*`
285 /// functions like [`Instance::get_func`].
286 ///
287 /// The [`ComponentItem`] is more expensive to compute than the
288 /// [`ComponentExportIndex`]. If you are not consuming the
289 /// [`ComponentItem`], use [`Instance::get_export_index`] instead.
290 ///
291 /// # Panics
292 ///
293 /// Panics if `store` does not own this instance.
294 pub fn get_export(
295 &self,
296 mut store: impl AsContextMut,
297 instance: Option<&ComponentExportIndex>,
298 name: &str,
299 ) -> Option<(ComponentItem, ComponentExportIndex)> {
300 self._get_export(store.as_context_mut().0, instance, name)
301 }
302
303 fn _get_export(
304 &self,
305 store: &StoreOpaque,
306 instance: Option<&ComponentExportIndex>,
307 name: &str,
308 ) -> Option<(ComponentItem, ComponentExportIndex)> {
309 let data = store[self.0].as_ref().unwrap();
310 let index = data.component.lookup_export_index(instance, name)?;
311 let item = ComponentItem::from_export(
312 &store.engine(),
313 &data.component.env_component().export_items[index],
314 &data.ty(),
315 );
316 Some((
317 item,
318 ComponentExportIndex {
319 id: data.component_id(),
320 index,
321 },
322 ))
323 }
324
325 /// A methods similar to [`Component::get_export_index`] except for this
326 /// instance.
327 ///
328 /// This method will lookup the `name` provided within the `instance`
329 /// provided and return a [`ComponentExportIndex`] which can be passed
330 /// other `get_*` functions like [`Instance::get_func`].
331 ///
332 /// If you need the [`ComponentItem`] corresponding to this export, use
333 /// the [`Instance::get_export`] instead.
334 ///
335 /// # Panics
336 ///
337 /// Panics if `store` does not own this instance.
338 pub fn get_export_index(
339 &self,
340 mut store: impl AsContextMut,
341 instance: Option<&ComponentExportIndex>,
342 name: &str,
343 ) -> Option<ComponentExportIndex> {
344 let data = store.as_context_mut().0[self.0].as_ref().unwrap();
345 let index = data.component.lookup_export_index(instance, name)?;
346 Some(ComponentExportIndex {
347 id: data.component_id(),
348 index,
349 })
350 }
351
352 fn lookup_export<'a>(
353 &self,
354 store: &'a StoreOpaque,
355 name: impl InstanceExportLookup,
356 ) -> Option<(&'a InstanceData, &'a Export, ExportIndex)> {
357 let data = store[self.0].as_ref().unwrap();
358 let index = name.lookup(&data.component)?;
359 Some((
360 data,
361 &data.component.env_component().export_items[index],
362 index,
363 ))
364 }
365
366 #[doc(hidden)]
367 pub fn instance_pre<T>(&self, store: &impl AsContext<Data = T>) -> InstancePre<T> {
368 // This indexing operation asserts the Store owns the Instance.
369 // Therefore, the InstancePre<T> must match the Store<T>.
370 let data = store.as_context().0[self.0].as_ref().unwrap();
371 unsafe {
372 InstancePre::new_unchecked(
373 data.component.clone(),
374 data.imports.clone(),
375 data.instance().resource_types().clone(),
376 )
377 }
378 }
379}
380
381/// Trait used to lookup the export of a component instance.
382///
383/// This trait is used as an implementation detail of [`Instance::get_func`]
384/// and related `get_*` methods. Notable implementors of this trait are:
385///
386/// * `str`
387/// * `String`
388/// * [`ComponentExportIndex`]
389///
390/// Note that this is intended to be a `wasmtime`-sealed trait so it shouldn't
391/// need to be implemented externally.
392pub trait InstanceExportLookup {
393 #[doc(hidden)]
394 fn lookup(&self, component: &Component) -> Option<ExportIndex>;
395}
396
397impl<T> InstanceExportLookup for &T
398where
399 T: InstanceExportLookup + ?Sized,
400{
401 fn lookup(&self, component: &Component) -> Option<ExportIndex> {
402 T::lookup(self, component)
403 }
404}
405
406impl InstanceExportLookup for str {
407 fn lookup(&self, component: &Component) -> Option<ExportIndex> {
408 component
409 .env_component()
410 .exports
411 .get(self, &NameMapNoIntern)
412 .copied()
413 }
414}
415
416impl InstanceExportLookup for String {
417 fn lookup(&self, component: &Component) -> Option<ExportIndex> {
418 str::lookup(self, component)
419 }
420}
421
422impl InstanceData {
423 pub fn lookup_def(&self, store: &mut StoreOpaque, def: &CoreDef) -> crate::runtime::vm::Export {
424 match def {
425 CoreDef::Export(e) => self.lookup_export(store, e),
426 CoreDef::Trampoline(idx) => {
427 crate::runtime::vm::Export::Function(crate::runtime::vm::ExportFunction {
428 func_ref: self.state.trampoline_func_ref(*idx),
429 })
430 }
431 CoreDef::InstanceFlags(idx) => {
432 crate::runtime::vm::Export::Global(crate::runtime::vm::ExportGlobal {
433 definition: self.state.instance_flags(*idx).as_raw(),
434 vmctx: None,
435 global: Global {
436 wasm_ty: WasmValType::I32,
437 mutability: true,
438 },
439 })
440 }
441 }
442 }
443
444 pub fn lookup_export<T>(
445 &self,
446 store: &mut StoreOpaque,
447 item: &CoreExport<T>,
448 ) -> crate::runtime::vm::Export
449 where
450 T: Copy + Into<EntityIndex>,
451 {
452 let instance = &self.instances[item.instance];
453 let id = instance.id(store);
454 let instance = store.instance_mut(id);
455 let idx = match &item.item {
456 ExportItem::Index(idx) => (*idx).into(),
457
458 // FIXME: ideally at runtime we don't actually do any name lookups
459 // here. This will only happen when the host supplies an imported
460 // module so while the structure can't be known at compile time we
461 // do know at `InstancePre` time, for example, what all the host
462 // imports are. In theory we should be able to, as part of
463 // `InstancePre` construction, perform all name=>index mappings
464 // during that phase so the actual instantiation of an `InstancePre`
465 // skips all string lookups. This should probably only be
466 // investigated if this becomes a performance issue though.
467 ExportItem::Name(name) => instance.module().exports[name],
468 };
469 instance.get_export_by_index(idx)
470 }
471
472 #[inline]
473 pub fn instance(&self) -> &ComponentInstance {
474 &self.state
475 }
476
477 #[inline]
478 pub fn instance_ptr(&self) -> *mut ComponentInstance {
479 self.state.instance_ptr()
480 }
481
482 #[inline]
483 pub fn component_types(&self) -> &Arc<ComponentTypes> {
484 self.component.types()
485 }
486
487 #[inline]
488 pub fn component_id(&self) -> CompiledModuleId {
489 self.component.id()
490 }
491
492 #[inline]
493 pub fn ty(&self) -> InstanceType<'_> {
494 InstanceType::new(self.instance())
495 }
496
497 // NB: This method is only intended to be called during the instantiation
498 // process because the `Arc::get_mut` here is fallible and won't generally
499 // succeed once the instance has been handed to the embedder. Before that
500 // though it should be guaranteed that the single owning reference currently
501 // lives within the `ComponentInstance` that's being built.
502 fn resource_types_mut(&mut self) -> &mut ImportedResources {
503 Arc::get_mut(self.state.resource_types_mut()).unwrap()
504 }
505}
506
507struct Instantiator<'a> {
508 component: &'a Component,
509 data: InstanceData,
510 core_imports: OwnedImports,
511 imports: &'a PrimaryMap<RuntimeImportIndex, RuntimeImport>,
512}
513
514pub(crate) enum RuntimeImport {
515 Func(Arc<HostFunc>),
516 Module(Module),
517 Resource {
518 ty: ResourceType,
519
520 // A strong reference to the host function that represents the
521 // destructor for this resource. At this time all resources here are
522 // host-defined resources. Note that this is itself never read because
523 // the funcref below points to it.
524 //
525 // Also note that the `Arc` here is used to support the same host
526 // function being used across multiple instances simultaneously. Or
527 // otherwise this makes `InstancePre::instantiate` possible to create
528 // separate instances all sharing the same host function.
529 _dtor: Arc<crate::func::HostFunc>,
530
531 // A raw function which is filled out (including `wasm_call`) which
532 // points to the internals of the `_dtor` field. This is read and
533 // possibly executed by wasm.
534 dtor_funcref: VMFuncRef,
535 },
536}
537
538pub type ImportedResources = PrimaryMap<ResourceIndex, ResourceType>;
539
540impl<'a> Instantiator<'a> {
541 fn new(
542 component: &'a Component,
543 store: &mut StoreOpaque,
544 imports: &'a Arc<PrimaryMap<RuntimeImportIndex, RuntimeImport>>,
545 ) -> Instantiator<'a> {
546 let env_component = component.env_component();
547 store.modules_mut().register_component(component);
548 let imported_resources: ImportedResources =
549 PrimaryMap::with_capacity(env_component.imported_resources.len());
550 Instantiator {
551 component,
552 imports,
553 core_imports: OwnedImports::empty(),
554 data: InstanceData {
555 instances: PrimaryMap::with_capacity(env_component.num_runtime_instances as usize),
556 component: component.clone(),
557 state: OwnedComponentInstance::new(
558 component.runtime_info(),
559 Arc::new(imported_resources),
560 store.traitobj(),
561 ),
562 imports: imports.clone(),
563 },
564 }
565 }
566
567 fn run<T>(&mut self, store: &mut StoreContextMut<'_, T>) -> Result<()> {
568 let env_component = self.component.env_component();
569
570 // Before all initializers are processed configure all destructors for
571 // host-defined resources. No initializer will correspond to these and
572 // it's required to happen before they're needed, so execute this first.
573 for (idx, import) in env_component.imported_resources.iter() {
574 let (ty, func_ref) = match &self.imports[*import] {
575 RuntimeImport::Resource {
576 ty, dtor_funcref, ..
577 } => (*ty, NonNull::from(dtor_funcref)),
578 _ => unreachable!(),
579 };
580 let i = self.data.resource_types_mut().push(ty);
581 assert_eq!(i, idx);
582 self.data.state.set_resource_destructor(idx, Some(func_ref));
583 }
584
585 // Next configure all `VMFuncRef`s for trampolines that this component
586 // will require. These functions won't actually get used until their
587 // associated state has been initialized through the global initializers
588 // below, but the funcrefs can all be configured here.
589 for (idx, sig) in env_component.trampolines.iter() {
590 let ptrs = self.component.trampoline_ptrs(idx);
591 let signature = match self.component.signatures().shared_type(*sig) {
592 Some(s) => s,
593 None => panic!("found unregistered signature: {sig:?}"),
594 };
595
596 self.data
597 .state
598 .set_trampoline(idx, ptrs.wasm_call, ptrs.array_call, signature);
599 }
600
601 for initializer in env_component.initializers.iter() {
602 match initializer {
603 GlobalInitializer::InstantiateModule(m) => {
604 let module;
605 let imports = match m {
606 // Since upvars are statically know we know that the
607 // `args` list is already in the right order.
608 InstantiateModule::Static(idx, args) => {
609 module = self.component.static_module(*idx);
610 self.build_imports(store.0, module, args.iter())
611 }
612
613 // With imports, unlike upvars, we need to do runtime
614 // lookups with strings to determine the order of the
615 // imports since it's whatever the actual module
616 // requires.
617 //
618 // FIXME: see the note in `ExportItem::Name` handling
619 // above for how we ideally shouldn't do string lookup
620 // here.
621 InstantiateModule::Import(idx, args) => {
622 module = match &self.imports[*idx] {
623 RuntimeImport::Module(m) => m,
624 _ => unreachable!(),
625 };
626 let args = module
627 .imports()
628 .map(|import| &args[import.module()][import.name()]);
629 self.build_imports(store.0, module, args)
630 }
631 };
632
633 // Note that the unsafety here should be ok because the
634 // validity of the component means that type-checks have
635 // already been performed. This means that the unsafety due
636 // to imports having the wrong type should not happen here.
637 //
638 // Also note we are calling new_started_impl because we have
639 // already checked for asyncness and are running on a fiber
640 // if required.
641
642 let i = unsafe {
643 crate::Instance::new_started_impl(store, module, imports.as_ref())?
644 };
645 self.data.instances.push(i);
646 }
647
648 GlobalInitializer::LowerImport { import, index } => {
649 let func = match &self.imports[*import] {
650 RuntimeImport::Func(func) => func,
651 _ => unreachable!(),
652 };
653 self.data.state.set_lowering(*index, func.lowering());
654 }
655
656 GlobalInitializer::ExtractTable(table) => self.extract_table(store.0, table),
657
658 GlobalInitializer::ExtractMemory(mem) => self.extract_memory(store.0, mem),
659
660 GlobalInitializer::ExtractRealloc(realloc) => {
661 self.extract_realloc(store.0, realloc)
662 }
663
664 GlobalInitializer::ExtractCallback(callback) => {
665 self.extract_callback(store.0, callback)
666 }
667
668 GlobalInitializer::ExtractPostReturn(post_return) => {
669 self.extract_post_return(store.0, post_return)
670 }
671
672 GlobalInitializer::Resource(r) => self.resource(store.0, r),
673 }
674 }
675 Ok(())
676 }
677
678 fn resource(&mut self, store: &mut StoreOpaque, resource: &Resource) {
679 let dtor = resource
680 .dtor
681 .as_ref()
682 .map(|dtor| self.data.lookup_def(store, dtor));
683 let dtor = dtor.map(|export| match export {
684 crate::runtime::vm::Export::Function(f) => f.func_ref,
685 _ => unreachable!(),
686 });
687 let index = self
688 .component
689 .env_component()
690 .resource_index(resource.index);
691 self.data.state.set_resource_destructor(index, dtor);
692 let ty = ResourceType::guest(store.id(), &self.data.state, resource.index);
693 let i = self.data.resource_types_mut().push(ty);
694 debug_assert_eq!(i, index);
695 }
696
697 fn extract_memory(&mut self, store: &mut StoreOpaque, memory: &ExtractMemory) {
698 let mem = match self.data.lookup_export(store, &memory.export) {
699 crate::runtime::vm::Export::Memory(m) => m,
700 _ => unreachable!(),
701 };
702 self.data
703 .state
704 .set_runtime_memory(memory.index, mem.definition);
705 }
706
707 fn extract_realloc(&mut self, store: &mut StoreOpaque, realloc: &ExtractRealloc) {
708 let func_ref = match self.data.lookup_def(store, &realloc.def) {
709 crate::runtime::vm::Export::Function(f) => f.func_ref,
710 _ => unreachable!(),
711 };
712 self.data.state.set_runtime_realloc(realloc.index, func_ref);
713 }
714
715 fn extract_callback(&mut self, store: &mut StoreOpaque, callback: &ExtractCallback) {
716 let func_ref = match self.data.lookup_def(store, &callback.def) {
717 crate::runtime::vm::Export::Function(f) => f.func_ref,
718 _ => unreachable!(),
719 };
720 self.data
721 .state
722 .set_runtime_callback(callback.index, func_ref);
723 }
724
725 fn extract_post_return(&mut self, store: &mut StoreOpaque, post_return: &ExtractPostReturn) {
726 let func_ref = match self.data.lookup_def(store, &post_return.def) {
727 crate::runtime::vm::Export::Function(f) => f.func_ref,
728 _ => unreachable!(),
729 };
730 self.data
731 .state
732 .set_runtime_post_return(post_return.index, func_ref);
733 }
734
735 fn extract_table(&mut self, store: &mut StoreOpaque, table: &ExtractTable) {
736 let export = match self.data.lookup_export(store, &table.export) {
737 crate::runtime::vm::Export::Table(t) => t,
738 _ => unreachable!(),
739 };
740 self.data
741 .state
742 .set_runtime_table(table.index, export.definition, export.vmctx);
743 }
744
745 fn build_imports<'b>(
746 &mut self,
747 store: &mut StoreOpaque,
748 module: &Module,
749 args: impl Iterator<Item = &'b CoreDef>,
750 ) -> &OwnedImports {
751 self.core_imports.clear();
752 self.core_imports.reserve(module);
753 let mut imports = module.compiled_module().module().imports();
754
755 for arg in args {
756 // The general idea of Wasmtime is that at runtime type-checks for
757 // core wasm instantiations internally within a component are
758 // unnecessary and superfluous. Naturally though mistakes may be
759 // made, so double-check this property of wasmtime in debug mode.
760
761 if cfg!(debug_assertions) {
762 let (imp_module, imp_name, expected) = imports.next().unwrap();
763 self.assert_type_matches(store, module, arg, imp_module, imp_name, expected);
764 }
765
766 // The unsafety here should be ok since the `export` is loaded
767 // directly from an instance which should only give us valid export
768 // items.
769 let export = self.data.lookup_def(store, arg);
770 unsafe {
771 self.core_imports.push_export(&export);
772 }
773 }
774 debug_assert!(imports.next().is_none());
775
776 &self.core_imports
777 }
778
779 fn assert_type_matches(
780 &self,
781 store: &mut StoreOpaque,
782 module: &Module,
783 arg: &CoreDef,
784 imp_module: &str,
785 imp_name: &str,
786 expected: EntityType,
787 ) {
788 let export = self.data.lookup_def(store, arg);
789
790 // If this value is a core wasm function then the type check is inlined
791 // here. This can otherwise fail `Extern::from_wasmtime_export` because
792 // there's no guarantee that there exists a trampoline for `f` so this
793 // can't fall through to the case below
794 if let crate::runtime::vm::Export::Function(f) = &export {
795 let expected = match expected.unwrap_func() {
796 EngineOrModuleTypeIndex::Engine(e) => Some(e),
797 EngineOrModuleTypeIndex::Module(m) => module.signatures().shared_type(m),
798 EngineOrModuleTypeIndex::RecGroup(_) => unreachable!(),
799 };
800 let actual = unsafe { f.func_ref.as_ref().type_index };
801 assert_eq!(
802 expected,
803 Some(actual),
804 "type mismatch for import {imp_module:?} {imp_name:?}!!!\n\n\
805 expected {:#?}\n\n\
806 found {:#?}",
807 expected.and_then(|e| store.engine().signatures().borrow(e)),
808 store.engine().signatures().borrow(actual)
809 );
810 return;
811 }
812
813 let val = unsafe { crate::Extern::from_wasmtime_export(export, store) };
814 let ty = DefinitionType::from(store, &val);
815 crate::types::matching::MatchCx::new(module.engine())
816 .definition(&expected, &ty)
817 .expect("unexpected typecheck failure");
818 }
819}
820
821/// A "pre-instantiated" [`Instance`] which has all of its arguments already
822/// supplied and is ready to instantiate.
823///
824/// This structure represents an efficient form of instantiation where import
825/// type-checking and import lookup has all been resolved by the time that this
826/// type is created. This type is primarily created through the
827/// [`Linker::instantiate_pre`](crate::component::Linker::instantiate_pre)
828/// method.
829pub struct InstancePre<T> {
830 component: Component,
831 imports: Arc<PrimaryMap<RuntimeImportIndex, RuntimeImport>>,
832 resource_types: Arc<PrimaryMap<ResourceIndex, ResourceType>>,
833 _marker: marker::PhantomData<fn() -> T>,
834}
835
836// `InstancePre`'s clone does not require `T: Clone`
837impl<T> Clone for InstancePre<T> {
838 fn clone(&self) -> Self {
839 Self {
840 component: self.component.clone(),
841 imports: self.imports.clone(),
842 resource_types: self.resource_types.clone(),
843 _marker: self._marker,
844 }
845 }
846}
847
848impl<T> InstancePre<T> {
849 /// This function is `unsafe` since there's no guarantee that the
850 /// `RuntimeImport` items provided are guaranteed to work with the `T` of
851 /// the store.
852 ///
853 /// Additionally there is no static guarantee that the `imports` provided
854 /// satisfy the imports of the `component` provided.
855 pub(crate) unsafe fn new_unchecked(
856 component: Component,
857 imports: Arc<PrimaryMap<RuntimeImportIndex, RuntimeImport>>,
858 resource_types: Arc<PrimaryMap<ResourceIndex, ResourceType>>,
859 ) -> InstancePre<T> {
860 InstancePre {
861 component,
862 imports,
863 resource_types,
864 _marker: marker::PhantomData,
865 }
866 }
867
868 /// Returns the underlying component that will be instantiated.
869 pub fn component(&self) -> &Component {
870 &self.component
871 }
872
873 #[doc(hidden)]
874 /// Returns the type at which the underlying component will be
875 /// instantiated. This contains the instantiated type information which
876 /// was determined by the Linker.
877 pub fn instance_type(&self) -> InstanceType<'_> {
878 InstanceType {
879 types: &self.component.types(),
880 resources: &self.resource_types,
881 }
882 }
883
884 /// Returns the underlying engine.
885 pub fn engine(&self) -> &Engine {
886 self.component.engine()
887 }
888
889 /// Performs the instantiation process into the store specified.
890 //
891 // TODO: needs more docs
892 pub fn instantiate(&self, store: impl AsContextMut<Data = T>) -> Result<Instance> {
893 assert!(
894 !store.as_context().async_support(),
895 "must use async instantiation when async support is enabled"
896 );
897 self.instantiate_impl(store)
898 }
899 /// Performs the instantiation process into the store specified.
900 ///
901 /// Exactly like [`Self::instantiate`] except for use on async stores.
902 //
903 // TODO: needs more docs
904 #[cfg(feature = "async")]
905 pub async fn instantiate_async(
906 &self,
907 mut store: impl AsContextMut<Data = T>,
908 ) -> Result<Instance>
909 where
910 T: Send,
911 {
912 let mut store = store.as_context_mut();
913 assert!(
914 store.0.async_support(),
915 "must use sync instantiation when async support is disabled"
916 );
917 store.on_fiber(|store| self.instantiate_impl(store)).await?
918 }
919
920 fn instantiate_impl(&self, mut store: impl AsContextMut<Data = T>) -> Result<Instance> {
921 let mut store = store.as_context_mut();
922 store
923 .engine()
924 .allocator()
925 .increment_component_instance_count()?;
926 let mut instantiator = Instantiator::new(&self.component, store.0, &self.imports);
927 instantiator.run(&mut store).map_err(|e| {
928 store
929 .engine()
930 .allocator()
931 .decrement_component_instance_count();
932 e
933 })?;
934 let data = Box::new(instantiator.data);
935 let instance = Instance(store.0.store_data_mut().insert(Some(data)));
936 store.0.push_component_instance(instance);
937 Ok(instance)
938 }
939}