| /wasmtime-44.0.1/tests/misc_testsuite/component-model/async/ |
| H A D | futures.wast | 4 ;; future.new
9 (type $future-type (future u8))
10 (core func $future-new (canon future.new $future-type))
21 (type $future-type (future u8))
36 (type $future-type (future string))
48 (type $future-type (future u8))
58 (type $future-type (future u8))
59 (core func $future-cancel-read (canon future.cancel-read $future-type))
68 (type $future-type (future u8))
78 (type $future-type (future u8))
[all …]
|
| H A D | futures-must-write.wast | 16 (import "" "future.new" (func $future.new (result i64)))
22 (func $start-future (export "start-future") (result i32)
48 (canon future.new $FT (core func $future.new))
53 (export "future.new" (func $future.new))
54 (export "future.write" (func $future.write))
57 (func (export "start-future") (result (future u8)) (canon lift (core func $cm "start-future")))
63 (export "start-future" (func (result (future u8))))
103 (canon future.new $FT (core func $future.new))
111 (export "future.new" (func $future.new))
112 (export "future.read" (func $future.read))
[all …]
|
| H A D | intra-futures.wast | 13 (type $s (future string))
14 (core func $future.new (canon future.new $s))
15 …(core func $future.read (canon future.read $s async (memory $libc "m") (realloc (func $libc "reall…
16 (core func $future.write (canon future.write $s async (memory $libc "m")))
20 (import "" "future.new" (func $future.new (result i64)))
21 (import "" "future.read" (func $future.read (param i32 i32) (result i32)))
22 (import "" "future.write" (func $future.write (param i32 i32) (result i32)))
28 (local.set $tmp (call $future.new))
46 (export "future.new" (func $future.new))
47 (export "future.read" (func $future.read))
[all …]
|
| H A D | trap-if-done.wast | 29 (import "" "future.new" (func $future.new (result i64)))
105 (canon future.new $FT (core func $future.new))
116 (export "future.new" (func $future.new))
117 (export "future.write" (func $future.write))
123 (func (export "start-future") (result (future u8)) (canon lift (core func $cm "start-future")))
134 (export "start-future" (func (result (future u8))))
391 (canon future.new $FT (core func $future.new))
410 (export "future.new" (func $future.new))
411 (export "future.read" (func $future.read))
416 (export "start-future" (func $start-future'))
[all …]
|
| H A D | async-builtins.wast | 24 ;; future.cancel-read
27 (import "" "future.cancel-read" (func $future-cancel-read (param i32) (result i32)))
29 (type $future-type (future u8))
30 (core func $future-cancel-read (canon future.cancel-read $future-type async))
31 …(core instance $i (instantiate $m (with "" (instance (export "future.cancel-read" (func $future-ca…
34 ;; future.cancel-write
37 (import "" "future.cancel-write" (func $future-cancel-write (param i32) (result i32)))
39 (type $future-type (future u8))
40 (core func $future-cancel-write (canon future.cancel-write $future-type async))
41 …(core instance $i (instantiate $m (with "" (instance (export "future.cancel-write" (func $future-c…
|
| H A D | future-read.wast | 12 (type $future (future))
34 (type $future (future))
39 (core func $new (canon future.new $future))
73 (type $future (future))
95 (type $future (future))
99 (core func $new (canon future.new $future))
133 (type $future (future))
159 (type $future (future))
163 (core func $new (canon future.new $future))
198 (type $future (future))
[all …]
|
| H A D | streams-massive-send.wast | 12 (type $f (future $t))
23 (import "" "future.new" (func $future.new (result i64)))
140 (core func $future.new (canon future.new $f))
149 (export "future.new" (func $future.new))
150 (export "future.write" (func $future.write))
153 (export "task.return future" (func $task.return-future))
181 (import "" "big-future" (func $big-future (result i32)))
202 (core func $big-future (canon lower (func $a "big-future")))
219 (export "big-future" (func $big-future))
220 (export "future.read" (func $future.read))
[all …]
|
| H A D | stream-cancel-finished-op.wast | 21 (import "" "future.new" (func $future.new (result i64)))
195 (core func $future.new (canon future.new $f))
198 (core func $future.cancel-read (canon future.cancel-read $f))
199 (core func $future.cancel-write (canon future.cancel-write $f))
217 (export "future.new" (func $future.new))
218 (export "future.read" (func $future.read))
219 (export "future.write" (func $future.write))
220 (export "future.cancel-read" (func $future.cancel-read))
221 (export "future.cancel-write" (func $future.cancel-write))
222 (export "future.drop-writable" (func $future.drop-writable))
[all …]
|
| H A D | future-cancel-read-dropped.wast | 3 ;; Create a future, start a read, drop the write end, and cancel the read.
5 (type $f (future))
6 (core func $new (canon future.new $f))
9 (core func $read (canon future.read $f async (memory $libc "mem")))
10 (core func $cancel (canon future.cancel-read $f))
11 (core func $write (canon future.write $f async (memory $libc "mem")))
12 (core func $drop-write (canon future.drop-writable $f))
64 ;; Note that there's no way for `future.read` to return DROPPED since the write
|
| H A D | future-cancel-write-completed.wast | 3 ;; Create a future, start a write, let it complete, and cancel the write prior
6 (type $f (future))
9 (type $f (future))
13 (core func $read (canon future.read $f async (memory $libc "mem")))
14 (core func $drop-read (canon future.drop-readable $f))
50 (core func $new (canon future.new $f))
53 (core func $write (canon future.write $f async (memory $libc "mem")))
54 (core func $cancel (canon future.cancel-write $f))
|
| H A D | future-cancel-write-dropped.wast | 3 ;; Create a future, start a write, drop the read end, and cancel the write.
5 (type $f (future))
6 (core func $new (canon future.new $f))
9 (core func $write (canon future.write $f async (memory $libc "mem")))
10 (core func $cancel (canon future.cancel-write $f))
11 (core func $drop-read (canon future.drop-readable $f))
|
| H A D | task-builtins.wast | 476 (export "run-future" (func async (param "future" $FT) (result u32)))
485 (import "" "future.write" (func $future.write (param i32 i32) (result i32)))
490 (import "" "future.new" (func $future.new (result i64)))
573 (canon future.new $FT (core func $future.new))
586 (export "future.new" (func $future.new))
587 (export "future.write" (func $future.write))
593 (export "run-reader-future" (func $run-reader-future))
646 (canon future.new $FT (core func $future.new))
658 (import "" "future.read" (func $future.read (param i32 i32) (result i32)))
695 (export "future.read" (func $future.read))
[all …]
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/ |
| H A D | abort.rs | 93 let future = JoinHandleFuture { in run() localVariable
94 future: ManuallyDrop::new(future), in run()
97 (handle, future) in run()
127 future: ManuallyDrop<F>, field
141 let (state, future) = unsafe { in poll()
163 future.poll(cx).map(Some) in poll()
221 let mut future = pin!(future); in abort_in_progress() localVariable
241 let mut future = pin!(future); in abort_complete() localVariable
255 drop(future); in abort_dropped()
267 let task = tokio::task::spawn(future); in await_completion()
[all …]
|
| /wasmtime-44.0.1/crates/fuzzing/wit/ |
| H A D | fuzz.wit | 29 future-new(u32),
30 // take a future readable end through the `future-take` import.
31 future-take(u32),
33 future-give(u32),
37 future-write-ready(future-payload),
38 future-read-ready(future-payload),
39 future-write-pending(future-payload),
46 future-read-assert-complete(future-payload),
75 %future: u32,
125 future-take: func(id: u32) -> future<u32>;
[all …]
|
| /wasmtime-44.0.1/crates/gdbstub-component/src/ |
| H A D | api.rs | 16 future: EventFuture, field
22 let future = d.continue_(r); in continue_() localVariable
23 let pollable = Some(AsyncPollable::new(future.subscribe())); in continue_()
24 Resumption { future, pollable } in continue_()
28 let future = d.single_step(r); in single_step() localVariable
29 let pollable = Some(AsyncPollable::new(future.subscribe())); in single_step()
30 Resumption { future, pollable } in single_step()
42 EventFuture::finish(self.future, d) in result()
|
| /wasmtime-44.0.1/crates/misc/component-async-tests/wit/ |
| H A D | test.wit | 72 read-future(string),
75 write-future(string),
81 … caller-future2: future<string>) -> tuple<stream<string>, future<string>, future<string>>;
115 interface run-future {
133 read-future: async func(rx: future<u8>, expected: u8, rx-ignore: future<u8>);
134 read-future-post-return: async func(rx: future<u8>, expected: u8, rx-ignore: future<u8>);
167 foo: func(fut: future);
286 world error-context-future-callee {
287 export run-future;
291 world error-context-future-caller {
[all …]
|
| /wasmtime-44.0.1/crates/component-macro/tests/expanded/ |
| H A D | resources-import_async.rs | 10 ) -> impl ::core::future::Future< in new()
16 ) -> impl ::core::future::Future<Output = ()> + Send; in foo()
26 ) -> impl ::core::future::Future< in new()
161 ) -> impl ::core::future::Future< in some_world_func()
168 ) -> impl ::core::future::Future< in some_world_func()
425 ) -> impl ::core::future::Future< in new()
443 ) -> impl ::core::future::Future< in new()
530 ) -> impl ::core::future::Future< in new()
544 ) -> impl ::core::future::Future< in new()
576 ) -> impl ::core::future::Future< in bar_result()
[all …]
|
| H A D | resources-import_tracing_async.rs | 10 ) -> impl ::core::future::Future< in new()
16 ) -> impl ::core::future::Future<Output = ()> + Send; in foo()
26 ) -> impl ::core::future::Future< in new()
161 ) -> impl ::core::future::Future< in some_world_func()
168 ) -> impl ::core::future::Future< in some_world_func()
488 ) -> impl ::core::future::Future< in new()
506 ) -> impl ::core::future::Future< in new()
593 ) -> impl ::core::future::Future< in new()
607 ) -> impl ::core::future::Future< in new()
639 ) -> impl ::core::future::Future< in bar_result()
[all …]
|
| H A D | integers_async.rs | 203 ) -> impl ::core::future::Future<Output = ()> + Send; in a1()
207 ) -> impl ::core::future::Future<Output = ()> + Send; in a2()
211 ) -> impl ::core::future::Future<Output = ()> + Send; in a3()
215 ) -> impl ::core::future::Future<Output = ()> + Send; in a4()
219 ) -> impl ::core::future::Future<Output = ()> + Send; in a5()
223 ) -> impl ::core::future::Future<Output = ()> + Send; in a6()
227 ) -> impl ::core::future::Future<Output = ()> + Send; in a7()
231 ) -> impl ::core::future::Future<Output = ()> + Send; in a8()
242 ) -> impl ::core::future::Future<Output = ()> + Send; in a9()
259 ) -> impl ::core::future::Future<Output = ()> + Send { in a1()
[all …]
|
| H A D | conventions_async.rs | 234 ) -> impl ::core::future::Future<Output = ()> + Send; in kebab_case()
238 ) -> impl ::core::future::Future<Output = ()> + Send; in foo()
241 ) -> impl ::core::future::Future<Output = ()> + Send; in function_with_dashes()
244 ) -> impl ::core::future::Future<Output = ()> + Send; in function_with_no_weird_characters()
248 ) -> impl ::core::future::Future<Output = ()> + Send; in apple_pear()
251 ) -> impl ::core::future::Future<Output = ()> + Send; in apple_pear_grape()
261 ) -> impl ::core::future::Future<Output = ()> + Send; in explicit()
264 ) -> impl ::core::future::Future<Output = ()> + Send; in explicit_kebab()
271 ) -> impl ::core::future::Future<Output = ()> + Send { in kebab_case()
277 ) -> impl ::core::future::Future<Output = ()> + Send { in foo()
[all …]
|
| H A D | lists_async.rs | 420 ) -> impl ::core::future::Future< in list_u8_ret()
425 ) -> impl ::core::future::Future< in list_u16_ret()
430 ) -> impl ::core::future::Future< in list_u32_ret()
435 ) -> impl ::core::future::Future< in list_u64_ret()
440 ) -> impl ::core::future::Future< in list_s8_ret()
445 ) -> impl ::core::future::Future< in list_s16_ret()
450 ) -> impl ::core::future::Future< in list_s32_ret()
455 ) -> impl ::core::future::Future< in list_s64_ret()
460 ) -> impl ::core::future::Future< in list_f32_ret()
465 ) -> impl ::core::future::Future< in list_f64_ret()
[all …]
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | debugger_component.rs | 38 future: EventFuture, field
43 let future = d.single_step(ResumptionValue::Normal); in single_step() localVariable
44 Self { future } in single_step()
48 let future = d.continue_(ResumptionValue::Normal); in continue_() localVariable
49 Self { future } in continue_()
53 EventFuture::finish(self.future, d) in result()
|
| H A D | async_synchronous_transmit.rs | 144 future: u32,
152 future: u32,
162 future: u32, in export_start()
176 future, in export_start()
194 future, in callback_start()
220 future, in callback_start()
232 future, in callback_start()
259 let status = future_read(future, received); in callback_start()
262 future_drop_readable(future); in callback_start()
|
| H A D | async_cancel_transmit.rs | 191 future: u32,
201 future: u32,
211 future: u32, in export_start()
225 future, in export_start()
243 future, in callback_start()
261 let status = future_read(future, future_read_buffer); in callback_start()
304 future, in callback_start()
318 future, in callback_start()
343 let status = future_cancel_read(future); in callback_start()
347 future_drop_readable(future); in callback_start()
|
| /wasmtime-44.0.1/crates/wasmtime/src/ |
| H A D | runtime.rs | 140 fn box_future<'a, F, T, E>(future: F) -> Pin<Box<dyn Future<Output = Result<T, E>> + Send + 'a>> in box_future()
146 if let Ok(future) = try_new::<Box<F>>(future) { in box_future()
147 return Pin::from(future); in box_future()
167 let future = OomFuture::<F, T, E>(marker::PhantomData); in box_future() localVariable
168 assert_eq!(size_of_val(&future), 0); in box_future()
169 Box::pin(future) in box_future()
|