| /libcore/luni/src/test/java/libcore/java/lang/ |
| OldAndroidMonitorTest.java | 110 static class Waiter extends Thread {
115 public Waiter(Object lock, CountDownLatch cdl) {
145 final Waiter waiter = new Waiter(lock, cdl); local
147 waiter.start();
149 // Wait for the "waiter" to start and acquire |lock| for the first time.
156 // Interrupt |waiter| after we acquire |lock|. This ensures that |waiter| is
159 waiter.interrupt()
[all...] |
| /art/test/059-finalizer-throw/src/ |
| Main.java | 25 static Object waiter = new Object(); field in class:Main
|
| /build/soong/ui/build/ |
| proc_sync.go | 69 func lockSynchronous(lock lockable, waiter waiter, logger logger.Logger) (err error) {
85 done, description := waiter.checkDeadline()
89 lock.description(), waiter.summarize())
92 waiter.wait()
110 type waiter interface { type
123 var _ waiter = (*sleepWaiter)(nil)
125 func newSleepWaiter(interval time.Duration, duration time.Duration) (waiter *sleepWaiter) {
|
| /external/libmojo/mojo/edk/system/ |
| waiter_test_utils.h | 15 #include "mojo/edk/system/waiter.h"
22 // This is a very simple thread that has a |Waiter|, on which it waits
24 // |Waiter| on creation, but the caller must start the thread with |Start()|. It
33 // awakable_list.Add(thread.waiter(), ...);
35 // ... some stuff to wake the waiter ...
36 // awakable_list.Remove(thread.waiter());
41 // |Waiter::Init()|, |AddAwakable()|, and |RemoveAwakable()| are done in the
42 // main (test) thread, not the waiter thread (as would actually happen in real
53 Waiter* waiter() { return &waiter_; function in class:mojo::edk::test::SimpleWaiterThread
[all...] |
| waiter_unittest.cc | 10 #include "mojo/edk/system/waiter.h"
57 Waiter* waiter() { return &waiter_; } function in class:mojo::edk::__anon25170::WaitingThread
80 Waiter waiter_; // Thread-safe.
102 thread.waiter()->Awake(MOJO_RESULT_OK, 1);
112 thread.waiter()->Awake(MOJO_RESULT_CANCELLED, 2);
125 thread.waiter()->Awake(1, 3);
138 thread.waiter()->Awake(2, 4);
163 thread.waiter()->Awake(MOJO_RESULT_OK, 5);
173 thread.waiter()->Awake(MOJO_RESULT_CANCELLED, 6)
212 Waiter waiter; local
[all...] |
| /external/linux-kselftest/tools/testing/selftests/futex/functional/ |
| futex_requeue_pi_signal_restart.c | 13 * kernel. The latter should return EWOULDBLOCK to the waiter.
103 info("Waiter running\n");
117 info("Waiter exiting with %d\n", waiter_ret);
126 pthread_t waiter; local
160 info("Creating waiter\n");
161 res = create_rt_thread(&waiter, waiterfn, NULL, SCHED_FIFO, 1);
175 * signal the waiter before requeue, waiter should automatically
177 * waiter to block on f1 again.
179 info("Issuing SIGUSR1 to waiter\n")
[all...] |
| futex_requeue_pi.c | 117 info("Waiter %ld: running\n", args->id);
130 info("waiter %ld woke with %d %s\n", args->id, args->ret,
144 info("Waiter %ld: exiting with %d\n", args->id, args->ret);
287 pthread_t waiter[THREAD_MAX], waker, blocker; local
324 if (create_rt_thread(&waiter[i], waiterfn, (void *)&args[i],
343 pthread_join(waiter[i],
|
| /external/ltp/testcases/kernel/ipc/semaphore/ |
| sem02.c | 29 * Waiter, pid = <pid#>
33 * Waiter waiting, pid = <pid#>
34 * Waiter done waiting
61 void *waiter(void *);
102 rc = pthread_create(&pt[i], &attr, waiter, retval[i]);
122 place, the semop should complete and we'll print "Waiter done
124 void *waiter(void *foo) function
129 tst_resm(TINFO, "Waiter, pid = %d", pid);
132 tst_resm(TINFO, "Waiter waiting, pid = %d", pid);
134 tst_resm(TINFO, "Waiter done waiting")
[all...] |
| /external/glide/library/src/main/java/com/bumptech/glide/request/ |
| RequestFutureTarget.java | 39 private static final Waiter DEFAULT_WAITER = new Waiter();
46 private final Waiter waiter; field in class:RequestFutureTarget
62 RequestFutureTarget(Handler mainHandler, int width, int height, boolean assertBackgroundThread, Waiter waiter) {
67 this.waiter = waiter;
83 waiter.notifyAll(this);
172 waiter.notifyAll(this)
[all...] |
| /tools/tradefederation/core/tests/src/com/android/tradefed/util/ |
| ConditionPriorityBlockingQueueTest.java | 154 Thread waiter = new Thread() { local
164 waiter.setName(getClass().getCanonicalName() + "#testTake_multiple_matchers");
165 waiter.start();
204 waiter.join();
|
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| WaitingThread.java | 65 private Thread waiter; field in class:WaitingThread
119 return this.waiter;
147 if (this.waiter != null) {
151 "\nwaiter: " + this.waiter);
157 this.waiter = Thread.currentThread();
170 this.waiter = null;
186 if (this.waiter == null) {
|
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/uicc/ |
| AdnRecordCache.java | 318 Message waiter = waiters.get(i); local
320 AsyncResult.forMessage(waiter, ar.result, ar.exception);
321 waiter.sendToTarget();
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_broadcast/ |
| 4-2.c | 125 static void *waiter(void *arg) function
137 UNRESOLVED(ret, "Unable to lock mutex in waiter thread");
150 UNRESOLVED(ret, "Unable to unlock mutex in waiter thread");
220 ret = pthread_create(&th_waiter[i], NULL, waiter, NULL);
222 UNRESOLVED(ret, "Waiter thread creation failed");
260 UNRESOLVED(ret, "Waiter thread join failed");
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_signal/ |
| 4-2.c | 160 void *waiter(void *arg) function
173 UNRESOLVED(ret, "Unable to lock mutex in waiter thread");
189 UNRESOLVED(ret, "Unable to unlock mutex in waiter thread");
266 if ((ret = pthread_create(&th_waiter, NULL, waiter, NULL))) {
267 UNRESOLVED(ret, "Waiter thread creation failed");
304 UNRESOLVED(ret, "Waiter thread join failed");
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_timedwait/ |
| 4-3.c | 136 void *waiter(void *arg) function
152 UNRESOLVED(ret, "Unable to lock mutex in waiter thread");
186 UNRESOLVED(ret, "Unable to unlock mutex in waiter thread");
278 if ((ret = pthread_create(&th_waiter, NULL, waiter, NULL))) {
279 UNRESOLVED(ret, "Waiter thread creation failed");
319 UNRESOLVED(ret, "Waiter thread join failed");
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_wait/ |
| 4-1.c | 162 void *waiter(void *arg) function
175 UNRESOLVED(ret, "Unable to lock mutex in waiter thread");
196 UNRESOLVED(ret, "Unable to unlock mutex in waiter thread");
289 if ((ret = pthread_create(&th_waiter, NULL, waiter, NULL))) {
290 UNRESOLVED(ret, "Waiter thread creation failed");
327 UNRESOLVED(ret, "Waiter thread join failed");
|
| /external/tensorflow/tensorflow/core/framework/ |
| rendezvous.cc | 168 // There is no waiter for this message. Append the message
169 // into the queue. The waiter will pick it up when arrives.
183 // There is an earliest waiter to consume this message.
188 // Notify the waiter by invoking its done closure, outside the
191 item->waiter(Status::OK(), send_args, item->recv_args, val, is_dead);
215 item->waiter = std::move(done);
249 item->waiter(status, Args(), Args(), Tensor(), false);
260 DoneCallback waiter = nullptr; member in struct:tensorflow::LocalRendezvousImpl::Item
276 bool IsSendValue() const { return this->waiter == nullptr; }
287 // [!item.IsSendValue()]* meaning each item is a waiter
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| AbstractServiceTest.java | 349 Thread waiter = new Thread() { local
354 waiter.start();
358 waiter.join(LONG_TIMEOUT_MILLIS); // ensure that the await in the other thread is triggered
359 assertFalse(waiter.isAlive());
365 Thread waiter = new Thread() { local
375 waiter.start();
381 waiter.join(LONG_TIMEOUT_MILLIS);
382 assertFalse(waiter.isAlive());
|
| /packages/apps/ManagedProvisioning/tests/instrumentation/src/com/android/managedprovisioning/provisioning/ |
| ProvisioningActivityTest.java | 257 ActivityLifecycleWaiter waiter = new ActivityLifecycleWaiter(activity, Stage.DESTROYED); local
259 waiter.waitForStage();
|
| /external/dnsmasq/src/ |
| log.c | 383 struct timespec waiter; local
384 waiter.tv_sec = 0;
385 waiter.tv_nsec = 1000000 << (d - 1); /* 1 ms */
386 nanosleep(&waiter, NULL);
|
| util.c | 504 struct timespec waiter; local
507 waiter.tv_sec = 0;
508 waiter.tv_nsec = 10000;
509 nanosleep(&waiter, NULL);
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| NonBlockingThreadPool.h | 128 MaxSizeVector<EventCount::Waiter> waiters_;
141 EventCount::Waiter* waiter = &waiters_[thread_id]; local
160 if (!WaitForWork(waiter, &t)) {
195 bool WaitForWork(EventCount::Waiter* waiter, Task* t) {
199 ec_.Prewait(waiter);
203 ec_.CancelWait(waiter);
212 ec_.CancelWait(waiter);
232 ec_.CommitWait(waiter);
[all...] |
| /external/ltp/testcases/open_posix_testsuite/stress/threads/pthread_cond_timedwait/ |
| s-c.c | 254 void *waiter(void *arg) function
262 UNRESOLVED(ret, "Mutex lock failed in waiter");
276 UNRESOLVED(ret, "pthread_cond_wait failed in waiter");
284 UNRESOLVED(ret, "Mutex unlock failed in waiter");
402 /* Create the waiter threads */
405 pthread_create(&th[i], &ta, waiter,
440 /* All waiter threads are created now */
442 output("%i waiter threads created successfully\n", i);
472 output("%i waiter threads are waiting; start measure\n",
|
| /external/python/cpython3/Lib/test/ |
| test_asyncgen.py | 984 async def waiter(timeout): function in function:AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01
994 async for _ in waiter(1):
1020 async def waiter(timeout): function in function:AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02
1028 async for _ in waiter(1):
|
| /cts/tests/tests/display/src/android/display/cts/ |
| VirtualDisplayTest.java | 263 Runnable waiter = new Runnable() { local
271 synchronized (waiter) {
273 mHandler.post(waiter);
275 waiter.wait(TIMEOUT);
|
