| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/ |
| H A D | abort.rs | 40 Complete, enumerator
76 JoinState::AbortRequested { .. } | JoinState::Complete => {} in abort()
121 JoinState::Complete => Poll::Ready(()), in poll()
157 JoinState::AbortRequested { .. } | JoinState::Complete => { in poll()
181 let prev = mem::replace(&mut *self.state.lock().unwrap(), JoinState::Complete); in drop()
190 JoinState::Complete => None, in drop()
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p3_http_middleware.rs | 82 let mut status = StreamResult::Complete(0); in handle()
85 while let StreamResult::Complete(_) = status { in handle()
146 let mut status = StreamResult::Complete(0); in handle()
149 while let StreamResult::Complete(_) = status { in handle()
|
| H A D | p3_sockets_tcp_sample_application.rs | 36 assert_eq!(result, StreamResult::Complete(0)); in test_tcp_sample_application()
47 assert_eq!(result, StreamResult::Complete(first_message.len())); in test_tcp_sample_application()
80 assert_eq!(result, StreamResult::Complete(second_message.len())); in test_tcp_sample_application()
|
| H A D | p3_cli.rs | 31 assert_eq!(res, StreamResult::Complete(13)); in run()
44 assert_eq!(res, StreamResult::Complete(13)); in run()
|
| H A D | async_transmit_callee.rs | 49 StreamResult::Complete(0) in exchange()
61 StreamResult::Complete(0) in exchange()
|
| H A D | p3_cli_read_stdin.rs | 12 assert_eq!(sresult, wit_bindgen::StreamResult::Complete(6)); in run()
|
| H A D | async_short_reads.rs | 50 StreamResult::Complete(_) => { in short_reads()
|
| H A D | async_closed_streams.rs | 26 if !matches!(result, StreamResult::Complete(_)) { in read_stream()
|
| H A D | p3_sockets_tcp_streams.rs | 24 assert_eq!(status, StreamResult::Complete(4)); in test_tcp_ping_pong()
33 assert_eq!(status, StreamResult::Complete(4)); in test_tcp_ping_pong()
247 StreamResult::Complete(n) => { in test_tcp_read_cancellation()
|
| H A D | p3_http_echo.rs | 41 StreamResult::Complete(_) => { in handle()
|
| H A D | debugger_component.rs | 121 matches!(event, Event::Complete), in test_loop()
|
| H A D | fuzz_async.rs | 580 assert_eq!(status, StreamResult::Complete(payload.ready_count as usize)); in run()
603 assert_eq!(status, StreamResult::Complete(payload.ready_count as usize)); in run()
636 StreamResult::Complete(n) => { in run()
694 StreamResult::Complete(_) => { in run()
|
| H A D | async_transmit_caller.rs | 80 StreamResult::Complete(0) in run()
|
| /wasmtime-44.0.1/crates/debugger/src/ |
| H A D | lib.rs | 116 Complete, enumerator
300 DebuggeeState::Complete => true, in is_complete()
379 DebuggeeState::Complete => { in run()
399 self.state = DebuggeeState::Complete; in run()
474 DebuggeeState::Complete => { in with_store()
|
| /wasmtime-44.0.1/crates/fuzzing/src/oracles/ |
| H A D | component_async.rs | 482 (HostFutureConsumerState::Complete(_), _) in future_or_stream_cmd()
490 HostFutureConsumerState::Complete(i) => assert_eq!(i, payload.item), in future_or_stream_cmd()
521 Some((HostFutureConsumerState::Complete(_), _)) in future_or_stream_cmd()
532 HostFutureConsumerState::Complete(i) => assert_eq!(i, payload.item), in future_or_stream_cmd()
539 assert!(matches!(state, HostFutureProducerState::Complete)); in future_or_stream_cmd()
834 Complete(u32), enumerator
884 .0 = HostFutureConsumerState::Complete(item.unwrap()); in poll_consume()
887 HostFutureConsumerState::Complete(_) => unreachable!(), in poll_consume()
899 Complete, enumerator
930 state.0 = HostFutureProducerState::Complete; in poll_produce()
[all …]
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/gc/ |
| H A D | gc_runtime.rs | 733 GcProgress::Complete => return, in collect()
744 Complete, enumerator
761 GcProgress::Complete => return, in collect_async()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/gc/enabled/ |
| H A D | null.rs | 349 GcProgress::Complete in collect_increment()
|
| H A D | drc.rs | 1122 GcProgress::Complete in collect_increment()
1124 DrcCollectionPhase::Done => GcProgress::Complete, in collect_increment()
|
| /wasmtime-44.0.1/crates/gdbstub-component/src/ |
| H A D | lib.rs | 221 api::Event::Complete => { in handle_event()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/ |
| H A D | concurrent.rs | 1198 Complete(R), in poll_until() enumerator
1205 return Poll::Ready(Ok(PollResult::Complete(value))); in poll_until()
1251 Poll::Ready(Ok(PollResult::Complete(value))) in poll_until()
1287 PollResult::Complete(value) => break Ok(value), in poll_until()
|
| /wasmtime-44.0.1/crates/debugger/src/host/ |
| H A D | api.rs | 255 DebugRunResult::Finished => wit::Event::Complete, in result_to_event()
|
| /wasmtime-44.0.1/docs/ |
| H A D | stability-tiers.md | 435 * Complete implementations for anything that's part of Tier 1. For
|
| /wasmtime-44.0.1/cranelift/codegen/src/isa/s390x/ |
| H A D | inst.isle | 2869 ;; Complete the sequence under construction.
|