add Component Model async ABI tests

Cargo.toml

@@ -156,6 +156,7 @@ members = [
   "crates/bench-api",
   "crates/c-api/artifact",
   "crates/environ/fuzz",
+  "crates/misc/component-async-tests",
   "crates/test-programs",
   "crates/wasi-preview1-component-adapter",
   "crates/wasi-preview1-component-adapter/verify",
@@ -304,6 +305,7 @@ test-programs-artifacts = { path = 'crates/test-programs/artifacts' }
 wasmtime-test-util = { path = "crates/test-util" }
 byte-array-literals = { path = "crates/wasi-preview1-component-adapter/byte-array-literals" }
 pulley-interpreter-fuzz = { path = 'pulley/fuzz' }
+component-async-tests = { path = "crates/misc/component-async-tests" }
 
 # Bytecode Alliance maintained dependencies:
 # ---------------------------

ci/miri-provenance-test.sh

@@ -8,17 +8,18 @@
 set -ex
 
 compile() {
-  cargo run --no-default-features --features compile,pulley,wat,gc-drc,component-model \
+  cargo run --no-default-features --features compile,pulley,wat,gc-drc,component-model,component-model-async \
     compile --target pulley64 $1 \
     -o ${1%.wat}.cwasm \
     -O memory-reservation=$((1 << 20)) \
     -O memory-guard-size=0 \
     -O signals-based-traps=n \
-    -W function-references
+    -W function-references,component-model-async,component-model-async-stackful,component-model-async-builtins,component-model-error-context
 }
 
 compile ./tests/all/pulley_provenance_test.wat
 compile ./tests/all/pulley_provenance_test_component.wat
+compile ./tests/all/pulley_provenance_test_async_component.wat
 
 MIRIFLAGS="$MIRIFLAGS -Zmiri-disable-isolation -Zmiri-permissive-provenance" \
   cargo miri test --test all -- \

crates/misc/component-async-tests/Cargo.toml

@@ -0,0 +1,38 @@
+[package]
+name = "component-async-tests"
+authors = ["The Wasmtime Project Developers"]
+license = "Apache-2.0 WITH LLVM-exception"
+version = "0.0.0"
+edition.workspace = true
+rust-version.workspace = true
+publish = false
+
+[lints]
+workspace = true
+
+[dependencies]
+anyhow = { workspace = true }
+futures = { workspace = true }
+env_logger = { workspace = true }
+tempfile = { workspace = true }
+tokio = { workspace = true, features = [
+  "fs",
+  "process",
+  "macros",
+  "rt-multi-thread",
+  "time",
+] }
+wasm-compose = { workspace = true }
+wasmparser = { workspace = true }
+wasmtime = { workspace = true, features = [
+  "default",
+  "pulley",
+  "cranelift",
+  "component-model-async",
+] }
+wasmtime-wasi = { workspace = true }
+
+[dev-dependencies]
+test-programs-artifacts = { workspace = true }
+bytes = { workspace = true }
+once_cell = { version = "1.12.0" }

crates/misc/component-async-tests/src/borrowing_host.rs

@@ -0,0 +1,42 @@
+use anyhow::Result;
+use wasmtime::component::Resource;
+use wasmtime_wasi::p2::IoView;
+
+use super::Ctx;
+
+pub mod bindings {
+    wasmtime::component::bindgen!({
+        path: "wit",
+        world: "borrowing-host",
+        trappable_imports: true,
+        concurrent_imports: true,
+        concurrent_exports: true,
+        async: {
+            only_imports: []
+        },
+        with: {
+            "local:local/borrowing-types/x": super::MyX,
+        }
+    });
+}
+
+/// Used as the borrowing type (`local:local/borrowing-types/x`)
+pub struct MyX;
+
+impl bindings::local::local::borrowing_types::HostX for &mut Ctx {
+    fn new(&mut self) -> Result<Resource<MyX>> {
+        Ok(IoView::table(self).push(MyX)?)
+    }
+
+    fn foo(&mut self, x: Resource<MyX>) -> Result<()> {
+        _ = IoView::table(self).get(&x)?;
+        Ok(())
+    }
+
+    fn drop(&mut self, x: Resource<MyX>) -> Result<()> {
+        IoView::table(self).delete(x)?;
+        Ok(())
+    }
+}
+
+impl bindings::local::local::borrowing_types::Host for &mut Ctx {}

crates/misc/component-async-tests/src/closed_streams.rs

@@ -0,0 +1,14 @@
+pub mod bindings {
+    wasmtime::component::bindgen!({
+        path: "wit",
+        world: "closed-streams",
+        concurrent_imports: true,
+        concurrent_exports: true,
+        async: {
+            only_imports: [
+                "local:local/closed#read-stream",
+                "local:local/closed#read-future",
+            ]
+        },
+    });
+}

crates/misc/component-async-tests/src/lib.rs

@@ -0,0 +1,42 @@
+#![expect(clippy::allow_attributes_without_reason)]
+
+use std::sync::{Arc, Mutex};
+use std::task::Waker;
+
+use wasmtime::component::{HasData, ResourceTable};
+use wasmtime_wasi::p2::{IoView, WasiCtx, WasiView};
+
+pub mod borrowing_host;
+pub mod closed_streams;
+pub mod resource_stream;
+pub mod round_trip;
+pub mod round_trip_direct;
+pub mod round_trip_many;
+pub mod sleep;
+pub mod transmit;
+pub mod util;
+pub mod yield_host;
+
+/// Host implementation, usable primarily by tests
+pub struct Ctx {
+    pub wasi: WasiCtx,
+    pub table: ResourceTable,
+    pub wakers: Arc<Mutex<Option<Vec<Waker>>>>,
+    pub continue_: bool,
+}
+
+impl IoView for Ctx {
+    fn table(&mut self) -> &mut ResourceTable {
+        &mut self.table
+    }
+}
+
+impl WasiView for Ctx {
+    fn ctx(&mut self) -> &mut WasiCtx {
+        &mut self.wasi
+    }
+}
+
+impl HasData for Ctx {
+    type Data<'a> = &'a mut Self;
+}