Home
last modified time | relevance | path

Searched refs:latch (Results 1 – 25 of 44) sorted by relevance

12

/packages/modules/NetworkStack/tests/unit/src/com/android/server/connectivity/ipmemorystore/
DIpMemoryStoreServiceTest.java363 final CountDownLatch latch = new CountDownLatch(1);
364 functor.accept(latch);
366 if (!latch.await(timeout, TimeUnit.MILLISECONDS)) {
380 doLatched(timeoutMessage, latch -> mService.storeNetworkAttributes(l2Key, na.toParcelable(),
383 latch.countDown();
395 doLatched(timeoutMessage, latch -> mService.storeBlob(l2Key, TEST_CLIENT_ID, TEST_DATA_NAME,
399 latch.countDown();
463 doLatched("Did not complete retrieving attributes", latch ->
470 latch.countDown();
479 doLatched("Did not complete retrieving attributes 2", latch ->
[all …]
/packages/apps/Contacts/tests/src/com/android/contacts/database/
DNoNullCursorAsyncQueryHandlerTest.java59 final CountDownLatch latch = new CountDownLatch(1); in testCursorIsNotNull() local
75 latch.countDown(); in testCursorIsNotNull()
82 latch.await(5, TimeUnit.SECONDS); in testCursorIsNotNull()
89 final CountDownLatch latch = new CountDownLatch(1); in testCursorContainsCorrectCookies() local
102 latch.countDown(); in testCursorContainsCorrectCookies()
109 latch.await(5, TimeUnit.SECONDS); in testCursorContainsCorrectCookies()
116 final CountDownLatch latch = new CountDownLatch(1); in testCursorContainsCorrectColumns() local
129 latch.countDown(); in testCursorContainsCorrectColumns()
136 latch.await(5, TimeUnit.SECONDS); in testCursorContainsCorrectColumns()
/packages/apps/DocumentsUI/tests/common/com/android/documentsui/testing/
DLatchedConsumer.java16 private CountDownLatch latch; field in LatchedConsumer
19 latch = new CountDownLatch(expectedCount); in LatchedConsumer()
22 public CountDownLatch getLatch() { return latch; } in getLatch()
29 latch.countDown(); in accept()
34 assertFalse(latch.await(timeout, unit)); in assertNotCalled()
39 assertTrue(latch.await(timeout, unit)); in assertCalled()
DTestScheduledExecutorService.java173 CountDownLatch latch = new CountDownLatch(1); in waitForTasks() local
175 new Handler(Looper.getMainLooper()).post(latch::countDown); in waitForTasks()
176 latch.await(millisTimeout, TimeUnit.MILLISECONDS); in waitForTasks()
/packages/apps/DocumentsUI/tests/unit/com/android/documentsui/archives/
DArchivesProviderTest.java101 final CountDownLatch latch = new CountDownLatch(1); in testOpen_Success() local
122 latch.countDown(); in testOpen_Success()
127 latch.await(3, TimeUnit.SECONDS); in testOpen_Success()
153 final CountDownLatch latch = new CountDownLatch(1); in testOpen_Failure() local
175 latch.countDown(); in testOpen_Failure()
180 latch.await(3, TimeUnit.SECONDS); in testOpen_Failure()
260 final CountDownLatch latch = new CountDownLatch(1); in testNoNotificationAfterAllReleased() local
264 latch.countDown(); in testNoNotificationAfterAllReleased()
270 assertFalse(latch.await(1, TimeUnit.SECONDS)); in testNoNotificationAfterAllReleased()
/packages/services/Car/tests/carservice_unit_test/src/com/android/car/
DCarProjectionServiceTest.java115 final CountDownLatch latch = new CountDownLatch(2); in updateProjectionStatus_defaultState() local
125 latch.countDown(); in updateProjectionStatus_defaultState()
129 latch.await(DEFAULT_TIMEOUT_MS, TimeUnit.MILLISECONDS); in updateProjectionStatus_defaultState()
137 final CountDownLatch latch = new CountDownLatch(1); in updateProjectionStatus_subscribeAfterUpdate() local
170 latch.countDown(); in updateProjectionStatus_subscribeAfterUpdate()
174 latch.await(DEFAULT_TIMEOUT_MS, TimeUnit.MILLISECONDS); in updateProjectionStatus_subscribeAfterUpdate()
181 final CountDownLatch latch = new CountDownLatch(2); in updateProjectionStatus_subscribeBeforeUpdate() local
187 if (latch.getCount() == 2) { in updateProjectionStatus_subscribeBeforeUpdate()
195 latch.countDown(); in updateProjectionStatus_subscribeBeforeUpdate()
200 latch.await(DEFAULT_TIMEOUT_MS, TimeUnit.MILLISECONDS); in updateProjectionStatus_subscribeBeforeUpdate()
/packages/providers/ContactsProvider/tests/src/com/android/providers/contacts/
DContactsTaskSchedulerTest.java31 final CountDownLatch latch; field in ContactsTaskSchedulerTest.MyContactsTaskScheduler
37 latch = new CountDownLatch(numExpectedTasks); in MyContactsTaskScheduler()
44 latch.countDown(); in onPerformTask()
55 assertTrue(scheduler.latch.await(10, TimeUnit.SECONDS)); in testSimple()
96 assertTrue(scheduler.latch.await(10, TimeUnit.SECONDS)); in testAutoShutdown()
/packages/providers/CalendarProvider/tests/src/com/android/providers/calendar/
DCalendarProviderBroadcastReceiverTest.java41 final CountDownLatch latch = new CountDownLatch(1); in testBroadcastToRealProvider() local
48 latch.countDown(); in testBroadcastToRealProvider()
52 assertTrue("Didn't receive the result.", latch.await(1, TimeUnit.MINUTES)); in testBroadcastToRealProvider()
/packages/apps/Settings/tests/unit/src/com/android/settings/dashboard/
DUiBlockerControllerTest.java54 final CountDownLatch latch = new CountDownLatch(1); in start_isSyncedReturnFalseUntilAllWorkDone() local
55 mSyncableController.start(() -> latch.countDown()); in start_isSyncedReturnFalseUntilAllWorkDone()
66 assertThat(latch.await(TIMEOUT, TimeUnit.MILLISECONDS)).isTrue(); in start_isSyncedReturnFalseUntilAllWorkDone()
/packages/apps/DocumentsUI/tests/common/com/android/documentsui/services/
DTestJobListener.java34 private final CountDownLatch latch = new CountDownLatch(1); field in TestJobListener
47 latch.countDown(); in onFinished()
140 latch.await(500, TimeUnit.MILLISECONDS); in waitForFinished()
/packages/services/Car/tests/CarDeveloperOptions/src/com/android/car/developeroptions/homepage/contextualcards/
DEligibleCardChecker.java107 final CountDownLatch latch = new CountDownLatch(1); in bindSlice() local
116 latch.countDown(); in bindSlice()
129 latch.await(LATCH_TIMEOUT_MS, TimeUnit.MILLISECONDS); in bindSlice()
/packages/apps/Settings/src/com/android/settings/homepage/contextualcards/
DEligibleCardChecker.java117 final CountDownLatch latch = new CountDownLatch(1); in bindSlice() local
126 latch.countDown(); in bindSlice()
139 latch.await(LATCH_TIMEOUT_MS, TimeUnit.MILLISECONDS); in bindSlice()
/packages/apps/Dialer/java/com/android/dialer/persistentlog/
DPersistentLogger.java141 private final CountDownLatch latch = new CountDownLatch(1); field in PersistentLogger.DumpStringRunnable
146 latch.countDown(); in run()
150 latch.await(); in get()
/packages/apps/DocumentsUI/tests/unit/com/android/documentsui/
DRecentsLoaderTests.java116 CountDownLatch latch = new CountDownLatch(1); in testContentsUpdate_observable() local
118 latch.countDown(); in testContentsUpdate_observable()
134 latch.await(1, TimeUnit.SECONDS); in testContentsUpdate_observable()
DAbstractActionHandlerTest.java263 CountDownLatch latch = new CountDownLatch(1); in testLoadChildrenDocuments() local
264 mEnv.model.addUpdateListener(event -> latch.countDown()); in testLoadChildrenDocuments()
267 latch.await(1, TimeUnit.SECONDS); in testLoadChildrenDocuments()
/packages/apps/ManagedProvisioning/tests/instrumentation/src/com/android/managedprovisioning/provisioning/
DProfileOwnerProvisioningControllerTest.java150 final CountDownLatch latch = new CountDownLatch(1); in testCancel() local
154 latch.countDown(); in testCancel()
163 assertTrue(latch.await(1, TimeUnit.SECONDS)); in testCancel()
/packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/latin/settings/
DAccountsSettingsFragmentTests.java161 final CountDownLatch latch = new CountDownLatch(1); in initDialog() local
175 latch.countDown(); in initDialog()
180 latch.await(TEST_TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in initDialog()
/packages/modules/ExtServices/tests/src/android/ext/services/watchdog/
DExplicitHealthCheckServiceImplTest.java105 CountDownLatch latch = new CountDownLatch(1); in testHealthCheckSupportedPackage() local
109 latch.countDown(); in testHealthCheckSupportedPackage()
111 latch.await(); in testHealthCheckSupportedPackage()
/packages/apps/Launcher3/src/com/android/launcher3/logging/
DFileLog.java109 CountDownLatch latch = new CountDownLatch(1); in flushAll() local
111 Pair.create(out, latch)).sendToTarget(); in flushAll()
113 latch.await(2, TimeUnit.SECONDS); in flushAll()
/packages/apps/Launcher3/quickstep/tests/src/com/android/quickstep/
DNavigationModeSwitchRule.java171 final CountDownLatch latch = new CountDownLatch(1); in apply() local
177 latch.countDown(); in apply()
184 latch.await(60, TimeUnit.SECONDS); in apply()
/packages/apps/Launcher3/tests/src/com/android/launcher3/util/
DCondition.java23 final CountDownLatch latch = new CountDownLatch(1); in runOnUiThread() local
32 latch.await(1, TimeUnit.SECONDS); in runOnUiThread()
/packages/services/Car/tests/vehiclehal_test/src/com/android/car/vehiclehal/test/
DE2ePerformanceTest.java279 CountDownLatch latch = new CountDownLatch(EXPECTED_EVENTS); in verifyEventsFromSingleProperty() local
280 OnSensorChangedListener listener = event -> latch.countDown(); in verifyEventsFromSingleProperty()
284 assertTrue(latch.await(EXPECTED_TIME_DURATION_MS, TimeUnit.MILLISECONDS)); in verifyEventsFromSingleProperty()
/packages/apps/Launcher3/src/com/android/launcher3/graphics/
DLauncherPreviewRenderer.java121 CountDownLatch latch = new CountDownLatch(1); in call()
124 latch.countDown(); in call()
128 latch.await(); in call()
/packages/modules/IPsec/tests/iketests/src/java/com/android/internal/net/ipsec/ike/
DIkeSocketTestBase.java171 DummyPacketReceiver(TestCountDownLatch latch) { in DummyPacketReceiver() argument
172 mLatch = latch; in DummyPacketReceiver()
/packages/apps/Dialer/java/com/android/incallui/multisim/
DSwapSimWorker.java156 void setLatchForTest(CountDownLatch latch) { in setLatchForTest() argument
157 latchForTest = latch; in setLatchForTest()

12