Searched refs:spawn_blocking (Results 1 – 5 of 5) sorted by relevance
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | ip_name_lookup.rs | 4 use crate::runtime::{AbortOnDropJoinHandle, spawn_blocking};
35 let task = spawn_blocking(move || blocking_resolve(&host)); in resolve_addresses()
|
| H A D | filesystem.rs | 127 .spawn_blocking(move |f| Self::blocking_read(f, p, size)), in read()
194 .spawn_blocking(move |f| Self::blocking_read(f, p, DEFAULT_READ_SIZE)), in ready()
299 .spawn_blocking(move |f| Self::blocking_write(f, buf, m)), in write()
|
| /wasmtime-44.0.1/crates/wasi/src/ |
| H A D | runtime.rs | 95 pub fn spawn_blocking<F, R>(f: F) -> AbortOnDropJoinHandle<R> in spawn_blocking() function
100 let j = with_ambient_tokio_runtime(|| tokio::task::spawn_blocking(f)); in spawn_blocking()
|
| H A D | filesystem.rs | 2 use crate::runtime::{AbortOnDropJoinHandle, spawn_blocking};
716 None => self.spawn_blocking(body).await, in run_blocking()
720 pub(crate) fn spawn_blocking<F, R>(&self, body: F) -> AbortOnDropJoinHandle<R> in spawn_blocking() method
726 spawn_blocking(move || body(&f)) in spawn_blocking()
832 spawn_blocking(move || body(&d)).await in run_blocking()
|
| /wasmtime-44.0.1/crates/wasi/src/p3/filesystem/ |
| H A D | host.rs | 18 use tokio::task::{JoinHandle, spawn_blocking};
205 spawn_blocking(move || { in poll_produce()
282 task: spawn_blocking(move || { in new()
463 spawn_blocking(move || location.write(&file, &buf).map(|n| (buf, n))) in poll_consume()
|