| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | fuzz_async.rs | 196 State::with(|s| { in async_pending()
231 struct State { struct
252 impl State { argument
287 State::with(|s| { in run()
306 State::with(|s| { in run()
320 State::with(|s| { in run()
337 State::with(|s| { in run()
346 State::with(|s| { in run()
399 State::with(|s| { in run()
453 State::with(|s| { in run()
[all …]
|
| H A D | async_poll_stackless.rs | 48 enum State { enum
83 State::S0 => { in callback_run()
91 *state = State::S1 { in callback_run()
99 &mut State::S1 { ref mut thing, set } => { in callback_run()
111 *state = State::S2 { in callback_run()
120 &mut State::S2 { in callback_run()
132 *state = State::S3 { in callback_run()
141 &mut State::S3 { in callback_run()
155 *state = State::S4 { in callback_run()
172 *state = State::S5 { set }; in callback_run()
[all …]
|
| H A D | async_cancel_caller.rs | 88 enum State { enum
121 u32::try_from(Box::into_raw(Box::new(State::S0 { in export_run()
136 State::S0 { in callback_run()
222 *state = State::S1 { in callback_run()
232 State::S1 { in callback_run()
267 *state = State::S2 { in callback_run()
277 State::S2 { in callback_run()
325 *state = State::S3 { in callback_run()
334 State::S3 { in callback_run()
367 *state = State::S4 { in callback_run()
[all …]
|
| H A D | async_cancel_callee.rs | 67 enum State { enum
117 u32::try_from(Box::into_raw(Box::new(State::S0(YieldParams { in export_yield_with_options_yield_times()
137 let state = &mut *(usize::try_from(context_get()).unwrap() as *mut State); in callback_yield_with_options_yield_times()
139 State::S0(params) => { in callback_yield_with_options_yield_times()
152 *state = State::S1 { in callback_yield_with_options_yield_times()
161 State::S1 { in callback_yield_with_options_yield_times()
215 *state = State::S2 { in callback_yield_with_options_yield_times()
225 State::S2 { in callback_yield_with_options_yield_times()
|
| H A D | async_intertask_communication.rs | 109 enum State { enum
118 u32::try_from(Box::into_raw(Box::new(State::S0 { in export_run()
130 let state = &mut *(usize::try_from(context_get()).unwrap() as *mut State); in callback_run()
132 State::S0 { number } => { in callback_run()
148 *state = State::S1 { set }; in callback_run()
181 State::S1 { set } => { in callback_run()
|
| H A D | async_readiness.rs | 85 enum State { enum
104 u32::try_from(Box::into_raw(Box::new(State::S0 { in export_start()
122 let state = &mut *(usize::try_from(context_get()).unwrap() as *mut State); in callback_start()
124 State::S0 { rx, expected } => { in callback_start()
167 *state = State::S1 { in callback_start()
177 State::S1 { in callback_start()
|
| H A D | async_synchronous_transmit.rs | 140 enum State { enum
169 u32::try_from(Box::into_raw(Box::new(State::S0 { in export_start()
189 let state = &mut *(usize::try_from(context_get()).unwrap() as *mut State); in callback_start()
191 &mut State::S0 { in callback_start()
215 *state = State::S1 { in callback_start()
227 &mut State::S1 { in callback_start()
|
| H A D | async_cancel_transmit.rs | 187 enum State { enum
218 u32::try_from(Box::into_raw(Box::new(State::S0 { in export_start()
238 let state = &mut *(usize::try_from(context_get()).unwrap() as *mut State); in callback_start()
240 &mut State::S0 { in callback_start()
297 *state = State::S1 { in callback_start()
311 &mut State::S1 { in callback_start()
|
| /wasmtime-44.0.1/crates/fiber/src/ |
| H A D | miri.rs | 73 state: Mutex<State<A, B, C>>,
76 enum State<A, B, C> { enum
91 unsafe impl<A, B, C> Send for State<A, B, C> {} implementation
92 unsafe impl<A, B, C> Sync for State<A, B, C> {} implementation
127 State::Exiting => {} in run()
143 state: Mutex::new(State::None), in new()
185 State::SuspendWith(msg) => msg, in resume()
222 assert!(matches!(*lock, State::None)); in set_result()
223 *lock = State::SuspendWith(result); in set_result()
233 !matches!(s, State::ResumeWith(_) | State::Exiting) in block_until_notified()
[all …]
|
| /wasmtime-44.0.1/cranelift/filetests/src/ |
| H A D | runner.rs | 22 state: State,
26 enum State { enum
113 state: State::New, in push_test()
190 state: State::Done(ref result), in report_job()
209 self.tests[jobid].state = State::Queued; in schedule_jobs()
213 self.tests[jobid].state = State::Running; in schedule_jobs()
228 self.tests[0].state = State::Running; in schedule_pass_job()
246 self.tests[jobid].state = State::Done(result); in finish_job()
259 self.tests[jobid].state = State::Running; in handle_reply()
315 state: State::Done(Ok(dur)), in report_slow_tests()
[all …]
|
| /wasmtime-44.0.1/crates/wasmtime/src/profiling_agent/ |
| H A D | vtune.rs | 24 state: Mutex<State>,
29 struct State { struct
36 state: Mutex::new(State { in new() argument
48 impl State { impl
73 impl State { impl
|
| H A D | pulley.rs | 49 state: Arc<State>,
60 struct State { struct
101 state: Arc::new(State { in new()
167 fn sampling_thread(state: &State, to_record: mpsc::Sender<Samples>) { in sampling_thread() argument
242 fn recording_thread(state: &State, to_record: mpsc::Receiver<Samples>) { in recording_thread() argument
|
| /wasmtime-44.0.1/tests/all/ |
| H A D | call_hook.rs | 12 let mut store = Store::<State>::default(); in call_wrapped_func()
15 fn verify(state: &State) { in call_wrapped_func() argument
43 |caller: Caller<State>, params, results| { in call_wrapped_func()
311 let mut store = Store::<State>::default(); in instantiate()
552 impl CallHookHandler<State> for HandlerR { in basic_async_hook()
555 ctx: StoreContextMut<'_, State>, in basic_async_hook() argument
628 impl CallHookHandler<State> for HandlerR { in timeout_async_hook()
818 pub struct State { struct
832 impl Default for State { argument
834 State { in default()
[all …]
|
| /wasmtime-44.0.1/tests/all/component_model/ |
| H A D | call_hook.rs | 4 use crate::call_hook::{Context, State, sync_call_hook};
46 let mut linker = Linker::<State>::new(&engine); in call_wrapped_func()
51 let mut store = Store::new(&engine, State::default()); in call_wrapped_func()
112 let linker = Linker::<State>::new(&engine); in call_func_with_realloc()
113 let mut store = Store::new(&engine, State::default()); in call_func_with_realloc()
160 let linker = Linker::<State>::new(&engine); in call_func_with_post_return()
220 let mut linker = Linker::<State>::new(&engine); in call_wrapped_async_func()
259 let mut linker = Linker::<State>::new(&engine); in trapping()
406 impl CallHookHandler<State> for HandlerR { in timeout_async_hook()
409 mut ctx: StoreContextMut<'_, State>, in timeout_async_hook() argument
[all …]
|
| /wasmtime-44.0.1/crates/wasi-preview1-component-adapter/src/ |
| H A D | lib.rs | 180 State::with(|state| { in adapter_open_badfd()
210 State::with(|state| { in cabi_import_realloc()
484 State::with(|state| { in args_get()
521 State::with(|state| { in args_sizes_get()
562 State::with(|state| { in environ_get()
614 State::with(|state| { in environ_sizes_get()
753 State::with(|state| { in fd_close()
952 State::with(|state| { in fd_fdstat_set_rights()
1259 State::with(|state| { in fd_read()
2681 struct State { struct
[all …]
|
| H A D | descriptors.rs | 3 use crate::{BlockingMode, ImportAlloc, State, TrappingUnwrap, WasmStr};
159 pub fn new(state: &State) -> Self { in new()
197 fn open_preopens(&self, state: &State) { in open_preopens() argument
234 pub unsafe fn get_preopen_path(&self, state: &State, fd: Fd, path: *mut u8, len: usize) { in get_preopen_path() argument
|
| /wasmtime-44.0.1/cranelift/isle/isle/src/ |
| H A D | recursion.rs | 52 enum State { in terms_in_cycles() enum
69 states.insert(term_id, State::Visiting); in terms_in_cycles()
78 Some(State::Visiting) => { in terms_in_cycles()
86 Some(State::Visited) => {} in terms_in_cycles()
89 states.insert(term_id, State::Visited); in terms_in_cycles()
|
| /wasmtime-44.0.1/crates/environ/src/compile/ |
| H A D | module_artifacts.rs | 299 type State; typedef
302 fn finish_object(obj: ObjectBuilder<'_>, state: &Self::State) -> Result<Self>; in finish_object()
306 type State = (); typedef
307 fn finish_object(obj: ObjectBuilder<'_>, _state: &Self::State) -> Result<Self> { in finish_object()
|
| /wasmtime-44.0.1/cranelift/codegen/src/machinst/ |
| H A D | mod.rs | 348 type State: MachInstEmitState<Self>; typedef
354 fn emit(&self, code: &mut MachBuffer<Self>, info: &Self::Info, state: &mut Self::State); in emit() argument
357 fn pretty_print_inst(&self, state: &mut Self::State) -> String; in pretty_print_inst()
|
| H A D | buffer.rs | 1793 emit_state: &I::State, in push_user_stack_map() argument
2544 let mut state = <Inst as MachInstEmit>::State::default(); in test_elide_jump_to_next()
2560 let mut state = <Inst as MachInstEmit>::State::default(); in test_elide_trivial_jump_blocks()
2591 let mut state = <Inst as MachInstEmit>::State::default(); in test_flip_cond()
2637 let mut state = <Inst as MachInstEmit>::State::default(); in test_island()
2706 let mut state = <Inst as MachInstEmit>::State::default(); in test_island_backward()
2792 let mut state = <Inst as MachInstEmit>::State::default(); in test_multiple_redirect()
2869 let mut state = <Inst as MachInstEmit>::State::default(); in test_handle_branch_cycle()
|
| /wasmtime-44.0.1/crates/explorer/src/ |
| H A D | index.js | 1 class State { class
9 const state = (window.STATE = new State(window.WAT, window.CLIF, window.ASM));
|
| /wasmtime-44.0.1/cranelift/interpreter/src/ |
| H A D | state.rs | 23 pub trait State<'a> { interface
|
| /wasmtime-44.0.1/crates/fuzzing/src/generators/ |
| H A D | component_async.rs | 96 let mut state = State::default(); in arbitrary()
117 struct State { struct
308 impl State { implementation
310 let State { in is_empty() localVariable
|
| /wasmtime-44.0.1/cranelift/codegen/src/isa/pulley_shared/inst/ |
| H A D | emit.rs | 92 type State = EmitState<P>; typedef
95 fn emit(&self, sink: &mut MachBuffer<Self>, emit_info: &Self::Info, state: &mut Self::State) { in emit() argument
113 fn pretty_print_inst(&self, state: &mut Self::State) -> String { in pretty_print_inst()
|
| /wasmtime-44.0.1/crates/wasmtime/src/compile/ |
| H A D | runtime.rs | 180 type State = CustomAlignment; typedef
|