Home
last modified time | relevance | path

Searched refs:Blocking (Results 1 – 25 of 35) sorted by relevance

12

/external/rust/crates/tokio/tests/support/
Dmock_pool.rs15 pub(crate) struct Blocking<T> { struct
19 pub(crate) fn run<F, R>(f: F) -> Blocking<R> in run() argument
31 Blocking { rx } in run()
34 impl<T> Future for Blocking<T> { implementation
/external/rust/crates/tokio/src/io/
Dblocking.rs16 pub(crate) struct Blocking<T> { struct
34 Busy(sys::Blocking<(io::Result<usize>, Buf, T)>), argument
38 impl<T> Blocking<T> { impl
39 pub(crate) fn new(inner: T) -> Blocking<T> {
40 Blocking {
49 impl<T> AsyncRead for Blocking<T> implementation
100 impl<T> AsyncWrite for Blocking<T> implementation
Dstdin.rs1 use crate::io::blocking::Blocking;
30 std: Blocking<std::io::Stdin>,
46 std: Blocking::new(std),
Dstderr.rs1 use crate::io::blocking::Blocking;
39 std: SplitByUtf8BoundaryIfWindows<Blocking<std::io::Stderr>>,
71 std: SplitByUtf8BoundaryIfWindows::new(Blocking::new(std)),
Dstdout.rs1 use crate::io::blocking::Blocking;
38 std: SplitByUtf8BoundaryIfWindows<Blocking<std::io::Stdout>>,
70 std: SplitByUtf8BoundaryIfWindows::new(Blocking::new(std)),
Dmod.rs265 pub(crate) use crate::blocking::JoinHandle as Blocking;
/external/rust/crates/tokio/src/net/
Daddr.rs168 MaybeReady(sealed::State::Blocking(spawn_blocking(move || {
205 MaybeReady(sealed::State::Blocking(spawn_blocking(move || {
273 Blocking(JoinHandle<io::Result<vec::IntoIter<SocketAddr>>>),
292 State::Blocking(ref mut rx) => {
/external/llvm-project/compiler-rt/lib/scudo/standalone/
Dlinux.cpp151 bool getRandom(void *Buffer, uptr Length, UNUSED bool Blocking) { in getRandom() argument
161 syscall(SYS_getrandom, Buffer, Length, Blocking ? 0 : GRND_NONBLOCK); in getRandom()
Dcommon.h141 bool getRandom(void *Buffer, uptr Length, bool Blocking = false);
Dfuchsia.cpp175 bool getRandom(void *Buffer, uptr Length, UNUSED bool Blocking) { in getRandom() argument
/external/perfetto/src/profiling/memory/
Dscoped_spinlock.cc49 for (size_t attempt = 1; mode == Mode::Blocking || in LockSlow()
Dscoped_spinlock.h46 Blocking enumerator
Dshared_ring_buffer_unittest.cc167 auto lock = wr.AcquireLock(ScopedSpinlock::Mode::Blocking); in TEST()
/external/scudo/standalone/
Dlinux.cpp190 bool getRandom(void *Buffer, uptr Length, UNUSED bool Blocking) { in getRandom() argument
200 syscall(SYS_getrandom, Buffer, Length, Blocking ? 0 : GRND_NONBLOCK); in getRandom()
Dcommon.h141 bool getRandom(void *Buffer, uptr Length, bool Blocking = false);
Dfuchsia.cpp186 bool getRandom(void *Buffer, uptr Length, UNUSED bool Blocking) { in getRandom() argument
/external/eigen/doc/
DTopicLinearAlgebraDecompositions.dox39 <td>Blocking, Implicit MT</td>
63 <td>Blocking</td>
99 <td>Blocking</td>
248 <dt><b>Blocking</b></dt>
/external/rust/crates/tokio/src/fs/
Dmod.rs126 pub(crate) use crate::blocking::JoinHandle as Blocking;
Dread_dir.rs48 Pending(sys::Blocking<(Option<io::Result<std::fs::DirEntry>>, std::fs::ReadDir)>),
/external/swiftshader/third_party/llvm-10.0/llvm/lib/Target/SystemZ/
DSystemZSchedule.td56 def VecFPd : SchedWrite; // Blocking BFP div/sqrt unit.
/external/llvm-project/llvm/lib/Target/SystemZ/
DSystemZSchedule.td56 def VecFPd : SchedWrite; // Blocking BFP div/sqrt unit.
/external/python/cpython3/Doc/library/
Dasyncio-dev.rst123 Running Blocking Code
126 Blocking (CPU-bound) code should not be called directly. For example,
/external/tensorflow/tensorflow/compiler/xla/pjrt/distributed/
Dprotocol.proto116 // Blocking enumeration of devices, used by the GPU backend only.
/external/rust/crates/tokio/tests/
Dfs_file_mocked.rs49 pub(crate) use crate::support::mock_pool::{run, Blocking};
55 pub(crate) use crate::support::mock_pool::{run, Blocking};
/external/kotlinx.coroutines/ui/
Dcoroutines-guide-ui.md41 * [Blocking operations](#blocking-operations)
44 * [Blocking operations](#blocking-operations)
344 ## Blocking operations
463 ### Blocking operations

12