1 //! Working with GC `array` objects. 2 3 use crate::runtime::vm::VMGcRef; 4 use crate::store::StoreId; 5 use crate::vm::{VMArrayRef, VMGcHeader}; 6 use crate::{AnyRef, FieldType}; 7 use crate::{ 8 ArrayType, AsContext, AsContextMut, EqRef, GcHeapOutOfMemory, GcRefImpl, GcRootIndex, HeapType, 9 ManuallyRooted, RefType, Rooted, Val, ValRaw, ValType, WasmTy, 10 prelude::*, 11 store::{AutoAssertNoGc, StoreContextMut, StoreOpaque}, 12 }; 13 use core::mem::{self, MaybeUninit}; 14 use wasmtime_environ::{GcArrayLayout, GcLayout, VMGcKind, VMSharedTypeIndex}; 15 16 /// An allocator for a particular Wasm GC array type. 17 /// 18 /// Every `ArrayRefPre` is associated with a particular [`Store`][crate::Store] 19 /// and a particular [`ArrayType`][crate::ArrayType]. 20 /// 21 /// Reusing an allocator across many allocations amortizes some per-type runtime 22 /// overheads inside Wasmtime. An `ArrayRefPre` is to `ArrayRef`s as an 23 /// `InstancePre` is to `Instance`s. 24 /// 25 /// # Example 26 /// 27 /// ``` 28 /// use wasmtime::*; 29 /// 30 /// # fn foo() -> Result<()> { 31 /// let mut config = Config::new(); 32 /// config.wasm_function_references(true); 33 /// config.wasm_gc(true); 34 /// 35 /// let engine = Engine::new(&config)?; 36 /// let mut store = Store::new(&engine, ()); 37 /// 38 /// // Define an array type. 39 /// let array_ty = ArrayType::new( 40 /// store.engine(), 41 /// FieldType::new(Mutability::Var, ValType::I32.into()), 42 /// ); 43 /// 44 /// // Create an allocator for the array type. 45 /// let allocator = ArrayRefPre::new(&mut store, array_ty); 46 /// 47 /// { 48 /// let mut scope = RootScope::new(&mut store); 49 /// 50 /// // Allocate a bunch of instances of our array type using the same 51 /// // allocator! This is faster than creating a new allocator for each 52 /// // instance we want to allocate. 53 /// for i in 0..10 { 54 /// let len = 42; 55 /// let elem = Val::I32(36); 56 /// ArrayRef::new(&mut scope, &allocator, &elem, len)?; 57 /// } 58 /// } 59 /// # Ok(()) 60 /// # } 61 /// # let _ = foo(); 62 /// ``` 63 pub struct ArrayRefPre { 64 store_id: StoreId, 65 ty: ArrayType, 66 } 67 68 impl ArrayRefPre { 69 /// Create a new `ArrayRefPre` that is associated with the given store 70 /// and type. 71 pub fn new(mut store: impl AsContextMut, ty: ArrayType) -> Self { 72 Self::_new(store.as_context_mut().0, ty) 73 } 74 75 pub(crate) fn _new(store: &mut StoreOpaque, ty: ArrayType) -> Self { 76 store.insert_gc_host_alloc_type(ty.registered_type().clone()); 77 let store_id = store.id(); 78 ArrayRefPre { store_id, ty } 79 } 80 81 pub(crate) fn layout(&self) -> &GcArrayLayout { 82 self.ty 83 .registered_type() 84 .layout() 85 .expect("array types have a layout") 86 .unwrap_array() 87 } 88 89 pub(crate) fn type_index(&self) -> VMSharedTypeIndex { 90 self.ty.registered_type().index() 91 } 92 } 93 94 /// A reference to a GC-managed `array` instance. 95 /// 96 /// WebAssembly `array`s are a sequence of elements of some homogeneous 97 /// type. The elements length is determined at allocation time — two instances 98 /// of the same array type may have different lengths — but, once allocated, an 99 /// array's length can never be resized. An array's elements are mutable or 100 /// constant, depending on the array's type. This determines whether any array 101 /// element can be assigned a new value or not. Each element is either an 102 /// unpacked [`Val`][crate::Val] or a packed 8-/16-bit integer. Array elements 103 /// are dynamically accessed via indexing; out-of-bounds accesses result in 104 /// traps. 105 /// 106 /// Like all WebAssembly references, these are opaque and unforgeable to Wasm: 107 /// they cannot be faked and Wasm cannot, for example, cast the integer 108 /// `0x12345678` into a reference, pretend it is a valid `arrayref`, and trick 109 /// the host into dereferencing it and segfaulting or worse. 110 /// 111 /// Note that you can also use `Rooted<ArrayRef>` and `ManuallyRooted<ArrayRef>` 112 /// as a type parameter with [`Func::typed`][crate::Func::typed]- and 113 /// [`Func::wrap`][crate::Func::wrap]-style APIs. 114 /// 115 /// # Example 116 /// 117 /// ``` 118 /// use wasmtime::*; 119 /// 120 /// # fn foo() -> Result<()> { 121 /// let mut config = Config::new(); 122 /// config.wasm_function_references(true); 123 /// config.wasm_gc(true); 124 /// 125 /// let engine = Engine::new(&config)?; 126 /// let mut store = Store::new(&engine, ()); 127 /// 128 /// // Define the type for an array of `i32`s. 129 /// let array_ty = ArrayType::new( 130 /// store.engine(), 131 /// FieldType::new(Mutability::Var, ValType::I32.into()), 132 /// ); 133 /// 134 /// // Create an allocator for the array type. 135 /// let allocator = ArrayRefPre::new(&mut store, array_ty); 136 /// 137 /// { 138 /// let mut scope = RootScope::new(&mut store); 139 /// 140 /// // Allocate an instance of the array type. 141 /// let len = 36; 142 /// let elem = Val::I32(42); 143 /// let my_array = match ArrayRef::new(&mut scope, &allocator, &elem, len) { 144 /// Ok(s) => s, 145 /// Err(e) => match e.downcast::<GcHeapOutOfMemory<()>>() { 146 /// // If the heap is out of memory, then do a GC to free up some 147 /// // space and try again. 148 /// Ok(oom) => { 149 /// // Do a GC! Note: in an async context, you'd want to do 150 /// // `scope.as_context_mut().gc_async().await`. 151 /// scope.as_context_mut().gc(Some(&oom)); 152 /// 153 /// // Try again. If the GC heap is still out of memory, then we 154 /// // weren't able to free up resources for this allocation, so 155 /// // propagate the error. 156 /// ArrayRef::new(&mut scope, &allocator, &elem, len)? 157 /// } 158 /// // Propagate any other kind of error. 159 /// Err(e) => return Err(e), 160 /// } 161 /// }; 162 /// 163 /// // That instance's elements should have the initial value. 164 /// for i in 0..len { 165 /// let val = my_array.get(&mut scope, i)?.unwrap_i32(); 166 /// assert_eq!(val, 42); 167 /// } 168 /// 169 /// // We can set an element to a new value because the type was defined with 170 /// // mutable elements (as opposed to const). 171 /// my_array.set(&mut scope, 3, Val::I32(1234))?; 172 /// let new_val = my_array.get(&mut scope, 3)?.unwrap_i32(); 173 /// assert_eq!(new_val, 1234); 174 /// } 175 /// # Ok(()) 176 /// # } 177 /// # foo().unwrap(); 178 /// ``` 179 #[derive(Debug)] 180 #[repr(transparent)] 181 pub struct ArrayRef { 182 pub(super) inner: GcRootIndex, 183 } 184 185 unsafe impl GcRefImpl for ArrayRef { 186 fn transmute_ref(index: &GcRootIndex) -> &Self { 187 // Safety: `ArrayRef` is a newtype of a `GcRootIndex`. 188 let me: &Self = unsafe { mem::transmute(index) }; 189 190 // Assert we really are just a newtype of a `GcRootIndex`. 191 assert!(matches!( 192 me, 193 Self { 194 inner: GcRootIndex { .. }, 195 } 196 )); 197 198 me 199 } 200 } 201 202 impl Rooted<ArrayRef> { 203 /// Upcast this `arrayref` into an `anyref`. 204 #[inline] 205 pub fn to_anyref(self) -> Rooted<AnyRef> { 206 self.unchecked_cast() 207 } 208 209 /// Upcast this `arrayref` into an `eqref`. 210 #[inline] 211 pub fn to_eqref(self) -> Rooted<EqRef> { 212 self.unchecked_cast() 213 } 214 } 215 216 impl ManuallyRooted<ArrayRef> { 217 /// Upcast this `arrayref` into an `anyref`. 218 #[inline] 219 pub fn to_anyref(self) -> ManuallyRooted<AnyRef> { 220 self.unchecked_cast() 221 } 222 223 /// Upcast this `arrayref` into an `eqref`. 224 #[inline] 225 pub fn to_eqref(self) -> ManuallyRooted<EqRef> { 226 self.unchecked_cast() 227 } 228 } 229 230 /// An iterator for elements in `ArrayRef::new[_async]. 231 /// 232 /// NB: We can't use `iter::repeat(elem).take(len)` because that doesn't 233 /// implement `ExactSizeIterator`. 234 #[derive(Clone)] 235 struct RepeatN<'a>(&'a Val, u32); 236 237 impl<'a> Iterator for RepeatN<'a> { 238 type Item = &'a Val; 239 240 fn next(&mut self) -> Option<Self::Item> { 241 if self.1 == 0 { 242 None 243 } else { 244 self.1 -= 1; 245 Some(self.0) 246 } 247 } 248 249 fn size_hint(&self) -> (usize, Option<usize>) { 250 let len = self.len(); 251 (len, Some(len)) 252 } 253 } 254 255 impl ExactSizeIterator for RepeatN<'_> { 256 fn len(&self) -> usize { 257 usize::try_from(self.1).unwrap() 258 } 259 } 260 261 impl ArrayRef { 262 /// Allocate a new `array` of the given length, with every element 263 /// initialized to `elem`. 264 /// 265 /// For example, `ArrayRef::new(ctx, pre, &Val::I64(9), 3)` allocates the 266 /// array `[9, 9, 9]`. 267 /// 268 /// This is similar to the `array.new` instruction. 269 /// 270 /// # Automatic Garbage Collection 271 /// 272 /// If the GC heap is at capacity, and there isn't room for allocating this 273 /// new array, then this method will automatically trigger a synchronous 274 /// collection in an attempt to free up space in the GC heap. 275 /// 276 /// # Errors 277 /// 278 /// If the given `elem` value's type does not match the `allocator`'s array 279 /// type's element type, an error is returned. 280 /// 281 /// If the allocation cannot be satisfied because the GC heap is currently 282 /// out of memory, then a [`GcHeapOutOfMemory<()>`][crate::GcHeapOutOfMemory] 283 /// error is returned. The allocation might succeed on a second attempt if 284 /// you drop some rooted GC references and try again. 285 /// 286 /// # Panics 287 /// 288 /// Panics if the `store` is configured for async; use 289 /// [`ArrayRef::new_async`][crate::ArrayRef::new_async] to perform 290 /// asynchronous allocation instead. 291 /// 292 /// Panics if either the allocator or the `elem` value is not associated 293 /// with the given store. 294 pub fn new( 295 mut store: impl AsContextMut, 296 allocator: &ArrayRefPre, 297 elem: &Val, 298 len: u32, 299 ) -> Result<Rooted<ArrayRef>> { 300 Self::_new(store.as_context_mut().0, allocator, elem, len) 301 } 302 303 pub(crate) fn _new( 304 store: &mut StoreOpaque, 305 allocator: &ArrayRefPre, 306 elem: &Val, 307 len: u32, 308 ) -> Result<Rooted<ArrayRef>> { 309 store.retry_after_gc((), |store, ()| { 310 Self::new_from_iter(store, allocator, RepeatN(elem, len)) 311 }) 312 } 313 314 /// Asynchronously allocate a new `array` of the given length, with every 315 /// element initialized to `elem`. 316 /// 317 /// For example, `ArrayRef::new(ctx, pre, &Val::I64(9), 3)` allocates the 318 /// array `[9, 9, 9]`. 319 /// 320 /// This is similar to the `array.new` instruction. 321 /// 322 /// # Automatic Garbage Collection 323 /// 324 /// If the GC heap is at capacity, and there isn't room for allocating this 325 /// new array, then this method will automatically trigger a asynchronous 326 /// collection in an attempt to free up space in the GC heap. 327 /// 328 /// # Errors 329 /// 330 /// If the given `elem` value's type does not match the `allocator`'s array 331 /// type's element type, an error is returned. 332 /// 333 /// If the allocation cannot be satisfied because the GC heap is currently 334 /// out of memory, then a [`GcHeapOutOfMemory<()>`][crate::GcHeapOutOfMemory] 335 /// error is returned. The allocation might succeed on a second attempt if 336 /// you drop some rooted GC references and try again. 337 /// 338 /// # Panics 339 /// 340 /// Panics if your engine is not configured for async; use 341 /// [`ArrayRef::new_async`][crate::ArrayRef::new_async] to perform 342 /// synchronous allocation instead. 343 /// 344 /// Panics if either the allocator or the `elem` value is not associated 345 /// with the given store. 346 #[cfg(feature = "async")] 347 pub async fn new_async( 348 mut store: impl AsContextMut, 349 allocator: &ArrayRefPre, 350 elem: &Val, 351 len: u32, 352 ) -> Result<Rooted<ArrayRef>> { 353 Self::_new_async(store.as_context_mut().0, allocator, elem, len).await 354 } 355 356 pub(crate) async fn _new_async( 357 store: &mut StoreOpaque, 358 allocator: &ArrayRefPre, 359 elem: &Val, 360 len: u32, 361 ) -> Result<Rooted<ArrayRef>> { 362 store 363 .retry_after_gc_async((), |store, ()| { 364 Self::new_from_iter(store, allocator, RepeatN(elem, len)) 365 }) 366 .await 367 } 368 369 /// Allocate a new array of the given elements. 370 /// 371 /// Does not attempt a GC on OOM; leaves that to callers. 372 fn new_from_iter<'a>( 373 store: &mut StoreOpaque, 374 allocator: &ArrayRefPre, 375 elems: impl Clone + ExactSizeIterator<Item = &'a Val>, 376 ) -> Result<Rooted<ArrayRef>> { 377 assert_eq!( 378 store.id(), 379 allocator.store_id, 380 "attempted to use a `ArrayRefPre` with the wrong store" 381 ); 382 383 // Type check the elements against the element type. 384 for elem in elems.clone() { 385 elem.ensure_matches_ty(store, allocator.ty.element_type().unpack()) 386 .context("element type mismatch")?; 387 } 388 389 let len = u32::try_from(elems.len()).unwrap(); 390 391 // Allocate the array and write each field value into the appropriate 392 // offset. 393 let arrayref = store 394 .require_gc_store_mut()? 395 .alloc_uninit_array(allocator.type_index(), len, allocator.layout()) 396 .context("unrecoverable error when allocating new `arrayref`")? 397 .map_err(|n| GcHeapOutOfMemory::new((), n))?; 398 399 // From this point on, if we get any errors, then the array is not 400 // fully initialized, so we need to eagerly deallocate it before the 401 // next GC where the collector might try to interpret one of the 402 // uninitialized fields as a GC reference. 403 let mut store = AutoAssertNoGc::new(store); 404 match (|| { 405 let elem_ty = allocator.ty.element_type(); 406 for (i, elem) in elems.enumerate() { 407 let i = u32::try_from(i).unwrap(); 408 debug_assert!(i < len); 409 arrayref.initialize_elem(&mut store, allocator.layout(), &elem_ty, i, *elem)?; 410 } 411 Ok(()) 412 })() { 413 Ok(()) => Ok(Rooted::new(&mut store, arrayref.into())), 414 Err(e) => { 415 store.require_gc_store_mut()?.dealloc_uninit_array(arrayref); 416 Err(e) 417 } 418 } 419 } 420 421 /// Synchronously allocate a new `array` containing the given elements. 422 /// 423 /// For example, `ArrayRef::new_fixed(ctx, pre, &[Val::I64(4), Val::I64(5), 424 /// Val::I64(6)])` allocates the array `[4, 5, 6]`. 425 /// 426 /// This is similar to the `array.new_fixed` instruction. 427 /// 428 /// # Automatic Garbage Collection 429 /// 430 /// If the GC heap is at capacity, and there isn't room for allocating this 431 /// new array, then this method will automatically trigger a synchronous 432 /// collection in an attempt to free up space in the GC heap. 433 /// 434 /// # Errors 435 /// 436 /// If any of the `elems` values' type does not match the `allocator`'s 437 /// array type's element type, an error is returned. 438 /// 439 /// If the allocation cannot be satisfied because the GC heap is currently 440 /// out of memory, then a [`GcHeapOutOfMemory<()>`][crate::GcHeapOutOfMemory] 441 /// error is returned. The allocation might succeed on a second attempt if 442 /// you drop some rooted GC references and try again. 443 /// 444 /// # Panics 445 /// 446 /// Panics if the `store` is configured for async; use 447 /// [`ArrayRef::new_fixed_async`][crate::ArrayRef::new_fixed_async] to 448 /// perform asynchronous allocation instead. 449 /// 450 /// Panics if the allocator or any of the `elems` values are not associated 451 /// with the given store. 452 pub fn new_fixed( 453 mut store: impl AsContextMut, 454 allocator: &ArrayRefPre, 455 elems: &[Val], 456 ) -> Result<Rooted<ArrayRef>> { 457 Self::_new_fixed(store.as_context_mut().0, allocator, elems) 458 } 459 460 pub(crate) fn _new_fixed( 461 store: &mut StoreOpaque, 462 allocator: &ArrayRefPre, 463 elems: &[Val], 464 ) -> Result<Rooted<ArrayRef>> { 465 store.retry_after_gc((), |store, ()| { 466 Self::new_from_iter(store, allocator, elems.iter()) 467 }) 468 } 469 470 /// Asynchronously allocate a new `array` containing the given elements. 471 /// 472 /// For example, `ArrayRef::new_fixed_async(ctx, pre, &[Val::I64(4), 473 /// Val::I64(5), Val::I64(6)])` allocates the array `[4, 5, 6]`. 474 /// 475 /// This is similar to the `array.new_fixed` instruction. 476 /// 477 /// If your engine is not configured for async, use 478 /// [`ArrayRef::new_fixed`][crate::ArrayRef::new_fixed] to perform 479 /// synchronous allocation. 480 /// 481 /// # Automatic Garbage Collection 482 /// 483 /// If the GC heap is at capacity, and there isn't room for allocating this 484 /// new array, then this method will automatically trigger a synchronous 485 /// collection in an attempt to free up space in the GC heap. 486 /// 487 /// # Errors 488 /// 489 /// If any of the `elems` values' type does not match the `allocator`'s 490 /// array type's element type, an error is returned. 491 /// 492 /// If the allocation cannot be satisfied because the GC heap is currently 493 /// out of memory, then a [`GcHeapOutOfMemory<()>`][crate::GcHeapOutOfMemory] 494 /// error is returned. The allocation might succeed on a second attempt if 495 /// you drop some rooted GC references and try again. 496 /// 497 /// # Panics 498 /// 499 /// Panics if the `store` is not configured for async; use 500 /// [`ArrayRef::new_fixed`][crate::ArrayRef::new_fixed] to perform 501 /// synchronous allocation instead. 502 /// 503 /// Panics if the allocator or any of the `elems` values are not associated 504 /// with the given store. 505 #[cfg(feature = "async")] 506 pub async fn new_fixed_async( 507 mut store: impl AsContextMut, 508 allocator: &ArrayRefPre, 509 elems: &[Val], 510 ) -> Result<Rooted<ArrayRef>> { 511 Self::_new_fixed_async(store.as_context_mut().0, allocator, elems).await 512 } 513 514 pub(crate) async fn _new_fixed_async( 515 store: &mut StoreOpaque, 516 allocator: &ArrayRefPre, 517 elems: &[Val], 518 ) -> Result<Rooted<ArrayRef>> { 519 store 520 .retry_after_gc_async((), |store, ()| { 521 Self::new_from_iter(store, allocator, elems.iter()) 522 }) 523 .await 524 } 525 526 #[inline] 527 pub(crate) fn comes_from_same_store(&self, store: &StoreOpaque) -> bool { 528 self.inner.comes_from_same_store(store) 529 } 530 531 /// Get this `arrayref`'s type. 532 /// 533 /// # Errors 534 /// 535 /// Return an error if this reference has been unrooted. 536 /// 537 /// # Panics 538 /// 539 /// Panics if this reference is associated with a different store. 540 pub fn ty(&self, store: impl AsContext) -> Result<ArrayType> { 541 self._ty(store.as_context().0) 542 } 543 544 pub(crate) fn _ty(&self, store: &StoreOpaque) -> Result<ArrayType> { 545 assert!(self.comes_from_same_store(store)); 546 let index = self.type_index(store)?; 547 Ok(ArrayType::from_shared_type_index(store.engine(), index)) 548 } 549 550 /// Does this `arrayref` match the given type? 551 /// 552 /// That is, is this array's type a subtype of the given type? 553 /// 554 /// # Errors 555 /// 556 /// Return an error if this reference has been unrooted. 557 /// 558 /// # Panics 559 /// 560 /// Panics if this reference is associated with a different store or if the 561 /// type is not associated with the store's engine. 562 pub fn matches_ty(&self, store: impl AsContext, ty: &ArrayType) -> Result<bool> { 563 self._matches_ty(store.as_context().0, ty) 564 } 565 566 pub(crate) fn _matches_ty(&self, store: &StoreOpaque, ty: &ArrayType) -> Result<bool> { 567 assert!(self.comes_from_same_store(store)); 568 Ok(self._ty(store)?.matches(ty)) 569 } 570 571 pub(crate) fn ensure_matches_ty(&self, store: &StoreOpaque, ty: &ArrayType) -> Result<()> { 572 if !self.comes_from_same_store(store) { 573 bail!("function used with wrong store"); 574 } 575 if self._matches_ty(store, ty)? { 576 Ok(()) 577 } else { 578 let actual_ty = self._ty(store)?; 579 bail!("type mismatch: expected `(ref {ty})`, found `(ref {actual_ty})`") 580 } 581 } 582 583 /// Get the length of this array. 584 /// 585 /// # Errors 586 /// 587 /// Return an error if this reference has been unrooted. 588 /// 589 /// # Panics 590 /// 591 /// Panics if this reference is associated with a different store. 592 pub fn len(&self, store: impl AsContext) -> Result<u32> { 593 self._len(store.as_context().0) 594 } 595 596 pub(crate) fn _len(&self, store: &StoreOpaque) -> Result<u32> { 597 assert!(self.comes_from_same_store(store)); 598 let gc_ref = self.inner.try_gc_ref(store)?; 599 debug_assert!({ 600 let header = store.require_gc_store()?.header(gc_ref); 601 header.kind().matches(VMGcKind::ArrayRef) 602 }); 603 let arrayref = gc_ref.as_arrayref_unchecked(); 604 Ok(arrayref.len(store)) 605 } 606 607 /// Get the values of this array's elements. 608 /// 609 /// Note that `i8` and `i16` element values are zero-extended into 610 /// `Val::I32(_)`s. 611 /// 612 /// # Errors 613 /// 614 /// Return an error if this reference has been unrooted. 615 /// 616 /// # Panics 617 /// 618 /// Panics if this reference is associated with a different store. 619 pub fn elems<'a, T: 'static>( 620 &'a self, 621 store: impl Into<StoreContextMut<'a, T>>, 622 ) -> Result<impl ExactSizeIterator<Item = Val> + 'a> { 623 self._elems(store.into().0) 624 } 625 626 pub(crate) fn _elems<'a>( 627 &'a self, 628 store: &'a mut StoreOpaque, 629 ) -> Result<impl ExactSizeIterator<Item = Val> + 'a> { 630 assert!(self.comes_from_same_store(store)); 631 let store = AutoAssertNoGc::new(store); 632 633 let gc_ref = self.inner.try_gc_ref(&store)?; 634 let header = store.require_gc_store()?.header(gc_ref); 635 debug_assert!(header.kind().matches(VMGcKind::ArrayRef)); 636 637 let len = self._len(&store)?; 638 639 return Ok(Elems { 640 arrayref: self, 641 store, 642 index: 0, 643 len, 644 }); 645 646 struct Elems<'a, 'b> { 647 arrayref: &'a ArrayRef, 648 store: AutoAssertNoGc<'b>, 649 index: u32, 650 len: u32, 651 } 652 653 impl Iterator for Elems<'_, '_> { 654 type Item = Val; 655 656 #[inline] 657 fn next(&mut self) -> Option<Self::Item> { 658 let i = self.index; 659 debug_assert!(i <= self.len); 660 if i >= self.len { 661 return None; 662 } 663 self.index += 1; 664 Some(self.arrayref._get(&mut self.store, i).unwrap()) 665 } 666 667 #[inline] 668 fn size_hint(&self) -> (usize, Option<usize>) { 669 let len = self.len - self.index; 670 let len = usize::try_from(len).unwrap(); 671 (len, Some(len)) 672 } 673 } 674 675 impl ExactSizeIterator for Elems<'_, '_> { 676 #[inline] 677 fn len(&self) -> usize { 678 let len = self.len - self.index; 679 usize::try_from(len).unwrap() 680 } 681 } 682 } 683 684 fn header<'a>(&self, store: &'a AutoAssertNoGc<'_>) -> Result<&'a VMGcHeader> { 685 assert!(self.comes_from_same_store(&store)); 686 let gc_ref = self.inner.try_gc_ref(store)?; 687 Ok(store.require_gc_store()?.header(gc_ref)) 688 } 689 690 fn arrayref<'a>(&self, store: &'a AutoAssertNoGc<'_>) -> Result<&'a VMArrayRef> { 691 assert!(self.comes_from_same_store(&store)); 692 let gc_ref = self.inner.try_gc_ref(store)?; 693 debug_assert!(self.header(store)?.kind().matches(VMGcKind::ArrayRef)); 694 Ok(gc_ref.as_arrayref_unchecked()) 695 } 696 697 pub(crate) fn layout(&self, store: &AutoAssertNoGc<'_>) -> Result<GcArrayLayout> { 698 assert!(self.comes_from_same_store(&store)); 699 let type_index = self.type_index(store)?; 700 let layout = store 701 .engine() 702 .signatures() 703 .layout(type_index) 704 .expect("array types should have GC layouts"); 705 match layout { 706 GcLayout::Array(a) => Ok(a), 707 GcLayout::Struct(_) => unreachable!(), 708 } 709 } 710 711 fn field_ty(&self, store: &StoreOpaque) -> Result<FieldType> { 712 let ty = self._ty(store)?; 713 Ok(ty.field_type()) 714 } 715 716 /// Get this array's `index`th element. 717 /// 718 /// Note that `i8` and `i16` field values are zero-extended into 719 /// `Val::I32(_)`s. 720 /// 721 /// # Errors 722 /// 723 /// Returns an `Err(_)` if the index is out of bounds or this reference has 724 /// been unrooted. 725 /// 726 /// # Panics 727 /// 728 /// Panics if this reference is associated with a different store. 729 pub fn get(&self, mut store: impl AsContextMut, index: u32) -> Result<Val> { 730 let mut store = AutoAssertNoGc::new(store.as_context_mut().0); 731 self._get(&mut store, index) 732 } 733 734 pub(crate) fn _get(&self, store: &mut AutoAssertNoGc<'_>, index: u32) -> Result<Val> { 735 assert!( 736 self.comes_from_same_store(store), 737 "attempted to use an array with the wrong store", 738 ); 739 let arrayref = self.arrayref(store)?.unchecked_copy(); 740 let field_ty = self.field_ty(store)?; 741 let layout = self.layout(store)?; 742 let len = arrayref.len(store); 743 ensure!( 744 index < len, 745 "index out of bounds: the length is {len} but the index is {index}" 746 ); 747 Ok(arrayref.read_elem(store, &layout, field_ty.element_type(), index)) 748 } 749 750 /// Set this array's `index`th element. 751 /// 752 /// # Errors 753 /// 754 /// Returns an error in the following scenarios: 755 /// 756 /// * When given a value of the wrong type, such as trying to write an `f32` 757 /// value into an array of `i64` elements. 758 /// 759 /// * When the array elements are not mutable. 760 /// 761 /// * When `index` is not within the range `0..self.len(ctx)`. 762 /// 763 /// * When `value` is a GC reference that has since been unrooted. 764 /// 765 /// # Panics 766 /// 767 /// Panics if either this reference or the given `value` is associated with 768 /// a different store. 769 pub fn set(&self, mut store: impl AsContextMut, index: u32, value: Val) -> Result<()> { 770 self._set(store.as_context_mut().0, index, value) 771 } 772 773 pub(crate) fn _set(&self, store: &mut StoreOpaque, index: u32, value: Val) -> Result<()> { 774 assert!( 775 self.comes_from_same_store(store), 776 "attempted to use an array with the wrong store", 777 ); 778 assert!( 779 value.comes_from_same_store(store), 780 "attempted to use a value with the wrong store", 781 ); 782 783 let mut store = AutoAssertNoGc::new(store); 784 785 let field_ty = self.field_ty(&store)?; 786 ensure!( 787 field_ty.mutability().is_var(), 788 "cannot set element {index}: array elements are not mutable" 789 ); 790 791 value 792 .ensure_matches_ty(&store, &field_ty.element_type().unpack()) 793 .with_context(|| format!("cannot set element {index}: type mismatch"))?; 794 795 let layout = self.layout(&store)?; 796 let arrayref = self.arrayref(&store)?.unchecked_copy(); 797 798 let len = arrayref.len(&store); 799 ensure!( 800 index < len, 801 "index out of bounds: the length is {len} but the index is {index}" 802 ); 803 804 arrayref.write_elem(&mut store, &layout, field_ty.element_type(), index, value) 805 } 806 807 pub(crate) fn type_index(&self, store: &StoreOpaque) -> Result<VMSharedTypeIndex> { 808 let gc_ref = self.inner.try_gc_ref(store)?; 809 let header = store.require_gc_store()?.header(gc_ref); 810 debug_assert!(header.kind().matches(VMGcKind::ArrayRef)); 811 Ok(header.ty().expect("arrayrefs should have concrete types")) 812 } 813 814 /// Create a new `Rooted<ArrayRef>` from the given GC reference. 815 /// 816 /// `gc_ref` should point to a valid `arrayref` and should belong to the 817 /// store's GC heap. Failure to uphold these invariants is memory safe but 818 /// will lead to general incorrectness such as panics or wrong results. 819 pub(crate) fn from_cloned_gc_ref( 820 store: &mut AutoAssertNoGc<'_>, 821 gc_ref: VMGcRef, 822 ) -> Rooted<Self> { 823 debug_assert!(gc_ref.is_arrayref(&*store.unwrap_gc_store().gc_heap)); 824 Rooted::new(store, gc_ref) 825 } 826 } 827 828 unsafe impl WasmTy for Rooted<ArrayRef> { 829 #[inline] 830 fn valtype() -> ValType { 831 ValType::Ref(RefType::new(false, HeapType::Array)) 832 } 833 834 #[inline] 835 fn compatible_with_store(&self, store: &StoreOpaque) -> bool { 836 self.comes_from_same_store(store) 837 } 838 839 #[inline] 840 fn dynamic_concrete_type_check( 841 &self, 842 store: &StoreOpaque, 843 _nullable: bool, 844 ty: &HeapType, 845 ) -> Result<()> { 846 match ty { 847 HeapType::Any | HeapType::Eq | HeapType::Array => Ok(()), 848 HeapType::ConcreteArray(ty) => self.ensure_matches_ty(store, ty), 849 850 HeapType::Extern 851 | HeapType::NoExtern 852 | HeapType::Func 853 | HeapType::ConcreteFunc(_) 854 | HeapType::NoFunc 855 | HeapType::I31 856 | HeapType::Struct 857 | HeapType::ConcreteStruct(_) 858 | HeapType::Cont 859 | HeapType::NoCont 860 | HeapType::ConcreteCont(_) 861 | HeapType::Exn 862 | HeapType::NoExn 863 | HeapType::ConcreteExn(_) 864 | HeapType::None => bail!( 865 "type mismatch: expected `(ref {ty})`, got `(ref {})`", 866 self._ty(store)?, 867 ), 868 } 869 } 870 871 fn store(self, store: &mut AutoAssertNoGc<'_>, ptr: &mut MaybeUninit<ValRaw>) -> Result<()> { 872 self.wasm_ty_store(store, ptr, ValRaw::anyref) 873 } 874 875 unsafe fn load(store: &mut AutoAssertNoGc<'_>, ptr: &ValRaw) -> Self { 876 Self::wasm_ty_load(store, ptr.get_anyref(), ArrayRef::from_cloned_gc_ref) 877 } 878 } 879 880 unsafe impl WasmTy for Option<Rooted<ArrayRef>> { 881 #[inline] 882 fn valtype() -> ValType { 883 ValType::ARRAYREF 884 } 885 886 #[inline] 887 fn compatible_with_store(&self, store: &StoreOpaque) -> bool { 888 self.map_or(true, |x| x.comes_from_same_store(store)) 889 } 890 891 #[inline] 892 fn dynamic_concrete_type_check( 893 &self, 894 store: &StoreOpaque, 895 nullable: bool, 896 ty: &HeapType, 897 ) -> Result<()> { 898 match self { 899 Some(s) => Rooted::<ArrayRef>::dynamic_concrete_type_check(s, store, nullable, ty), 900 None => { 901 ensure!( 902 nullable, 903 "expected a non-null reference, but found a null reference" 904 ); 905 Ok(()) 906 } 907 } 908 } 909 910 #[inline] 911 fn is_vmgcref_and_points_to_object(&self) -> bool { 912 self.is_some() 913 } 914 915 fn store(self, store: &mut AutoAssertNoGc<'_>, ptr: &mut MaybeUninit<ValRaw>) -> Result<()> { 916 <Rooted<ArrayRef>>::wasm_ty_option_store(self, store, ptr, ValRaw::anyref) 917 } 918 919 unsafe fn load(store: &mut AutoAssertNoGc<'_>, ptr: &ValRaw) -> Self { 920 <Rooted<ArrayRef>>::wasm_ty_option_load( 921 store, 922 ptr.get_anyref(), 923 ArrayRef::from_cloned_gc_ref, 924 ) 925 } 926 } 927 928 unsafe impl WasmTy for ManuallyRooted<ArrayRef> { 929 #[inline] 930 fn valtype() -> ValType { 931 ValType::Ref(RefType::new(false, HeapType::Array)) 932 } 933 934 #[inline] 935 fn compatible_with_store(&self, store: &StoreOpaque) -> bool { 936 self.comes_from_same_store(store) 937 } 938 939 #[inline] 940 fn dynamic_concrete_type_check( 941 &self, 942 store: &StoreOpaque, 943 _: bool, 944 ty: &HeapType, 945 ) -> Result<()> { 946 match ty { 947 HeapType::Any | HeapType::Eq | HeapType::Array => Ok(()), 948 HeapType::ConcreteArray(ty) => self.ensure_matches_ty(store, ty), 949 950 HeapType::Extern 951 | HeapType::NoExtern 952 | HeapType::Func 953 | HeapType::ConcreteFunc(_) 954 | HeapType::NoFunc 955 | HeapType::I31 956 | HeapType::Struct 957 | HeapType::ConcreteStruct(_) 958 | HeapType::Cont 959 | HeapType::NoCont 960 | HeapType::ConcreteCont(_) 961 | HeapType::Exn 962 | HeapType::NoExn 963 | HeapType::ConcreteExn(_) 964 | HeapType::None => bail!( 965 "type mismatch: expected `(ref {ty})`, got `(ref {})`", 966 self._ty(store)?, 967 ), 968 } 969 } 970 971 fn store(self, store: &mut AutoAssertNoGc<'_>, ptr: &mut MaybeUninit<ValRaw>) -> Result<()> { 972 self.wasm_ty_store(store, ptr, ValRaw::anyref) 973 } 974 975 unsafe fn load(store: &mut AutoAssertNoGc<'_>, ptr: &ValRaw) -> Self { 976 Self::wasm_ty_load(store, ptr.get_anyref(), ArrayRef::from_cloned_gc_ref) 977 } 978 } 979 980 unsafe impl WasmTy for Option<ManuallyRooted<ArrayRef>> { 981 #[inline] 982 fn valtype() -> ValType { 983 ValType::ARRAYREF 984 } 985 986 #[inline] 987 fn compatible_with_store(&self, store: &StoreOpaque) -> bool { 988 self.as_ref() 989 .map_or(true, |x| x.comes_from_same_store(store)) 990 } 991 992 #[inline] 993 fn dynamic_concrete_type_check( 994 &self, 995 store: &StoreOpaque, 996 nullable: bool, 997 ty: &HeapType, 998 ) -> Result<()> { 999 match self { 1000 Some(s) => { 1001 ManuallyRooted::<ArrayRef>::dynamic_concrete_type_check(s, store, nullable, ty) 1002 } 1003 None => { 1004 ensure!( 1005 nullable, 1006 "expected a non-null reference, but found a null reference" 1007 ); 1008 Ok(()) 1009 } 1010 } 1011 } 1012 1013 #[inline] 1014 fn is_vmgcref_and_points_to_object(&self) -> bool { 1015 self.is_some() 1016 } 1017 1018 fn store(self, store: &mut AutoAssertNoGc<'_>, ptr: &mut MaybeUninit<ValRaw>) -> Result<()> { 1019 <ManuallyRooted<ArrayRef>>::wasm_ty_option_store(self, store, ptr, ValRaw::anyref) 1020 } 1021 1022 unsafe fn load(store: &mut AutoAssertNoGc<'_>, ptr: &ValRaw) -> Self { 1023 <ManuallyRooted<ArrayRef>>::wasm_ty_option_load( 1024 store, 1025 ptr.get_anyref(), 1026 ArrayRef::from_cloned_gc_ref, 1027 ) 1028 } 1029 } 1030