/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/ |
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/tests/hardware/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...] |
TestSensorEventListener.java | 120 CountDownLatch latch = mFlushLatch; local 122 if(latch != null) { 123 latch.countDown(); 134 CountDownLatch latch = mFlushLatch; local 135 if(latch == null) { 140 latch.await(FLUSH_TIMEOUT_US, TimeUnit.MICROSECONDS));
|
/libcore/luni/src/test/java/libcore/java/lang/ref/ |
FinalizeTest.java | 100 CountDownLatch latch = new CountDownLatch(5); local 101 createSlowFinalizer( 1, latch); 102 createSlowFinalizer(1000, latch); 103 createSlowFinalizer(2000, latch); 104 createSlowFinalizer(4000, latch); 105 createSlowFinalizer(8000, latch); 107 latch.await(); 110 public void createSlowFinalizer(final long millis, final CountDownLatch latch) { 115 latch.countDown();
|
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
AbstractListenableFutureTest.java | 43 protected CountDownLatch latch; field in class:AbstractListenableFutureTest 49 // Create a latch and a future that waits on the latch. 50 latch = new CountDownLatch(1); 51 future = createListenableFuture(Boolean.TRUE, null, latch); 58 latch.countDown(); 62 * Constructs a listenable future with a value available after the latch 94 latch.countDown(); 113 // The task thread waits for the latch, so we expect a timeout here. 120 latch.countDown() [all...] |
/external/mockwebserver/src/test/java/com/google/mockwebserver/ |
CustomDispatcherTest.java | 62 final CountDownLatch latch = new CountDownLatch(1); local 67 latch.await(); 80 latch.countDown();
|
/external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/ |
CustomDispatcherTest.java | 61 final CountDownLatch latch = new CountDownLatch(1); local 66 latch.await(); 79 latch.countDown();
|
/frameworks/testing/espresso/espresso-lib/src/main/java/com/google/android/apps/common/testing/ui/espresso/base/ |
ThreadPoolExecutorExtractor.java | 87 final CountDownLatch latch = new CountDownLatch(1); local 94 latch.countDown(); 99 latch.await();
|
/packages/apps/Dialer/tests/src/com/android/dialer/util/ |
FakeAsyncTaskExecutor.java | 190 final CountDownLatch latch = new CountDownLatch(1); local 195 latch.countDown(); 202 Assert.assertTrue(latch.await(mTimeoutMs, TimeUnit.MILLISECONDS));
|
/cts/apps/CtsVerifier/src/com/android/cts/verifier/jobscheduler/ |
ConstraintTestActivity.java | 82 final CountDownLatch latch = new CountDownLatch(1); local 86 latch.countDown(); 90 return latch.await(5, TimeUnit.SECONDS);
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
Uninterruptibles.java | 47 * Invokes {@code latch.}{@link CountDownLatch#await() await()} 50 public static void awaitUninterruptibly(CountDownLatch latch) { 55 latch.await(); 70 * {@code latch.}{@link CountDownLatch#await(long, TimeUnit) 73 public static boolean awaitUninterruptibly(CountDownLatch latch, 83 return latch.await(remainingNanos, NANOSECONDS);
|
/external/guava/guava-testlib/src/com/google/common/testing/ |
GcFinalization.java | 55 * final CountDownLatch latch = new CountDownLatch(1); 58 * protected void finalize() { latch.countDown(); ... } 61 * GcFinalization.await(latch); 145 * Waits until the given latch has {@linkplain CountDownLatch#countDown counted down} to zero, 150 public static void await(CountDownLatch latch) { 151 if (latch.getCount() == 0) { 158 if (latch.getCount() == 0) { 163 if (latch.await(1L, SECONDS)) { 167 throw new RuntimeException("Unexpected interrupt while waiting for latch", ie); 171 String.format("Latch failed to count down within %d second timeout", timeoutSeconds)) [all...] |
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
ListenableFutureTester.java | 40 private final CountDownLatch latch; field in class:ListenableFutureTester 45 this.latch = new CountDownLatch(1); 51 latch.countDown(); 55 assertEquals(1, latch.getCount()); 69 assertTrue(latch.await(5, TimeUnit.SECONDS)); 81 assertTrue(latch.await(5, TimeUnit.SECONDS)); 96 assertTrue(latch.await(5, TimeUnit.SECONDS));
|
/cts/tests/tests/content/src/android/content/cts/ |
ContentResolverSyncTestCase.java | 92 private CountDownLatch setNewLatch(CountDownLatch latch) { 94 getMockSyncAdapter().setLatch(latch); 95 return latch; 101 CountDownLatch latch = setNewLatch(new CountDownLatch(1)); local 107 if (!latch.await(latchTimeoutMs, TimeUnit.MILLISECONDS)) { 108 fail("should not time out waiting on latch"); 122 CountDownLatch latch = setNewLatch(new CountDownLatch(1)); local 131 latch.await(latchTimeoutMillis, TimeUnit.MILLISECONDS); 138 CountDownLatch latch = setNewLatch(new CountDownLatch(1)); local 147 latch.await(latchTimeoutMillis, TimeUnit.MILLISECONDS) [all...] |
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
AsyncApiTest.java | 316 final CountDownLatch latch = new CountDownLatch(1); local 328 latch.countDown(); 333 latch.await();
|
/frameworks/testing/espresso/espresso-lib-tests/src/androidTest/java/com/google/android/apps/common/testing/ui/espresso/base/ |
IdlingResourceRegistryTest.java | 66 final CountDownLatch latch = new CountDownLatch(1); local 71 latch.countDown(); 74 latch.await(); 96 final CountDownLatch latch = new CountDownLatch(1); local 101 latch.countDown(); 104 latch.await();
|
/packages/providers/DownloadProvider/src/com/android/providers/downloads/ |
StorageUtils.java | 120 if (!observer.latch.await(30, TimeUnit.SECONDS)) { 264 public final CountDownLatch latch = new CountDownLatch(1); field in class:StorageUtils.ObserverLatch 268 latch.countDown();
|
/libcore/luni/src/main/java/java/net/ |
InetAddress.java | 725 final CountDownLatch latch = new CountDownLatch(sourceAddresses.size()); local 735 while (latch.getCount() > 0) { 736 latch.countDown(); 741 latch.countDown(); 746 latch.await(); [all...] |
/frameworks/testing/espresso/espresso-lib/src/main/java/com/google/android/apps/common/testing/ui/espresso/action/ |
CloseKeyboardAction.java | 83 final CountDownLatch latch = new CountDownLatch(1); local 89 latch.countDown(); 99 if (!latch.await(2, TimeUnit.SECONDS)) {
|
/packages/apps/ContactsCommon/tests/src/com/android/contacts/common/database/ |
NoNullCursorAsyncQueryHandlerTest.java | 57 final CountDownLatch latch = new CountDownLatch(1); local 73 latch.countDown(); 80 latch.await(5, TimeUnit.SECONDS); 87 final CountDownLatch latch = new CountDownLatch(1); local 100 latch.countDown(); 107 latch.await(5, TimeUnit.SECONDS); 114 final CountDownLatch latch = new CountDownLatch(1); local 127 latch.countDown(); 134 latch.await(5, TimeUnit.SECONDS);
|
/development/samples/Vault/tests/src/com/example/android/vault/ |
EncryptedDocumentTest.java | 131 final CountDownLatch latch = new CountDownLatch(1); local 145 latch.countDown(); 153 latch.await(5, TimeUnit.SECONDS);
|
/cts/apps/CtsVerifier/src/com/android/cts/verifier/sensors/base/ |
BaseSensorTestActivity.java | 164 for (CountDownLatch latch : mWaitForUserLatches) { 165 latch.countDown(); 287 CountDownLatch latch = new CountDownLatch(1); local 289 mWaitForUserLatches.add(latch); 294 latch.await(); 326 ActivityResultMultiplexedLatch.Latch latch = mActivityResultMultiplexedLatch.bindThread(); local 327 startActivityForResult(intent, latch.getRequestCode()); 328 return latch.await();
|
/cts/tests/tests/animation/src/android/animation/cts/ |
PropertyValuesHolderTest.java | 105 final CountDownLatch latch = new CountDownLatch(1); local 110 latch.countDown(); 113 latch.await(timeoutMilliseconds, TimeUnit.MILLISECONDS);
|
/cts/tests/tests/net/src/android/net/cts/ |
TrafficStatsTest.java | 59 final CountDownLatch latch = new CountDownLatch(1); local 67 latch.countDown(); 71 latch.await(5, TimeUnit.SECONDS);
|
/frameworks/support/v7/recyclerview/tests/src/android/support/v7/widget/ |
BaseRecyclerViewInstrumentationTest.java | 144 final CountDownLatch latch = new CountDownLatch(2); local 149 latch.countDown(); 153 latch.await(seconds, TimeUnit.SECONDS);
|