wasmtime/runtime/component/
instance.rs

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