| /external/libmojo/mojo/edk/system/ |
| core.cc | 37 #include "mojo/edk/system/waiter.h"
1129 Waiter waiter; local
[all...] |
| /frameworks/base/core/tests/coretests/src/android/hardware/display/ |
| VirtualDisplayTest.java | 318 Runnable waiter = new Runnable() { local
326 synchronized (waiter) {
328 mHandler.post(waiter);
330 waiter.wait(TIMEOUT);
|
| /system/libhidl/transport/ |
| ServiceManagement.cpp | 509 struct Waiter : IServiceNotification {
510 Waiter(const std::string& interface, const std::string& instanceName,
545 ~Waiter() {
548 << "Waiter still registered for notifications, call done() before dropping ref!";
592 // the corresponding service before blocking on the waiter; otherwise, you might run
594 // here, and subsequently calling waiter->wait() will block forever.
600 // done() must be called before dropping the last strong ref to the Waiter, to make
628 sp<Waiter> waiter = new Waiter(interface, instanceName, defaultServiceManager1_1()) local
[all...] |
| /tools/tradefederation/core/tests/src/com/android/tradefed/device/ |
| DeviceManagerTest.java | 1221 Thread waiter = new Thread() { local
1260 Thread waiter = new Thread() { local
1298 Thread waiter = new Thread() { local
[all...] |
| /cts/tests/tests/media/src/android/media/cts/ |
| EncodeVirtualDisplayTest.java | 575 Runnable waiter = new Runnable() { local
583 synchronized (waiter) {
585 mUiHandler.post(waiter);
587 waiter.wait(UI_TIMEOUT_MS);
|
| /external/dng_sdk/source/ |
| dng_pthread.cpp | 59 struct waiter { struct in namespace:__anon18938
60 struct waiter *prev;
61 struct waiter *next;
87 waiter *head_waiter; // List of threads waiting on this condition
88 waiter *tail_waiter; // Used to get FIFO, rather than LIFO, behavior for pthread_cond_signal
576 waiter this_wait;
578 int my_generation; // The broadcast generation this waiter is in
587 // Add this waiter to the end of the list.
593 // If the list was empty, set the head of the list to this waiter.
597 // Note which broadcast generation this waiter belongs to
[all...] |
| /external/python/cpython3/Lib/test/ |
| test_coroutines.py | 1096 async def waiter(coro): function in function:CoroutineTest.test_await_15
1104 waiter(coro).send(None)
[all...] |
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| LinkedTransferQueue.java | 420 * is apparently the first waiter in the queue. See above for
455 volatile Thread waiter; // null until waiting field in class:LinkedTransferQueue.Node
485 * Sets item to self and waiter to null, to avoid garbage
489 * mechanics that extract items. Similarly, clearing waiter
495 U.putObject(this, WAITER, null);
532 LockSupport.unpark(waiter);
544 private static final long WAITER;
551 WAITER = U.objectFieldOffset
552 (Node.class.getDeclaredField("waiter"));
624 LockSupport.unpark(p.waiter);
[all...] |
| SynchronousQueue.java | 237 volatile Thread waiter; // to control park/unpark field in class:SynchronousQueue.TransferStack.SNode
264 Thread w = waiter;
266 waiter = null;
392 if (m == null) // waiter is gone
415 * When a node/thread is about to block, it sets its waiter
418 * fulfiller noticing that waiter is non-null so should be
456 else if (s.waiter == null)
457 s.waiter = w; // establish waiter so can park next iter
479 s.waiter = null; // forget threa
539 volatile Thread waiter; \/\/ to control park\/unpark field in class:SynchronousQueue.TransferQueue.QNode
[all...] |
| ConcurrentHashMap.java | 471 * waiter, we use a simple scheme using a single "waiter" field to
2781 volatile Thread waiter; field in class:ConcurrentHashMap.TreeBin
[all...] |
| /packages/apps/Launcher2/src/com/android/launcher2/ |
| LauncherModel.java | 392 Runnable waiter = new Runnable() { local
401 synchronized(waiter) {
402 runOnWorkerThread(waiter);
411 waiter.wait();
[all...] |
| /cts/tests/app/src/android/app/cts/ |
| ActivityManagerProcessStateTest.java | 856 WaitForBroadcast waiter = new WaitForBroadcast(mInstrumentation.getTargetContext()); local
[all...] |
| /frameworks/base/core/java/android/database/sqlite/ |
| SQLiteConnectionPool.java | 680 final ConnectionWaiter waiter; local
703 // No connections available. Enqueue a waiter in priority order.
706 waiter = obtainConnectionWaiterLocked(Thread.currentThread(), startTime,
712 waiter.mNext = successor;
719 predecessor.mNext = waiter;
721 mConnectionWaiterQueue = waiter;
724 nonce = waiter.mNonce;
733 if (waiter.mNonce == nonce) {
734 cancelConnectionWaiterLocked(waiter);
744 long nextBusyTimeoutTime = waiter.mStartTime + busyTimeoutMillis
871 ConnectionWaiter waiter = mConnectionWaiterQueue; local
1011 ConnectionWaiter waiter = mConnectionWaiterQueue; local
1076 ConnectionWaiter waiter = mConnectionWaiterPool; local
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ScheduledExecutorSubclassTest.java | 725 Runnable waiter = new CheckedRunnable() { public void realRun() { local
733 p.execute(waiter);
[all...] |
| ScheduledExecutorTest.java | 674 Runnable waiter = new CheckedRunnable() { public void realRun() { local
682 p.execute(waiter);
[all...] |
| ThreadPoolExecutorSubclassTest.java | 773 Runnable waiter = new CheckedRunnable() { public void realRun() { local
781 p.execute(waiter);
[all...] |
| ThreadPoolExecutorTest.java | 658 Runnable waiter = new CheckedRunnable() { public void realRun() { local
666 p.execute(waiter);
[all...] |
| /prebuilts/tools/common/m2/repository/com/jayway/android/robotium/robotium-solo/5.5.3/ |
| robotium-solo-5.5.3.jar | |
| /prebuilts/tools/common/m2/repository/com/koushikdutta/async/androidasync/2.1.3/ |
| androidasync-2.1.3.jar | |
| /external/robolectric/v1/lib/main/ |
| httpclient-4.0.3.jar | |
| /prebuilts/misc/common/robolectric/3.1.1/lib/ |
| httpclient-4.0.3.jar | |
| /prebuilts/misc/common/robolectric/3.4.2/lib/ |
| httpclient-4.0.3.jar | |
| /prebuilts/misc/common/robolectric/3.5.1/lib/ |
| httpclient-4.0.3.jar | |
| /prebuilts/misc/common/robolectric/3.6.1/lib/ |
| httpclient-4.0.3.jar | |
| /prebuilts/tools/common/m2/repository/org/apache/httpcomponents/httpclient/4.0.1/ |
| httpclient-4.0.1.jar | |
