| /wasmtime-44.0.1/crates/wasi-common/src/tokio/ |
| H A D | file.rs | 14 pub struct File(crate::sync::file::File);
25 pub struct TcpListener(crate::sync::net::TcpListener);
36 pub struct TcpStream(crate::sync::net::TcpStream);
48 pub struct UnixListener(crate::sync::net::UnixListener);
61 pub struct UnixStream(crate::sync::net::UnixStream);
73 pub struct Stdin(crate::sync::stdio::Stdin);
76 Stdin(crate::sync::stdio::stdin()) in stdin()
79 pub struct Stdout(crate::sync::stdio::Stdout);
82 Stdout(crate::sync::stdio::stdout()) in stdout()
85 pub struct Stderr(crate::sync::stdio::Stderr);
[all …]
|
| H A D | dir.rs | 10 pub struct Dir(crate::sync::dir::Dir);
14 Dir(crate::sync::dir::Dir::from_cap_std(dir)) in from_cap_std()
37 crate::sync::dir::OpenResult::File(f) => { in open_file()
40 crate::sync::dir::OpenResult::Dir(d) => { in open_file()
|
| /wasmtime-44.0.1/tests/misc_testsuite/component-model/async/ |
| H A D | task-builtins.wast | 291 (core func $sync-to-sync
321 (import "" "sync-to-sync" (func $sync-to-sync (param i32)))
331 (func (export "sync-to-sync")
333 (call $sync-to-sync (i32.const 20))
370 (export "sync-to-sync" (func $sync-to-sync))
371 (export "sync-to-async" (func $sync-to-async))
372 (export "async-to-sync" (func $async-to-sync))
375 (func (export "sync-to-sync") async (canon lift (core func $m "sync-to-sync")))
383 (export "sync-to-sync" (func $b "sync-to-sync"))
384 (export "sync-to-async" (func $b "sync-to-async"))
[all …]
|
| /wasmtime-44.0.1/crates/wasmtime/src/ |
| H A D | sync_std.rs | 7 use once_cell::sync::OnceCell;
41 pub struct RwLock<T>(std::sync::RwLock<T>);
46 RwLock(std::sync::RwLock::new(val)) in new()
|
| H A D | lib.rs | 506 use sync_std as sync;
510 use sync_nostd as sync;
|
| /wasmtime-44.0.1/crates/wasi-common/src/sync/ |
| H A D | mod.rs | 93 self.stdin(Box::new(crate::sync::stdio::stdin())) in inherit_stdin()
96 self.stdout(Box::new(crate::sync::stdio::stdout())) in inherit_stdout()
99 self.stderr(Box::new(crate::sync::stdio::stderr())) in inherit_stderr()
109 let dir = Box::new(crate::sync::dir::Dir::from_cap_std(dir)); in preopened_dir()
|
| H A D | net.rs | 59 Socket::TcpListener(l) => Box::new(crate::sync::net::TcpListener::from_cap_std(l)), in from()
60 Socket::UnixListener(l) => Box::new(crate::sync::net::UnixListener::from_cap_std(l)), in from()
61 Socket::TcpStream(l) => Box::new(crate::sync::net::TcpStream::from_cap_std(l)), in from()
62 Socket::UnixStream(l) => Box::new(crate::sync::net::UnixStream::from_cap_std(l)), in from()
71 Socket::TcpListener(l) => Box::new(crate::sync::net::TcpListener::from_cap_std(l)), in from()
72 Socket::TcpStream(l) => Box::new(crate::sync::net::TcpStream::from_cap_std(l)), in from()
|
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | mod.rs | 455 let options = bindings::sync::LinkOptions::default(); in add_to_linker_sync()
462 options: &bindings::sync::LinkOptions, in add_to_linker_with_options_sync()
468 bindings::sync::filesystem::types::add_to_linker::<T, WasiFilesystem>(l, T::filesystem)?; in add_to_linker_with_options_sync()
469 bindings::sync::sockets::tcp::add_to_linker::<T, WasiSockets>(l, T::sockets)?; in add_to_linker_with_options_sync()
470 bindings::sync::sockets::udp::add_to_linker::<T, WasiSockets>(l, T::sockets)?; in add_to_linker_with_options_sync()
481 bindings::sync::io::poll::add_to_linker::<T, HasIo>(l, |t| t.ctx().table)?; in add_sync_wasi_io()
482 bindings::sync::io::streams::add_to_linker::<T, HasIo>(l, |t| t.ctx().table)?; in add_sync_wasi_io()
|
| H A D | poll.rs | 7 impl crate::p2::bindings::sync::io::poll::Host for ResourceTable {
13 impl crate::p2::bindings::sync::io::poll::HostPollable for ResourceTable {
|
| H A D | write_stream.rs | 4 use std::sync::{Arc, Mutex};
32 new_work: tokio::sync::Notify,
51 new_work: tokio::sync::Notify::new(), in new()
66 fn state(&self) -> std::sync::MutexGuard<'_, WorkerState> { in state()
|
| H A D | tcp.rs | 12 use std::sync::Arc;
13 use tokio::sync::Mutex;
346 fn try_lock_for_stream<T>(mutex: &Mutex<T>) -> Result<tokio::sync::MutexGuard<'_, T>, StreamError> { in try_lock_for_stream()
352 fn try_lock_for_socket<T>(mutex: &Mutex<T>) -> SocketResult<tokio::sync::MutexGuard<'_, T>> { in try_lock_for_socket()
|
| /wasmtime-44.0.1/crates/wasi-common/ |
| H A D | Cargo.toml | 31 # Optional, enabled by sync feature:
67 default = ["trace_log", "wasmtime", "sync"]
82 sync = [
90 "sync",
|
| /wasmtime-44.0.1/crates/wasi-http/src/p2/ |
| H A D | bindings.rs | 48 pub mod sync { module
59 "wasi:io": wasmtime_wasi::p2::bindings::sync::io,
|
| H A D | body.rs | 12 use std::{pin::Pin, sync::Arc, time::Duration};
13 use tokio::sync::{mpsc, oneshot};
388 written: Arc<std::sync::atomic::AtomicU64>,
395 written: Arc::new(std::sync::atomic::AtomicU64::new(0)), in new()
401 self.written.load(std::sync::atomic::Ordering::Relaxed) in written()
410 .fetch_add(len, std::sync::atomic::Ordering::Relaxed); in update()
421 finish_sender: Option<tokio::sync::oneshot::Sender<FinishMessage>>,
436 use tokio::sync::oneshot::error::RecvError; in new()
|
| H A D | mod.rs | 544 bindings::sync::http::outgoing_handler::add_to_linker::<_, WasiHttp>(l, T::http)?; in add_only_http_to_linker_sync()
545 bindings::sync::http::types::add_to_linker::<_, WasiHttp>(l, &options.into(), T::http)?; in add_only_http_to_linker_sync()
624 let connector = tokio_rustls::TlsConnector::from(std::sync::Arc::new(config));
|
| /wasmtime-44.0.1/crates/wasi-common/src/ |
| H A D | pipe.rs | 14 use std::sync::{Arc, RwLock};
72 fn borrow(&self) -> std::sync::RwLockWriteGuard<'_, R> { in borrow()
174 fn borrow(&self) -> std::sync::RwLockWriteGuard<'_, W> { in borrow()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/ |
| H A D | provenance.rs | 49 use core::sync::atomic::AtomicUsize;
215 unsafe impl VmSafe for core::sync::atomic::AtomicU64 {}
|
| /wasmtime-44.0.1/crates/fuzzing/src/ |
| H A D | lib.rs | 30 static INIT: std::sync::Once = std::sync::Once::new(); in init_fuzzing()
|
| /wasmtime-44.0.1/crates/wasi-common/src/sync/sched/ |
| H A D | windows.rs | 13 use std::sync::mpsc::{self, Receiver, RecvTimeoutError, Sender, TryRecvError};
14 use std::sync::{LazyLock, Mutex};
124 f.as_any().is::<crate::sync::stdio::Stdin>() in wasi_file_is_stdin()
|
| /wasmtime-44.0.1/crates/wasi/tests/all/p2/ |
| H A D | mod.rs | 3 mod sync; module
|
| /wasmtime-44.0.1/crates/wasi/src/cli/ |
| H A D | worker_thread_stdin.rs | 31 use std::sync::{Condvar, Mutex, OnceLock};
34 use tokio::sync::Notify;
35 use tokio::sync::futures::Notified;
|
| /wasmtime-44.0.1/crates/jit-debug/src/ |
| H A D | gdb_jit_int.rs | 39 use std::sync::{Mutex, MutexGuard};
70 use core::sync::atomic::{AtomicBool, Ordering};
|
| /wasmtime-44.0.1/crates/fuzzing/tests/oom/ |
| H A D | arc.rs | 3 use std::sync::Arc;
|
| /wasmtime-44.0.1/crates/wasi-http/src/p3/host/ |
| H A D | handler.rs | 8 use std::sync::Arc;
9 use tokio::sync::oneshot;
|
| /wasmtime-44.0.1/crates/wizer/tests/regex-test/src/ |
| H A D | lib.rs | 2 use std::sync::LazyLock;
|