HomeSort by relevance Sort by last modified time
    Searched defs:waiter (Results 1 - 25 of 98) sorted by null

1 2 3 4

  /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);

Completed in 1828 milliseconds

1 2 3 4