/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
|
/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::__anon23510::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...] |
core.cc | 37 #include "mojo/edk/system/waiter.h" 1113 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. 102 info("Waiter running\n"); 116 info("Waiter exiting with %d\n", waiter_ret); 125 pthread_t waiter; local 158 info("Creating waiter\n"); 159 res = create_rt_thread(&waiter, waiterfn, NULL, SCHED_FIFO, 1); 173 * signal the waiter before requeue, waiter should automatically 175 * waiter to block on f1 again. 177 info("Issuing SIGUSR1 to waiter\n") [all...] |
futex_requeue_pi.c | 116 info("Waiter %ld: running\n", args->id); 129 info("waiter %ld woke with %d %s\n", args->id, args->ret, 143 info("Waiter %ld: exiting with %d\n", args->id, args->ret); 286 pthread_t waiter[THREAD_MAX], waker, blocker; local 323 if (create_rt_thread(&waiter[i], waiterfn, (void *)&args[i], 342 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();
|
/tools/tradefederation/core/tests/src/com/android/tradefed/targetprep/ |
DeviceFlashPreparerTest.java | 189 Thread waiter = new Thread() { local 201 waiter.start(); 203 assertTrue("Invalid state: waiter thread is not alive", waiter.isAlive()); 211 waiter.join(1000); 212 assertFalse("waiter thread has not returned", waiter.isAlive()); 225 Thread waiter = new Thread() { local 238 waiter.start(); 240 assertTrue("Invalid state: waiter thread is not alive", waiter.isAlive()) 263 Thread waiter = new Thread() { local [all...] |
/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/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());
|
/external/dnsmasq/src/ |
log.c | 385 struct timespec waiter; local 386 waiter.tv_sec = 0; 387 waiter.tv_nsec = 1000000 << (d - 1); /* 1 ms */ 388 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...] |
/system/libhidl/transport/ |
ServiceManagement.cpp | 388 struct Waiter : IServiceNotification { 437 sp<Waiter> waiter = new Waiter(); local 438 Return<bool> ret = manager->registerForNotifications(interface, instanceName, waiter); 453 waiter->wait(interface, instanceName);
|
/cts/tests/app/src/android/app/cts/ |
ActivityManagerProcessStateTest.java | 612 WaitForBroadcast waiter = new WaitForBroadcast(mInstrumentation.getTargetContext()); local 613 waiter.prepare(ACTION_SIMPLE_ACTIVITY_START_SERVICE_RESULT); 616 Intent resultIntent = waiter.doWait(WAIT_TIME);
|
/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",
|
/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);
|