| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| Ping.java | 25 private final CountDownLatch latch = new CountDownLatch(1); field in class:Ping
40 latch.countDown();
46 latch.countDown();
55 latch.await();
65 if (latch.await(timeout, unit)) {
|
| /cts/tests/autofillservice/src/android/autofillservice/cts/ |
| MultipleTimesTimeListener.java | 33 private final CountDownLatch latch; field in class:MultipleTimesTimeListener
44 this.latch = new CountDownLatch(times);
49 latch.countDown();
53 final boolean set = latch.await(FILL_TIMEOUT_MS, TimeUnit.MILLISECONDS);
|
| OneTimeCompoundButtonListener.java | 34 private final CountDownLatch latch = new CountDownLatch(1); field in class:OneTimeCompoundButtonListener
47 latch.countDown();
51 final boolean set = latch.await(FILL_TIMEOUT_MS, TimeUnit.MILLISECONDS);
|
| OneTimeDateListener.java | 33 private final CountDownLatch latch = new CountDownLatch(1); field in class:OneTimeDateListener
50 latch.countDown();
54 final boolean set = latch.await(FILL_TIMEOUT_MS, TimeUnit.MILLISECONDS);
|
| OneTimeRadioGroupListener.java | 34 private final CountDownLatch latch = new CountDownLatch(1); field in class:OneTimeRadioGroupListener
46 latch.countDown();
50 final boolean set = latch.await(FILL_TIMEOUT_MS, TimeUnit.MILLISECONDS);
|
| OneTimeSpinnerListener.java | 36 private final CountDownLatch latch = new CountDownLatch(1); field in class:OneTimeSpinnerListener
47 final boolean set = latch.await(FILL_TIMEOUT_MS, TimeUnit.MILLISECONDS);
57 latch.countDown();
62 latch.countDown();
|
| AbstractAutoFillActivity.java | 46 final CountDownLatch latch = new CountDownLatch(1); local
49 latch.countDown();
52 if (!latch.await(timeoutMs, TimeUnit.MILLISECONDS)) {
|
| /frameworks/support/lifecycle/integration-tests/testapp/src/androidTest/java/android/arch/lifecycle/ |
| TestUtils.java | 65 final CountDownLatch latch = new CountDownLatch(1); local
69 latch.countDown();
74 latch.countDown();
79 latch.await();
|
| /cts/tests/sensor/src/android/hardware/cts/helpers/ |
| ActivityResultMultiplexedLatch.java | 26 * It holds a {@link CountDownLatch} latch for each thread that requests synchronization.
28 * Each thread requests a {@link Latch} to synchronize an Activity that will be started, by invoking
29 * {@link #bindThread()}, this guarantees that a latch is associated with the thread, and the result
38 * A latch for a bound thread.
41 public class Latch {
44 private Latch(Entry entry) {
54 mEntry.latch.await();
70 public final CountDownLatch latch = new CountDownLatch(1); field in class:ActivityResultMultiplexedLatch.Entry
85 public Latch bindThread() {
97 return new Latch(entry)
[all...] |
| SuspendStateMonitor.java | 44 CountDownLatch latch = new CountDownLatch(1); local
46 mWaitForWakeUpLatch.add(latch);
50 latch.await();
53 boolean countZero = latch.await(numSeconds, TimeUnit.SECONDS);
70 for (CountDownLatch latch : mWaitForWakeUpLatch) {
71 latch.countDown();
|
| /cts/tests/tests/widget/src/android/widget/cts/ |
| QuickContactBadgeTest.java | 51 final CountDownLatch latch = new CountDownLatch(1); local
71 latch.countDown();
84 assertTrue(latch.await(1, TimeUnit.SECONDS));
|
| /packages/providers/CalendarProvider/tests/src/com/android/providers/calendar/ |
| CalendarProviderBroadcastReceiverTest.java | 41 final CountDownLatch latch = new CountDownLatch(1); local
48 latch.countDown();
52 assertTrue("Didn't receive the result.", latch.await(1, TimeUnit.MINUTES));
|
| /cts/tests/JobScheduler/src/android/jobscheduler/cts/ |
| SharedUidTest.java | 64 final CountDownLatch latch = new CountDownLatch(1); local
75 latch.countDown();
92 assertTrue(latch.await(BROADCAST_TIMEOUT_SECONDS, TimeUnit.SECONDS));
|
| /packages/providers/ContactsProvider/tests/src/com/android/providers/contacts/ |
| ContactsTaskSchedulerTest.java | 32 final CountDownLatch latch; field in class:ContactsTaskSchedulerTest.MyContactsTaskScheduler
38 latch = new CountDownLatch(numExpectedTasks);
45 latch.countDown();
56 assertTrue(scheduler.latch.await(10, TimeUnit.SECONDS));
97 assertTrue(scheduler.latch.await(10, TimeUnit.SECONDS));
|
| /libcore/luni/src/test/java/libcore/java/lang/ref/ |
| FinalizeTest.java | 112 CountDownLatch latch = new CountDownLatch(3); local
113 createSlowFinalizer( 1, latch);
114 createSlowFinalizer(1000, latch);
115 createSlowFinalizer(8000, latch);
117 latch.await();
120 public void createSlowFinalizer(final long millis, final CountDownLatch latch) {
125 latch.countDown();
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| PendingFuture.java | 50 // latch for waiting (created lazily if needed)
51 private CountDownLatch latch; field in class:PendingFuture
117 // creates latch if required; return true if caller needs to wait
123 if (latch == null)
124 latch = new CountDownLatch(1);
141 if (latch != null)
142 latch.countDown();
159 if (latch != null)
160 latch.countDown();
180 latch.await()
[all...] |
| /cts/tests/app/app/src/android/app/stubs/ |
| OrientationTestUtils.java | 79 final CountDownLatch latch = new CountDownLatch(1); local
80 assertTrue(mLatch.compareAndSet(null, latch));
100 final CountDownLatch latch = mLatch.get(); local
101 if (latch != null) {
102 latch.countDown();
|
| /cts/tests/app/src/android/app/cts/ |
| NewDocumentTest.java | 51 private final CountDownLatch latch = new CountDownLatch(1); field in class:NewDocumentTest.Receiver
60 latch.await(TIMEOUT_MS, TimeUnit.MILLISECONDS));
65 latch.countDown();
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| ListenerCallQueueTest.java | 81 final CountDownLatch latch = new CountDownLatch(1); local
87 queue.add(countDownCallback(latch));
90 latch.await();
103 final CountDownLatch latch = new CountDownLatch(1); local
113 queue.add(countDownCallback(latch));
116 latch.await();
131 private Callback<Object> countDownCallback(final CountDownLatch latch) {
134 latch.countDown();
|
| /frameworks/support/v7/recyclerview/tests/src/android/support/v7/widget/ |
| WrappedRecyclerView.java | 84 final CountDownLatch latch = new CountDownLatch(1); local
89 latch.countDown();
92 latch.countDown();
96 latch.await(60, TimeUnit.SECONDS), CoreMatchers.is(true));
|
| /cts/tests/tests/provider/src/android/provider/cts/contacts/ |
| ContactsContract_QuickContactsTest.java | 46 final CountDownLatch latch = new CountDownLatch(2); local
69 latch.countDown();
81 assertTrue(latch.await(1, TimeUnit.SECONDS));
|
| /frameworks/base/services/backup/java/com/android/server/backup/params/ |
| AdbParams.java | 30 public final AtomicBoolean latch; field in class:AdbParams
36 latch = new AtomicBoolean(false);
|
| /packages/apps/Launcher3/tests/src/com/android/launcher3/util/ |
| Condition.java | 25 final CountDownLatch latch = new CountDownLatch(1); local
37 latch.await(1, TimeUnit.SECONDS);
|
| /cts/tests/tests/background/src/android/app/cts/backgroundrestrictions/ |
| BroadcastsTest.java | 116 final CountDownLatch latch = new CountDownLatch(SUPPORTED_BROADCASTS.length); local
133 latch.countDown();
149 assertTrue(latch.await(BROADCASTS_TIMEOUT_SECOND, TimeUnit.SECONDS));
|
| /cts/tests/tests/content/src/android/content/cts/ |
| MockSyncAdapter.java | 125 final CountDownLatch latch = mLatch; local
126 if (latch != null) {
127 latch.countDown();
|
