Home
last modified time | relevance | path

Searched refs:MutexGuard (Results 1 – 9 of 9) sorted by relevance

/wasmtime-44.0.1/examples/min-platform/embedding/src/
H A Dallocator.rs142 Some(MutexGuard { lock: self }) in try_lock()
147 struct MutexGuard<'a, T> { struct
151 impl<T> Deref for MutexGuard<'_, T> { argument
159 impl<T> DerefMut for MutexGuard<'_, T> { implementation
165 impl<T> Drop for MutexGuard<'_, T> { implementation
/wasmtime-44.0.1/crates/wasi-tls/src/p3/util/
H A Dshared.rs2 use std::sync::{Arc, Mutex, MutexGuard};
14 pub(crate) fn lock(&self) -> MutexGuard<'_, IO> { in lock()
/wasmtime-44.0.1/crates/test-programs/src/bin/
H A Dp2_api_reactor.rs1 use std::sync::{Mutex, MutexGuard};
13 fn state() -> MutexGuard<'static, Vec<String>> { in state()
/wasmtime-44.0.1/crates/jit-debug/src/
H A Dgdb_jit_int.rs39 use std::sync::{Mutex, MutexGuard};
54 pub struct LockGuard<'a>(MutexGuard<'a, ()>);
/wasmtime-44.0.1/crates/wasi/src/p2/
H A Dtcp.rs346 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()
H A Dwrite_stream.rs66 fn state(&self) -> std::sync::MutexGuard<'_, WorkerState> { in state()
/wasmtime-44.0.1/crates/wasi-tls/src/p2/
H A Dio.rs219 async fn lock(&self) -> tokio::sync::MutexGuard<'_, WriteState<IO>> { in lock()
223 fn try_lock(&self) -> Result<tokio::sync::MutexGuard<'_, WriteState<IO>>, StreamError> { in try_lock()
/wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/instance/allocator/
H A Dpooling.rs63 use std::sync::{Mutex, MutexGuard};
498 fn flush_decommit_queue(&self, mut locked_queue: MutexGuard<'_, DecommitQueue>) -> bool { in flush_decommit_queue()
/wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/
H A Dfutures_and_streams.rs35 use std::sync::{Arc, Mutex, MutexGuard};
4779 fn try_lock(&self) -> Result<MutexGuard<'_, Option<T>>> { in try_lock()