| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | async_cancel_caller.rs | 96 waitable: u32,
102 waitable: u32,
107 waitable: u32,
112 waitable: u32,
225 waitable, in callback_run()
235 waitable, in callback_run()
270 waitable, in callback_run()
280 waitable, in callback_run()
327 waitable, in callback_run()
336 waitable, in callback_run()
[all …]
|
| H A D | async_cancel_callee.rs | 71 waitable: u32,
76 waitable: u32,
144 let waitable = status >> 4; in callback_yield_with_options_yield_times() localVariable
150 waitable_join(waitable, set); in callback_yield_with_options_yield_times()
154 waitable, in callback_yield_with_options_yield_times()
163 waitable, in callback_yield_with_options_yield_times()
179 waitable_join(*waitable, 0); in callback_yield_with_options_yield_times()
182 subtask_drop(*waitable); in callback_yield_with_options_yield_times()
217 waitable, in callback_yield_with_options_yield_times()
227 waitable, in callback_yield_with_options_yield_times()
[all …]
|
| H A D | async_yield_caller_cancel.rs | 35 let waitable = status >> 4; in run() localVariable
46 let status = subtask_cancel(waitable); in run()
|
| /wasmtime-44.0.1/tests/misc_testsuite/component-model/async/ |
| H A D | wait-forever2.wast | 12 (import "" "waitable-set.new" (func $waitable-set.new (result i32)))
24 (canon waitable-set.new (core func $waitable-set.new))
27 (export "waitable-set.new" (func $waitable-set.new))
42 (import "" "waitable.join" (func $waitable.join (param i32 i32)))
43 (import "" "waitable-set.new" (func $waitable-set.new (result i32)))
57 (canon waitable.join (core func $waitable.join))
58 (canon waitable-set.new (core func $waitable-set.new))
59 (canon waitable-set.wait (memory $memory "mem") (core func $waitable-set.wait))
63 (export "waitable.join" (func $waitable.join))
64 (export "waitable-set.new" (func $waitable-set.new))
[all …]
|
| H A D | backpressure-deadlock.wast | 9 ;; - Component B adds the subtask to a waitable set and calls waitable-set.wait
52 (core func $waitable-set.new (canon waitable-set.new))
53 (core func $waitable.join (canon waitable.join))
54 (core func $waitable-set.wait (canon waitable-set.wait (memory $libc "mem")))
59 (import "" "waitable-set.new" (func $waitable-set.new (result i32)))
60 (import "" "waitable.join" (func $waitable.join (param i32 i32)))
61 (import "" "waitable-set.wait" (func $waitable-set.wait (param i32 i32) (result i32)))
80 (call $waitable.join
94 (export "waitable-set.new" (func $waitable-set.new))
95 (export "waitable.join" (func $waitable.join))
[all …]
|
| H A D | cancel-host.wast | 147 (core func $waitable-set.new (canon waitable-set.new))
148 (core func $waitable.join (canon waitable.join))
150 (core func $waitable-set.drop (canon waitable-set.drop))
156 (export "waitable.join" (func $waitable.join))
157 (export "waitable-set.new" (func $waitable-set.new))
236 (core func $waitable-set.new (canon waitable-set.new))
237 (core func $waitable.join (canon waitable.join))
245 (export "waitable.join" (func $waitable.join))
365 (core func $waitable-set.new (canon waitable-set.new))
366 (core func $waitable.join (canon waitable.join))
[all …]
|
| H A D | stream-cancel-finished-op.wast | 16 (import "" "waitable-set.new" (func $waitable-set.new (result i32)))
19 (import "" "waitable.join" (func $waitable.join (param i32) (param i32)))
20 (import "" "waitable-set.drop" (func $waitable-set.drop (param i32)))
181 (core func $waitable-set.new (canon waitable-set.new))
182 (core func $waitable.join (canon waitable.join))
185 (core func $waitable-set.drop (canon waitable-set.drop))
212 (export "waitable-set.new" (func $waitable-set.new))
213 (export "waitable.join" (func $waitable.join))
214 (export "waitable-set.wait" (func $waitable-set.wait))
215 (export "waitable-set.poll" (func $waitable-set.poll))
[all …]
|
| H A D | partial-stream-copies.wast | 22 (import "" "waitable.join" (func $waitable.join (param i32 i32)))
23 (import "" "waitable-set.new" (func $waitable-set.new (result i32)))
114 (canon waitable.join (core func $waitable.join))
115 (canon waitable-set.new (core func $waitable-set.new))
124 (export "waitable.join" (func $waitable.join))
125 (export "waitable-set.new" (func $waitable-set.new))
216 (canon waitable.join (core func $waitable.join))
217 (canon waitable-set.new (core func $waitable-set.new))
227 (export "waitable.join" (func $waitable.join))
228 (export "waitable-set.new" (func $waitable-set.new))
[all …]
|
| H A D | stackful.wast | 110 ;; waitable-set.wait
115 (import "" "waitable-set.wait" (func $waitable-set-wait (param i32 i32) (result i32)))
117 (core func $waitable-set-wait (canon waitable-set.wait cancellable (memory $libc "memory")))
118 …(core instance $i (instantiate $m (with "" (instance (export "waitable-set.wait" (func $waitable-s…
121 ;; waitable-set.poll
126 (import "" "waitable-set.poll" (func $waitable-set-poll (param i32 i32) (result i32)))
128 (core func $waitable-set-poll (canon waitable-set.poll cancellable (memory $libc "memory")))
129 …(core instance $i (instantiate $m (with "" (instance (export "waitable-set.poll" (func $waitable-s…
|
| H A D | wait-forever.wast | 12 (import "" "waitable-set-new" (func $waitable-set-new (result i32)))
14 call $waitable-set-new
25 (core func $waitable-set-new (canon waitable-set.new))
29 (export "waitable-set-new" (func $waitable-set-new))
|
| H A D | trap-if-done.wast | 26 (import "" "waitable.join" (func $waitable.join (param i32 i32)))
102 (canon waitable.join (core func $waitable.join))
103 (canon waitable-set.new (core func $waitable-set.new))
113 (export "waitable.join" (func $waitable.join))
114 (export "waitable-set.new" (func $waitable-set.new))
115 (export "waitable-set.wait" (func $waitable-set.wait))
388 (canon waitable.join (core func $waitable.join))
389 (canon waitable-set.new (core func $waitable-set.new))
407 (export "waitable.join" (func $waitable.join))
408 (export "waitable-set.new" (func $waitable-set.new))
[all …]
|
| H A D | subtask-wait.wast | 30 (core func $new (canon waitable-set.new))
31 (core func $join (canon waitable.join))
32 (core func $drop (canon waitable-set.drop))
33 (core func $wait (canon waitable-set.wait (memory $libc "memory")))
52 ;; extract the waitable handle
55 ;; Make a waitable set and insert our handle into it
|
| H A D | task-builtins.wast | 32 ;; waitable-set.wait
39 (core func $waitable-set-wait (canon waitable-set.wait (memory $libc "memory")))
43 ;; waitable-set.poll
50 (core func $waitable-set-poll (canon waitable-set.poll (memory $libc "memory")))
487 (import "" "waitable.join" (func $waitable.join (param i32 i32)))
579 (canon waitable.join (core func $waitable.join))
580 (canon waitable-set.new (core func $waitable-set.new))
590 (export "waitable.join" (func $waitable.join))
591 (export "waitable-set.new" (func $waitable-set.new))
652 (canon waitable.join (core func $waitable.join))
[all …]
|
| H A D | reenter-during-yield.wast | 12 ;; simulate `waitable-set.poll` with a yield loop
|
| /wasmtime-44.0.1/tests/all/ |
| H A D | pulley_provenance_test_async_component.wat | 121 (import "" "waitable-set.new" (func $waitable-set.new (result i32)))
122 (import "" "waitable.join" (func $waitable.join (param i32 i32)))
124 (import "" "waitable-set.drop" (func $waitable-set.drop (param i32)))
183 (core func $waitable-set.new (canon waitable-set.new))
184 (core func $waitable.join (canon waitable.join))
185 (core func $waitable-set.wait (canon waitable-set.wait (memory $libc "mem")))
186 (core func $waitable-set.drop (canon waitable-set.drop))
195 (export "waitable-set.new" (func $waitable-set.new))
196 (export "waitable.join" (func $waitable.join))
197 (export "waitable-set.wait" (func $waitable-set.wait))
[all …]
|
| /wasmtime-44.0.1/tests/misc_testsuite/component-model-threading/ |
| H A D | stackful-cancellation.wast | 61 (import "" "waitable.join" (func $waitable.join (param i32 i32)))
198 (core func $waitable-set.new (canon waitable-set.new))
199 (core func $waitable.join (canon waitable.join))
220 (export "waitable.join" (func $waitable.join))
221 (export "waitable-set.wait" (func $waitable-set.wait))
222 (export "waitable-set.new" (func $waitable-set.new))))
347 (core func $waitable-set.new (canon waitable-set.new))
349 (core func $waitable.join (canon waitable.join))
364 (export "waitable.join" (func $waitable.join))
365 (export "waitable-set.new" (func $waitable-set.new))
[all …]
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/ |
| H A D | concurrent.rs | 134 let waitable = waitable.unwrap_or(0); in pack() localVariable
135 assert!(waitable < (1 << 28)); in pack()
136 (waitable << 4) | (self as u32) in pack()
828 let (event, waitable) = in handle_guest_call()
1882 waitable.join(state, Some(set))?; in wait_for_event()
1889 waitable.join(state, old_set) in wait_for_event()
2707 let (status, waitable) = loop { in start_call()
2781 Ok(status.pack(waitable)) in start_call()
3081 let waitable = in waitable_join() localVariable
4626 waitable: u32, in from_instance()
[all …]
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/ |
| H A D | futures_and_streams.rs | 3867 let waitable = Waitable::Transmit(handle); in wait_for_write() localVariable
3868 store.wait_for_event(waitable)?; in wait_for_write()
3873 waitable.on_delivery(store, self, event)?; in wait_for_write()
3900 waitable.on_delivery(store, self, event)?; in cancel_write()
3954 let waitable = Waitable::Transmit(handle); in wait_for_read() localVariable
3955 store.wait_for_event(waitable)?; in wait_for_read()
3960 waitable.on_delivery(store, self, event)?; in wait_for_read()
3987 waitable.on_delivery(store, self, event)?; in cancel_read()
4573 let waitable = Waitable::Transmit(TableId::<TransmitHandle>::new(waitable)); in update_event() localVariable
4590 let event = match (waitable.take_event(self)?, event) { in update_event()
[all …]
|
| /wasmtime-44.0.1/crates/test-programs/src/ |
| H A D | async_.rs | 16 pub fn waitable_join(waitable: u32, set: u32); in waitable_join()
|
| /wasmtime-44.0.1/crates/environ/src/ |
| H A D | component.rs | 118 waitable_join(vmctx: vmctx, caller_instance: u32, set: u32, waitable: u32) -> bool;
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/component/ |
| H A D | libcalls.rs | 788 waitable: u32, in waitable_join()
794 waitable, in waitable_join()
|