| /wasmtime-44.0.1/tests/all/guest_debug/ |
| H A D | mod.rs | 61 fn spawn( in spawn() method
75 let mut child = cmd.spawn()?; in spawn()
174 let mut wt = WasmtimeWithGdbstub::spawn( in guest_debug_cli_fib_breakpoint()
211 let mut wt = WasmtimeWithGdbstub::spawn( in guest_debug_cli_fib_step()
271 let mut wt = WasmtimeWithGdbstub::spawn( in guest_debug_serve_requests()
284 let lldb_handle = std::thread::spawn(move || lldb_with_gdbstub_script(gdb_port, "c\n")); in guest_debug_serve_requests()
328 let mut wt = WasmtimeWithGdbstub::spawn( in guest_debug_serve_breakpoint()
343 let lldb_handle = std::thread::spawn(move || { in guest_debug_serve_breakpoint()
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p3_cli_hello_stdout_post_return.rs | 10 wit_bindgen::spawn(async move { in run()
14 wit_bindgen::spawn(async move { in run()
|
| H A D | p3_api_proxy.rs | 4 use wit_bindgen::spawn;
39 spawn(async { in handle()
|
| H A D | async_yield_post_return_callee.rs | 21 async_support::spawn(async move { in run()
|
| H A D | async_yield_post_return_caller.rs | 24 async_support::spawn(async move { in run()
|
| H A D | async_unit_stream_callee.rs | 22 wit_bindgen::spawn(async move { in run()
|
| H A D | async_borrowing_callee.rs | 21 wit_bindgen::spawn(async move { in foo()
|
| /wasmtime-44.0.1/examples/tokio/ |
| H A D | main.rs | 21 let join1 = tokio::task::spawn(async move { run_wasm(inputs1).await }); in main()
22 let join2 = tokio::task::spawn(async move { in main()
26 let join3 = tokio::task::spawn(async move { in main()
|
| /wasmtime-44.0.1/tests/all/ |
| H A D | piped_tests.rs | 15 .spawn()?; in run_wasmtime_piped()
24 .spawn()?; in run_wasmtime_piped()
|
| H A D | cli_tests.rs | 543 .spawn()?; in run_cwasm_from_stdin()
997 .spawn()?; in preview2_stdin()
999 std::thread::spawn(move || { in preview2_stdin()
1015 .spawn()?; in preview2_stdin()
1156 .spawn()?; in p2_cli_stdin_empty()
1177 .spawn()?; in p2_cli_stdin()
1198 .spawn()?; in p2_cli_splice_stdin()
1409 .spawn()?; in p2_cli_stdio_write_flushes()
1531 Self::spawn(&mut cmd) in new()
2871 .spawn() in p3_cli_read_stdin()
[all …]
|
| H A D | iloop.rs | 84 let thread = std::thread::spawn(move || { in loop_interrupt_from_afar()
121 let thread = std::thread::spawn(move || { in function_interrupt_from_afar()
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p2/ |
| H A D | io.rs | 36 pub(crate) fn spawn<F>(fut: F) -> Self in spawn() function
41 wasmtime_wasi::runtime::spawn(async move { fut.await }), in spawn()
300 *self = WriteState::Writing(wasmtime_wasi::runtime::spawn(async move { in write()
320 *self = WriteState::Flushing(wasmtime_wasi::runtime::spawn(async move { in flush()
331 *self = WriteState::Flushing(wasmtime_wasi::runtime::spawn(async move { in flush()
366 *self = WriteState::Closing(wasmtime_wasi::runtime::spawn(async move { in close()
373 *self = WriteState::Closing(wasmtime_wasi::runtime::spawn(async move { in close()
|
| /wasmtime-44.0.1/examples/ |
| H A D | threads.rs | 35 thread::spawn(move || { in main()
64 let child = thread::spawn(move || run.call(&mut store, ())); in run()
|
| H A D | interrupt.rs | 21 std::thread::spawn(move || { in main()
|
| /wasmtime-44.0.1/crates/wasi-http/tests/all/ |
| H A D | http_server.rs | 44 let thread = std::thread::spawn(|| -> Result<_> { in new()
57 let worker = std::thread::spawn(move || { in new()
145 tokio::task::spawn(fut); in execute()
|
| /wasmtime-44.0.1/crates/wasi-threads/src/ |
| H A D | lib.rs | 34 pub fn spawn(&self, host: T, thread_start_arg: i32) -> Result<i32> { in spawn() method
69 builder.spawn(move || { in spawn()
159 match ctx.spawn(host, start_arg) { in add_to_linker()
|
| /wasmtime-44.0.1/benches/ |
| H A D | thread_eager_init.rs | 67 thread::spawn(move || duration_of_call(&engine, &module)) in lazy_thread_instantiate()
76 thread::spawn(move || { in eager_thread_instantiate()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/ |
| H A D | parking_spot.rs | 334 let thread1 = s.spawn(|| { in atomic_wait_notify()
341 let thread2 = s.spawn(|| { in atomic_wait_notify()
349 let thread3 = s.spawn(|| { in atomic_wait_notify()
453 threads.push(s.spawn(move || test.run())); in run_parking_test()
602 let thread = s.spawn(|| { in wait_with_timeout()
616 threads.push(s.spawn(|| { in wait_with_timeout()
|
| /wasmtime-44.0.1/cranelift/isle/isle/tests/ |
| H A D | run_tests.rs | 60 .spawn() in build_and_link_isle()
76 .spawn() in run_run()
|
| /wasmtime-44.0.1/ci/ |
| H A D | build-test-matrix.js | 8 const { spawn } = require('node:child_process');
167 const child = spawn("cargo", ["metadata"], { encoding: "utf8" });
|
| /wasmtime-44.0.1/crates/wasi/src/ |
| H A D | runtime.rs | 86 pub fn spawn<F>(f: F) -> AbortOnDropJoinHandle<F::Output> in spawn() function
91 let j = with_ambient_tokio_runtime(|| tokio::task::spawn(f)); in spawn()
|
| /wasmtime-44.0.1/crates/wasi-http/src/p2/ |
| H A D | mod.rs | 559 let handle = wasmtime_wasi::runtime::spawn(async move { in default_send_request()
647 let worker = wasmtime_wasi::runtime::spawn(async move {
668 let worker = wasmtime_wasi::runtime::spawn(async move {
|
| /wasmtime-44.0.1/cranelift/filetests/src/ |
| H A D | concurrent.rs | 119 .spawn(move || { in heartbeat_thread()
136 .spawn(move || { in worker_thread()
|
| /wasmtime-44.0.1/crates/wasmtime/src/profiling_agent/ |
| H A D | pulley.rs | 120 agent.sampling_thread = Some(thread::spawn(move || sampling_thread(&state, tx))); in new()
122 agent.recording_thread = Some(thread::spawn(move || recording_thread(&state, rx))); in new()
|
| /wasmtime-44.0.1/crates/wasmtime/tests/ |
| H A D | unload-engine.rs | 14 std::thread::spawn(|| { in test_unload_engine()
|