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#[derive(Copy, Clone, Debug)]
39#[repr(transparent)]
40pub struct Instance {
41 id: StoreComponentInstanceId,
42}
43
44const _: () = {
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 pub(crate) fn from_wasmtime(store: &StoreOpaque, id: ComponentInstanceId) -> Instance {
57 Instance {
58 id: StoreComponentInstanceId::new(store.id(), id),
59 }
60 }
61
62 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 let index = name.lookup(component)?;
167
168 match &component.env_component().export_items[index] {
170 Export::LiftedFunction { .. } => {}
171 _ => return None,
172 }
173
174 Some(Func::from_lifted_func(*self, index))
176 }
177
178 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 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 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 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 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 pub fn instance_pre<T>(&self, store: impl AsContext<Data = T>) -> InstancePre<T> {
361 let data = self.id().get(store.as_context().0);
364
365 unsafe { data.instance_pre() }
370 }
371
372 pub(crate) fn id(&self) -> StoreComponentInstanceId {
373 self.id
374 }
375
376 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 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 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 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
470pub(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 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 vm::Export::Function(unsafe { crate::Func::from_vm_func_ref(store.id(), funcref) })
500 }
501 }
502}
503
504pub(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 ExportItem::Name(name) => instance.env_module().exports[name],
533 };
534 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
550pub 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 _dtor: Arc<crate::func::HostFunc>,
614
615 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 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 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 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 InstantiateModule::Static(idx, args) => {
723 module = self.component.static_module(*idx);
724 self.build_imports(store.0, module, args.iter())
725 }
726
727 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 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 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 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 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 fn instance<'b>(&self, store: &'b StoreOpaque) -> &'b ComponentInstance {
937 store.store_data().component_instance(self.id)
938 }
939
940 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 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
958pub 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
973impl<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 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 pub fn component(&self) -> &Component {
1007 &self.component
1008 }
1009
1010 #[doc(hidden)]
1011 pub fn instance_type(&self) -> InstanceType<'_> {
1015 InstanceType {
1016 types: &self.component.types(),
1017 resources: &self.resource_types,
1018 }
1019 }
1020
1021 pub fn engine(&self) -> &Engine {
1023 self.component.engine()
1024 }
1025
1026 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 #[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}