| /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 | base_subprocess.py | 14 waiter=None, extra=None, **kwargs): argument
156 async def _connect_pipes(self, waiter): 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
752 def __init__(self, loop, sock, protocol, waiter=None, argument
990 waiter=None, extra=None): argument
|
| D | unix_events.py | 177 def _make_read_pipe_transport(self, pipe, protocol, waiter=None, argument
181 def _make_write_pipe_transport(self, pipe, protocol, waiter=None, argument
440 def __init__(self, loop, pipe, protocol, waiter=None, extra=None): argument
575 def __init__(self, loop, pipe, protocol, waiter=None, extra=None): argument
|
| D | base_events.py | 458 def _make_socket_transport(self, sock, protocol, waiter=None, *, argument
464 self, rawsock, protocol, sslcontext, waiter=None, argument
473 address=None, waiter=None, extra=None): argument
477 def _make_read_pipe_transport(self, pipe, protocol, waiter=None, argument
482 def _make_write_pipe_transport(self, pipe, protocol, waiter=None, 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/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | CancelledAwaitStressTest.kt | 21 val waiter = launch(start = CoroutineStart.UNDISPATCHED) { in <lambda>() constant
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 1152 abstract void putThread(Waiter waiter, Thread newValue); in putThread()
1155 abstract void putNext(Waiter waiter, Waiter newValue); in putNext()
1222 void putThread(Waiter waiter, Thread newValue) { in putThread()
1227 void putNext(Waiter waiter, Waiter newValue) { in putNext()
1272 void putThread(Waiter waiter, Thread newValue) { in putThread()
1277 void putNext(Waiter waiter, Waiter newValue) { in putNext()
1305 void putThread(Waiter waiter, Thread newValue) { in putThread()
1310 void putNext(Waiter waiter, Waiter newValue) { in putNext()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 1153 abstract void putThread(Waiter waiter, Thread newValue); in putThread()
1156 abstract void putNext(Waiter waiter, Waiter newValue); in putNext()
1223 void putThread(Waiter waiter, Thread newValue) { in putThread()
1228 void putNext(Waiter waiter, Waiter newValue) { in putNext()
1273 void putThread(Waiter waiter, Thread newValue) { in putThread()
1278 void putNext(Waiter waiter, Waiter newValue) { in putNext()
1306 void putThread(Waiter waiter, Thread newValue) { in putThread()
1311 void putNext(Waiter waiter, 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/kotlinx.coroutines/kotlinx-coroutines-core/common/src/sync/ |
| D | Mutex.kt | 191 val waiter = LockCont(owner, cont) in toString() constant
312 val waiter = state.removeFirstOrNull() in toString() constant
|
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| D | WaitingThread.java | 65 private Thread waiter; field in WaitingThread
|
| /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/ltp/testcases/kernel/ipc/semaphore/ |
| D | sem02.c | 124 void *waiter(void *foo) in waiter() function
|
| /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/linux-kselftest/tools/testing/selftests/futex/functional/ |
| D | futex_requeue_pi_signal_restart.c | 122 pthread_t waiter; in main() local
|
| /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/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_broadcast/ |
| D | 4-2.c | 124 static void *waiter(void *arg LTP_ATTRIBUTE_UNUSED) in waiter() function
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_signal/ |
| D | 4-2.c | 158 void *waiter(void *arg LTP_ATTRIBUTE_UNUSED) in waiter() function
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_timedwait/ |
| D | 4-3.c | 133 void *waiter(void *arg) in waiter() function
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_wait/ |
| D | 4-1.c | 160 void *waiter(void *arg LTP_ATTRIBUTE_UNUSED) in waiter() function
|
| /external/dnsmasq/src/ |
| D | log.c | 335 struct timespec waiter; in my_syslog() local
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | run_handler.cc | 117 void WaitOnWaiter(Waiter* waiter, Waiter* queue_head, mutex* mutex, in WaitOnWaiter()
281 thread_local Waiter waiter; in WaitForWork() local
302 void SetWaiter(uint64 version, Waiter* waiter, mutex* mutex) { in SetWaiter()
786 thread_local Waiter waiter; in WaitForWorkInSubThreadPool() local
|