| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| StressTestClient.cs | 129 await Task.WhenAll(tasks);
133 await channel.ShutdownAsync();
136 await metricsServer.ShutdownAsync();
148 await RunTestCaseAsync(client, testCase);
167 await InteropClient.RunClientStreamingAsync(client);
170 await InteropClient.RunServerStreamingAsync(client);
173 await InteropClient.RunPingPongAsync(client);
176 await InteropClient.RunEmptyStreamAsync(client);
179 await InteropClient.RunCancelAfterBeginAsync(client);
182 await InteropClient.RunCancelAfterFirstResponseAsync(client)
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| ListenableFutureTester.java | 72 assertTrue(latch.await(5, TimeUnit.SECONDS));
84 assertTrue(latch.await(5, TimeUnit.SECONDS));
99 assertTrue(latch.await(5, TimeUnit.SECONDS));
|
| /cts/tests/tests/media/src/android/media/cts/ |
| MediaSessionManagerTest.java | 133 assertTrue(listener.mCountDownLatch.await(TIMEOUT_MS, TimeUnit.MILLISECONDS));
146 assertFalse(listener.mCountDownLatch.await(WAIT_MS, TimeUnit.MILLISECONDS));
152 assertFalse(listener.mCountDownLatch.await(WAIT_MS, TimeUnit.MILLISECONDS));
181 assertTrue(listener.mCountDownLatch.await(TIMEOUT_MS, TimeUnit.MILLISECONDS));
187 assertFalse(callback.mCountDownLatch.await(WAIT_MS, TimeUnit.MILLISECONDS));
195 assertTrue(listener.mCountDownLatch.await(TIMEOUT_MS, TimeUnit.MILLISECONDS));
201 assertTrue(callback.mCountDownLatch.await(TIMEOUT_MS, TimeUnit.MILLISECONDS));
213 assertFalse(listener.mCountDownLatch.await(WAIT_MS, TimeUnit.MILLISECONDS));
258 assertTrue(callback.mCountDownLatch.await(TIMEOUT_MS, TimeUnit.MILLISECONDS));
294 assertTrue(sessionCallback.mCountDownLatch.await(TIMEOUT_MS, TimeUnit.MILLISECONDS))
[all...] |
| /cts/hostsidetests/devicepolicy/app/DeviceAndProfileOwner/src/com/android/cts/deviceandprofileowner/ |
| AutofillActivity.java | 54 final boolean called = mLatch.await(2, TimeUnit.SECONDS);
|
| ContentSuggestionsActivity.java | 57 final boolean called = mLatch.await(2, TimeUnit.SECONDS);
|
| /cts/hostsidetests/incident/apps/errorsapp/src/com/android/server/cts/errors/ |
| ErrorsTests.java | 79 assertTrue(mResultsReceivedSignal.await(TIMEOUT_SECS, TimeUnit.SECONDS));
99 assertTrue(mResultsReceivedSignal.await(TIMEOUT_SECS, TimeUnit.SECONDS));
113 assertTrue(mResultsReceivedSignal.await(TIMEOUT_SECS, TimeUnit.SECONDS));
127 assertTrue(mResultsReceivedSignal.await(TIMEOUT_SECS, TimeUnit.SECONDS));
|
| /cts/tests/acceleration/src/android/acceleration/ |
| AcceleratedView.java | 56 if (mDrawLatch.await(1, TimeUnit.SECONDS)) {
|
| /cts/tests/app/app/src/android/app/stubs/ |
| ActivityManagerMemoryClassLaunchActivity.java | 68 mLatch.await(5, TimeUnit.SECONDS);
|
| /cts/tests/autofillservice/src/android/autofillservice/cts/ |
| MultiWindowEmptyActivity.java | 54 if (!sLastInstanceLatch.await(Timeouts.ACTIVITY_RESURRECTION.getMaxValue(),
|
| MultiWindowLoginActivity.java | 54 if (!sLastInstanceLatch.await(Timeouts.ACTIVITY_RESURRECTION.getMaxValue(),
|
| OneTimeCompoundButtonListener.java | 51 final boolean set = latch.await(FILL_TIMEOUT.ms(), TimeUnit.MILLISECONDS);
|
| OneTimeRadioGroupListener.java | 50 final boolean set = latch.await(FILL_TIMEOUT.ms(), TimeUnit.MILLISECONDS);
|
| TrampolineForResultActivity.java | 52 final boolean called = mLatch.await(1000, TimeUnit.MILLISECONDS);
|
| /cts/tests/contentsuggestions/src/android/contentsuggestions/cts/ |
| ContentSuggestionsManagerTest.java | 80 await(mWatcher.created, "Waiting for create"); method
87 await(mWatcher.destroyed, "Waiting for service destroyed"); method
138 private void await(@NonNull CountDownLatch latch, @NonNull String message) { method in class:ContentSuggestionsManagerTest
141 latch.await(SERVICE_LIFECYCLE_TIMEOUT_MS, TimeUnit.MILLISECONDS)).isTrue();
|
| /cts/tests/tests/assist/src/android/assist/cts/ |
| LifecycleTest.java | 53 if (!mHasFocusLatch.await(Utils.ACTIVITY_ONRESUME_TIMEOUT_MS, TimeUnit.MILLISECONDS)) {
60 if (!mLostFocusLatch.await(Utils.ACTIVITY_ONRESUME_TIMEOUT_MS, TimeUnit.MILLISECONDS)) {
66 if (mActivityLifecycleLatch.await(Utils.TIMEOUT_MS, TimeUnit.MILLISECONDS)) {
73 if (!mDestroyLatch.await(Utils.ACTIVITY_ONRESUME_TIMEOUT_MS, TimeUnit.MILLISECONDS)) {
|
| /cts/tests/tests/net/api23Test/src/android/net/cts/api23test/ |
| ConnectivityReceiver.java | 42 sLatch.await(30, TimeUnit.SECONDS);
|
| /cts/tests/tests/role/src/android/app/role/cts/ |
| WaitForResultActivity.java | 48 mLatch.await(timeoutMillis, TimeUnit.MILLISECONDS);
|
| /cts/tests/tests/voiceinteraction/common/src/android/voiceinteraction/common/ |
| Utils.java | 168 public static boolean await(CountDownLatch latch) { method in class:Utils
170 if (latch.await(OPERATION_TIMEOUT_MS, TimeUnit.MILLISECONDS)) return true;
179 public static boolean await(Condition condition) { method in class:Utils
181 if (condition.await(OPERATION_TIMEOUT_MS, TimeUnit.MILLISECONDS)) return true;
|
| /cts/tests/tests/voiceinteraction/src/android/voiceinteraction/cts/ |
| VoiceInteractionTestReceiver.java | 37 if (!sServiceStartedLatch.await(timeout, unit)) {
|
| /cts/tools/cts-holo-generation/src/com/android/cts/holo_capture/ |
| CaptureActivity.java | 31 mLatch.await();
|
| /external/grpc-grpc/src/csharp/Grpc.Examples.Tests/ |
| MathClientServerTests.cs | 87 DivReply response = await client.DivAsync(new DivArgs { Dividend = 10, Divisor = 3 });
97 var responses = await call.ResponseStream.ToListAsync();
114 while (await call.ResponseStream.MoveNext())
138 var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.ToListAsync());
153 await call.RequestStream.WriteAllAsync(numbers);
154 var result = await call.ResponseAsync;
171 await call.RequestStream.WriteAllAsync(divArgsList);
172 var result = await call.ResponseStream.ToListAsync();
|
| /art/test/911-get-stack-trace/src/art/ |
| OtherThread.java | 32 data.reached.await();
66 data.reached.await();
|
| /cts/tests/AlarmManager/src/android/alarmmanager/cts/ |
| InstantAppsTests.java | 67 assertTrue("Alarm did not fire as expected", latch.await(500, TimeUnit.MILLISECONDS));
77 assertTrue("Alarm did not fire as expected", latch.await(500, TimeUnit.MILLISECONDS));
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| StreamRecorder.java | 82 latch.await();
89 return latch.await(timeout, unit);
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
| StreamRecorder.java | 87 latch.await();
94 return latch.await(timeout, unit);
|
