Searched refs:executor (Results 1 – 8 of 8) sorted by relevance
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p2_api_proxy_streaming.rs | 17 executor::run(async move { in handle()
52 executor::outgoing_body(response.body().expect("response should be writable")); in handle_request()
83 executor::outgoing_body(response.body().expect("response should be writable")); in handle_request()
117 let mut stream = executor::incoming_body( in handle_request()
131 let mut body = executor::outgoing_body( in handle_request()
199 let mut body = executor::outgoing_body( in double_echo()
205 let response = executor::outgoing_request_send(outgoing_request); in double_echo()
207 let mut stream = executor::incoming_body( in double_echo()
281 let response = executor::outgoing_request_send(request).await?; in hash()
290 executor::incoming_body(response.consume().expect("response should be readable")); in hash()
[all …]
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/ |
| H A D | fiber.rs | 580 executor: Executor, field
597 let mut executor = self.executor; in replace() localVariable
598 store.swap_executor(&mut executor); in replace()
602 executor, in replace()
657 executor: Executor, field
676 let mut executor = self.executor; in replace() localVariable
677 store.swap_executor(&mut executor); in replace()
682 executor, in replace()
786 let executor = Executor::new(&engine)?; in make_fiber_unchecked() localVariable
850 executor, in make_fiber_unchecked()
|
| H A D | store.rs | 541 executor: Executor, field
776 executor: Executor::new(engine)?, in try_new()
2548 pub(crate) fn executor(&mut self) -> ExecutorRef<'_> { in executor() method
2549 match &mut self.executor { in executor()
2557 pub(crate) fn swap_executor(&mut self, executor: &mut Executor) { in swap_executor()
2558 mem::swap(&mut self.executor, executor); in swap_executor()
2562 match &self.executor { in unwinder()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/ |
| H A D | traphandlers.rs | 430 let result = CallThreadState::new(store.0, old_state).with(|_cx| match store.0.executor() { in catch_traps()
918 store.executor(), in unwind()
940 store.executor(), in unwind()
965 executor: ExecutorRef<'_>, in resume_to_exception_handler()
971 match executor { in resume_to_exception_handler()
|
| /wasmtime-44.0.1/examples/min-platform/embedding/src/ |
| H A D | wasi.rs | 424 let executor = Executor::new(); in block_on() localVariable
425 *EXECUTOR.0.borrow_mut() = Some(Executor(executor.0.clone())); in block_on()
449 if let Some(sleep_until) = executor.0.borrow().earliest_deadline() { in block_on()
456 for waker in executor.0.borrow_mut().ready_deadlines(clock.get()) { in block_on()
|
| /wasmtime-44.0.1/crates/test-programs/ |
| H A D | README.md | 38 Each test program executor spawns a fresh tokio runtime on a unique local
|
| /wasmtime-44.0.1/ |
| H A D | Cargo.lock | 1505 "futures-executor",
1529 name = "futures-executor"
|
| /wasmtime-44.0.1/supply-chain/ |
| H A D | audits.toml | 2135 notes = "Fairly significant chunk of unsafe code in the async executor core, but seems isolated to …
3112 [[audits.futures-executor]]
3118 [[audits.futures-executor]]
|