1 use crate::component::func::HostFunc; 2 use crate::component::matching::InstanceType; 3 use crate::component::store::{ComponentInstanceId, StoreComponentInstanceId}; 4 use crate::component::{ 5 Component, ComponentExportIndex, ComponentNamedList, Func, Lift, Lower, ResourceType, 6 TypedFunc, types::ComponentItem, 7 }; 8 use crate::instance::OwnedImports; 9 use crate::linker::DefinitionType; 10 use crate::prelude::*; 11 use crate::runtime::vm::component::{ 12 CallContexts, ComponentInstance, ResourceTables, TypedResource, TypedResourceIndex, 13 }; 14 use crate::runtime::vm::{self, VMFuncRef}; 15 use crate::store::StoreOpaque; 16 use crate::{AsContext, AsContextMut, Engine, Module, StoreContextMut}; 17 use alloc::sync::Arc; 18 use core::marker; 19 use core::pin::Pin; 20 use core::ptr::NonNull; 21 use wasmtime_environ::{EngineOrModuleTypeIndex, component::*}; 22 use 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)] 40 pub 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. 46 const _: () = { 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 54 impl 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. 472 pub(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. 506 pub(crate) fn lookup_vmexport<T>( 507 store: &mut StoreOpaque, 508 id: ComponentInstanceId, 509 item: &CoreExport<T>, 510 ) -> vm::Export 511 where 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 539 fn 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. 561 pub trait InstanceExportLookup { 562 #[doc(hidden)] 563 fn lookup(&self, component: &Component) -> Option<ExportIndex>; 564 } 565 566 impl<T> InstanceExportLookup for &T 567 where 568 T: InstanceExportLookup + ?Sized, 569 { 570 fn lookup(&self, component: &Component) -> Option<ExportIndex> { 571 T::lookup(self, component) 572 } 573 } 574 575 impl 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 585 impl InstanceExportLookup for String { 586 fn lookup(&self, component: &Component) -> Option<ExportIndex> { 587 str::lookup(self, component) 588 } 589 } 590 591 struct Instantiator<'a> { 592 component: &'a Component, 593 id: ComponentInstanceId, 594 core_imports: OwnedImports, 595 imports: &'a PrimaryMap<RuntimeImportIndex, RuntimeImport>, 596 } 597 598 pub(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 622 pub type ImportedResources = PrimaryMap<ResourceIndex, ResourceType>; 623 624 impl<'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. 966 pub 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` 974 impl<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 985 impl<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 } 1065