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

1 2 3 4

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

Completed in 841 milliseconds

1 2 3 4