| /external/musl/src/thread/ |
| D | pthread_cond_timedwait.c | 25 struct waiter { struct
26 struct waiter *prev, *next; argument
27 volatile int state, barrier;
28 volatile int *notify;
|
| /external/cronet/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | waiter_test.cc | 79 TypeParam waiter; in TYPED_TEST_P() local
98 TypeParam waiter; in TYPED_TEST_P() local
116 TypeParam waiter; in TYPED_TEST_P() local
133 TypeParam waiter; in TYPED_TEST_P() local
143 TypeParam waiter; in TYPED_TEST_P() local
|
| /external/angle/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | waiter_test.cc | 79 TypeParam waiter; in TYPED_TEST_P() local
98 TypeParam waiter; in TYPED_TEST_P() local
116 TypeParam waiter; in TYPED_TEST_P() local
133 TypeParam waiter; in TYPED_TEST_P() local
143 TypeParam waiter; in TYPED_TEST_P() local
|
| /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/igt-gpu-tools/tests/i915/ |
| D | gem_sync.c | 772 struct waiter { struct
785 static void *waiter(void *arg) in 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
459 waiter=None, extra=None): argument
603 def __init__(self, loop, sock, protocol, waiter=None, argument
637 def _make_socket_transport(self, sock, protocol, waiter=None, argument
643 self, rawsock, protocol, sslcontext, waiter=None, argument
656 address=None, waiter=None, extra=None): argument
660 def _make_duplex_pipe_transport(self, sock, protocol, waiter=None, argument
665 def _make_read_pipe_transport(self, sock, protocol, waiter=None, argument
669 def _make_write_pipe_transport(self, sock, protocol, waiter=None, 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
|
| /external/cronet/base/synchronization/ |
| D | waitable_event_posix.cc | 323 Waiter* waiter) NO_THREAD_SAFETY_ANALYSIS { in EnqueueMany()
405 void WaitableEvent::Enqueue(Waiter* waiter) { in Enqueue()
413 bool WaitableEvent::WaitableEventKernel::Dequeue(Waiter* waiter, void* tag) { in Dequeue()
|
| D | waitable_event_perftest.cc | 89 SignalerThread(TraceWaitableEvent* waiter, TraceWaitableEvent* signaler) in SignalerThread()
153 TraceWaitableEvent waiter; in TEST() local
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 1284 abstract void putThread(Waiter waiter, Thread newValue); in putThread()
1287 abstract void putNext(Waiter waiter, @CheckForNull Waiter newValue); in putNext()
1363 void putThread(Waiter waiter, Thread newValue) { in putThread()
1368 void putNext(Waiter waiter, @CheckForNull Waiter newValue) { in putNext()
1403 Waiter waiter = future.waiters; in gasWaiters() local
1443 void putThread(Waiter waiter, Thread newValue) { in putThread()
1448 void putNext(Waiter waiter, @CheckForNull Waiter newValue) { in putNext()
1489 void putThread(Waiter waiter, Thread newValue) { in putThread()
1494 void putNext(Waiter waiter, @CheckForNull Waiter newValue) { in putNext()
|
| /external/crosvm/cros_async/src/ |
| D | sync.rs | 8 mod waiter; module
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 1284 abstract void putThread(Waiter waiter, Thread newValue); in putThread()
1287 abstract void putNext(Waiter waiter, @CheckForNull Waiter newValue); in putNext()
1363 void putThread(Waiter waiter, Thread newValue) { in putThread()
1368 void putNext(Waiter waiter, @CheckForNull Waiter newValue) { in putNext()
1427 void putThread(Waiter waiter, Thread newValue) { in putThread()
1432 void putNext(Waiter waiter, @CheckForNull Waiter newValue) { in putNext()
1473 void putThread(Waiter waiter, Thread newValue) { in putThread()
1478 void putNext(Waiter waiter, @CheckForNull Waiter newValue) { in putNext()
|
| /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/libchromeos-rs/src/ |
| D | sync.rs | 9 mod waiter; module
|
| /external/rust/crates/tokio/src/sync/ |
| D | notify.rs | 253 waiter: UnsafeCell<Waiter>, field
527 let waiter = unsafe { waiter.as_mut() }; in notify_waiters() localVariable
595 let mut waiter = waiters.pop_back().unwrap(); in notify_locked() localVariable
598 let waiter = unsafe { waiter.as_mut() }; in notify_locked() localVariable
|
| /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/cronet/net/http/ |
| D | http_stream_factory_unittest.cc | 762 StreamRequestWaiter waiter; in TEST_F() local
816 StreamRequestWaiter waiter; in TEST_F() local
909 StreamRequestWaiter waiter; in TEST_F() local
1122 StreamRequestWaiter waiter; in TEST_F() local
1191 StreamRequestWaiter waiter; in TEST_F() local
1246 StreamRequestWaiter waiter; in TEST_F() local
1279 StreamRequestWaiter waiter; in TEST_F() local
1327 StreamRequestWaiter waiter; in TEST_F() local
1376 StreamRequestWaiter waiter; in TEST_F() local
1416 StreamRequestWaiter waiter; in TEST_F() local
[all …]
|
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| D | WaitingThread.java | 65 private Thread waiter; field in WaitingThread
|
| /external/rust/crates/futures/tests/ |
| D | lock_mutex.rs | 27 let mut waiter = mutex.lock(); in mutex_wakes_waiters() localVariable
|
| /external/cronet/net/socket/ |
| D | websocket_endpoint_lock_manager_unittest.cc | 101 FakeWaiter waiter; in TEST_F() local
183 FakeWaiter waiter; in TEST_F() local
|
| /external/linux-kselftest/tools/testing/selftests/futex/functional/ |
| D | futex_requeue.c | 43 pthread_t waiter[10]; in main() local
|
| D | futex_waitv.c | 62 pthread_t waiter; in main() local
|