| /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 | 28 def __init__(self, loop, sock, protocol, waiter=None, argument
160 def __init__(self, loop, sock, protocol, waiter=None, argument
447 def __init__(self, loop, sock, protocol, waiter=None, argument
493 def _make_socket_transport(self, sock, protocol, waiter=None, argument
499 self, rawsock, protocol, sslcontext, waiter=None, argument
511 def _make_duplex_pipe_transport(self, sock, protocol, waiter=None, argument
516 def _make_read_pipe_transport(self, sock, protocol, waiter=None, argument
520 def _make_write_pipe_transport(self, sock, protocol, waiter=None, argument
|
| D | base_subprocess.py | 14 waiter=None, extra=None, **kwargs): argument
157 async def _connect_pipes(self, waiter): argument
|
| D | selector_events.py | 58 def _make_socket_transport(self, sock, protocol, waiter=None, *, argument
64 self, rawsock, protocol, sslcontext, waiter=None, argument
77 address=None, waiter=None, extra=None): argument
713 def __init__(self, loop, sock, protocol, waiter=None, argument
935 waiter=None, extra=None): argument
|
| D | unix_events.py | 174 def _make_read_pipe_transport(self, pipe, protocol, waiter=None, argument
178 def _make_write_pipe_transport(self, pipe, protocol, waiter=None, argument
426 def __init__(self, loop, pipe, protocol, waiter=None, extra=None): argument
551 def __init__(self, loop, pipe, protocol, waiter=None, extra=None): argument
|
| D | base_events.py | 430 def _make_socket_transport(self, sock, protocol, waiter=None, *, argument
436 self, rawsock, protocol, sslcontext, waiter=None, argument
445 address=None, waiter=None, extra=None): argument
449 def _make_read_pipe_transport(self, pipe, protocol, waiter=None, argument
454 def _make_write_pipe_transport(self, pipe, protocol, waiter=None, argument
|
| /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/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 | 126 pthread_t waiter; in main() local
|
| D | futex_requeue_pi.c | 287 pthread_t waiter[THREAD_MAX], waker, blocker; in unit_test() 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) in waiter() function
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_signal/ |
| D | 4-2.c | 158 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) 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/dnsmasq/src/ |
| D | log.c | 335 struct timespec waiter; in my_syslog() local
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractServiceTest.java | 349 Thread waiter = new Thread() { in testAwaitTerminated() local
365 Thread waiter = new Thread() { in testAwaitTerminated_FailedService() local
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_proactor_events.py | 39 def socket_transport(self, waiter=None): argument
488 def socket_transport(self, waiter=None): argument
|
| D | test_subprocess.py | 42 def create_transport(self, waiter=None): argument
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | rendezvous.cc | 260 DoneCallback waiter = nullptr; member
|
| /external/python/cpython3/Lib/test/ |
| D | test_asyncgen.py | 981 async def waiter(timeout): function
1017 async def waiter(timeout): function
|