| /external/grpc-grpc/src/ruby/qps/ |
| D | client.rb | 103 def wait_to_issue(waiter) argument
109 def unary_ping_ponger(req, stub, config,waiter) argument
117 def streaming_ping_ponger(req, stub, config, waiter) argument
|
| /external/python/cpython3/Lib/asyncio/ |
| D | proactor_events.py | 50 def __init__(self, loop, sock, protocol, waiter=None, argument
181 def __init__(self, loop, sock, protocol, waiter=None, argument
456 waiter=None, extra=None): argument
600 def __init__(self, loop, sock, protocol, waiter=None, argument
634 def _make_socket_transport(self, sock, protocol, waiter=None, argument
640 self, rawsock, protocol, sslcontext, waiter=None, argument
653 address=None, waiter=None, extra=None): argument
657 def _make_duplex_pipe_transport(self, sock, protocol, waiter=None, argument
662 def _make_read_pipe_transport(self, sock, protocol, waiter=None, argument
666 def _make_write_pipe_transport(self, sock, protocol, waiter=None, argument
|
| D | selector_events.py | 64 def _make_socket_transport(self, sock, protocol, waiter=None, *, argument
70 self, rawsock, protocol, sslcontext, waiter=None, argument
83 address=None, waiter=None, extra=None): argument
762 def __init__(self, loop, sock, protocol, waiter=None, argument
1000 waiter=None, extra=None): argument
|
| D | base_subprocess.py | 14 waiter=None, extra=None, **kwargs): argument
156 async def _connect_pipes(self, waiter): argument
|
| /external/igt-gpu-tools/tests/i915/ |
| D | gem_sync.c | 772 struct waiter { struct
785 static void *waiter(void *arg) in waiter() argument
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/executor/ |
| D | mpmcqueue.cc | 168 void InfLenFIFOQueue::PushWaiter(Waiter* waiter) { in PushWaiter()
175 void InfLenFIFOQueue::RemoveWaiter(Waiter* waiter) { in RemoveWaiter()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | CancelledAwaitStressTest.kt | 21 val waiter = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>() constant
|
| /external/openscreen/platform/impl/ |
| D | socket_handle_waiter_posix_unittest.cc | 50 TestingSocketHandleWaiter waiter; in TEST() local
71 TestingSocketHandleWaiter waiter; in TEST() local
|
| D | udp_socket_reader_posix.cc | 16 UdpSocketReaderPosix::UdpSocketReaderPosix(SocketHandleWaiter* waiter) in UdpSocketReaderPosix()
|
| D | tls_data_router_posix.cc | 17 SocketHandleWaiter* waiter, in TlsDataRouterPosix()
|
| /external/crosvm/cros_async/src/ |
| D | sync.rs | 9 mod waiter; module
|
| /external/libchromeos-rs/src/ |
| D | sync.rs | 9 mod waiter; module
|
| /external/libchrome/base/synchronization/ |
| D | waitable_event_posix.cc | 331 Waiter* waiter) { in EnqueueMany()
414 void WaitableEvent::Enqueue(Waiter* waiter) { in Enqueue()
422 bool WaitableEvent::WaitableEventKernel::Dequeue(Waiter* waiter, void* tag) { in Dequeue()
|
| D | waitable_event_perftest.cc | 67 SignalerThread(TraceWaitableEvent* waiter, TraceWaitableEvent* signaler) in SignalerThread()
130 TraceWaitableEvent waiter(kSamples); in TEST() local
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 1227 abstract void putThread(Waiter waiter, Thread newValue); in putThread()
1230 abstract void putNext(Waiter waiter, Waiter newValue); in putNext()
1297 void putThread(Waiter waiter, Thread newValue) { in putThread()
1302 void putNext(Waiter waiter, Waiter newValue) { in putNext()
1347 void putThread(Waiter waiter, Thread newValue) { in putThread()
1352 void putNext(Waiter waiter, Waiter newValue) { in putNext()
1380 void putThread(Waiter waiter, Thread newValue) { in putThread()
1385 void putNext(Waiter waiter, Waiter newValue) { in putNext()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 1229 abstract void putThread(Waiter waiter, Thread newValue); in putThread()
1232 abstract void putNext(Waiter waiter, Waiter newValue); in putNext()
1299 void putThread(Waiter waiter, Thread newValue) { in putThread()
1304 void putNext(Waiter waiter, Waiter newValue) { in putNext()
1349 void putThread(Waiter waiter, Thread newValue) { in putThread()
1354 void putNext(Waiter waiter, Waiter newValue) { in putNext()
1382 void putThread(Waiter waiter, Thread newValue) { in putThread()
1387 void putNext(Waiter waiter, Waiter newValue) { in putNext()
|
| /external/rust/crates/tokio/src/sync/ |
| D | notify.rs | 153 waiter: UnsafeCell<Waiter>, field
413 let waiter = unsafe { waiter.as_mut() }; in notify_waiters() localVariable
485 let mut waiter = waiters.pop_back().unwrap(); in notify_locked() localVariable
488 let waiter = unsafe { waiter.as_mut() }; in notify_locked() localVariable
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/sync/ |
| D | Mutex.kt | 194 val waiter = LockCont(owner, cont) in toString() constant
316 val waiter = state.removeFirstOrNull() in toString() constant
|
| /external/glide/library/src/main/java/com/bumptech/glide/request/ |
| D | RequestFutureTarget.java | 46 private final Waiter waiter; field in RequestFutureTarget
62 …Target(Handler mainHandler, int width, int height, boolean assertBackgroundThread, Waiter waiter) { in RequestFutureTarget()
|
| /external/rust/crates/futures/tests/ |
| D | mutex.rs | 26 let mut waiter = mutex.lock(); in mutex_wakes_waiters() localVariable
|
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| D | WaitingThread.java | 65 private Thread waiter; field in WaitingThread
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | NonBlockingThreadPool.h | 141 EventCount::Waiter* waiter = &waiters_[thread_id]; in WorkerLoop() local
195 bool WaitForWork(EventCount::Waiter* waiter, Task* t) { in WaitForWork()
|
| /external/ltp/testcases/kernel/ipc/semaphore/ |
| D | sem02.c | 124 void *waiter(void *foo) in waiter() function
|
| /external/dng_sdk/source/ |
| D | dng_pthread.cpp | 59 struct waiter { struct
60 struct waiter *prev;
61 struct waiter *next;
62 HANDLE semaphore;
63 bool chosen_by_signal;
|
| /external/linux-kselftest/tools/testing/selftests/futex/functional/ |
| D | futex_requeue_pi_signal_restart.c | 122 pthread_t waiter; in main() local
|