Home
last modified time | relevance | path

Searched refs:future (Results 1 – 25 of 144) sorted by relevance

123456

/packages/services/Car/tests/carservice_unit_test/src/com/android/car/user/
DCarUserManagerUnitTest.java216 AsyncFuture<UserSwitchResult> future = mMgr.switchUser(11); in testSwitchUser_success() local
218 assertThat(future).isNotNull(); in testSwitchUser_success()
219 UserSwitchResult result = getResult(future); in testSwitchUser_success()
229 AsyncFuture<UserSwitchResult> future = mMgr.switchUser(11); in testSwitchUser_remoteException() local
231 assertThat(future).isNotNull(); in testSwitchUser_remoteException()
232 UserSwitchResult result = getResult(future); in testSwitchUser_remoteException()
241 AsyncFuture<UserSwitchResult> future = mMgr.switchUser(11); in testSwitchUser_runtimeException() local
243 assertThat(future).isNotNull(); in testSwitchUser_runtimeException()
244 UserSwitchResult result = getResult(future); in testSwitchUser_runtimeException()
296 AsyncFuture<UserCreationResult> future = mMgr.createUser("dude", "sweet", 42); in testCreateUser_withType_success() local
[all …]
DExperimentalCarUserManagerUnitTest.java75 AndroidFuture<UserCreationResult> future = mManager.createDriver(name, true); in testCreateDriver_Success_Admin() local
77 UserCreationResult result = getResult(future); in testCreateDriver_Success_Admin()
89 AndroidFuture<UserCreationResult> future = mManager.createDriver(name, false); in testCreateDriver_Success_NonAdmin() local
91 UserCreationResult result = getResult(future); in testCreateDriver_Success_NonAdmin()
101 AndroidFuture<UserCreationResult> future = mManager.createDriver("test driver", false); in testCreateDriver_Error() local
103 assertThat(future).isNotNull(); in testCreateDriver_Error()
104 UserCreationResult result = getResult(future); in testCreateDriver_Error()
125 AndroidFuture<UserSwitchResult> future = mManager.switchDriver(10); in testSwitchDriver_Success() local
126 UserSwitchResult result = getResult(future); in testSwitchDriver_Success()
133 AndroidFuture<UserSwitchResult> future = mManager.switchDriver(20); in testSwitchDriver_Error() local
[all …]
/packages/services/Telephony/src/com/android/services/telephony/rcs/
DUceControllerManager.java162 Future future = mExecutorService.submit(() -> { in requestCapabilities() local
169 future.get(); in requestCapabilities()
187 Future future = mExecutorService.submit(() -> { in requestNetworkAvailability() local
194 future.get(); in requestNetworkAvailability()
210 Future<Integer> future = mExecutorService.submit(() -> { in getUcePublishState() local
216 return future.get(); in getUcePublishState()
232 Future<RcsContactUceCapability> future = mExecutorService.submit(() -> { in addUceRegistrationOverride() local
238 return future.get(); in addUceRegistrationOverride()
254 Future<RcsContactUceCapability> future = mExecutorService.submit(() -> { in removeUceRegistrationOverride() local
260 return future.get(); in removeUceRegistrationOverride()
[all …]
/packages/modules/Permission/framework-s/java/android/app/role/
DRoleControllerManager.java142 AndroidFuture<Bundle> future = new AndroidFuture<>(); in grantDefaultRoles()
143 service.grantDefaultRoles(new RemoteCallback(future::complete)); in grantDefaultRoles()
144 return future; in grantDefaultRoles()
157 AndroidFuture<Bundle> future = new AndroidFuture<>(); in onAddRoleHolder()
159 new RemoteCallback(future::complete)); in onAddRoleHolder()
160 return future; in onAddRoleHolder()
173 AndroidFuture<Bundle> future = new AndroidFuture<>(); in onRemoveRoleHolder()
175 new RemoteCallback(future::complete)); in onRemoveRoleHolder()
176 return future; in onRemoveRoleHolder()
189 AndroidFuture<Bundle> future = new AndroidFuture<>(); in onClearRoleHolders()
[all …]
/packages/services/Car/car-lib/src/android/car/user/
DCarUserManager.java349 AndroidFuture<UserSwitchResult> future = new AndroidFuture<UserSwitchResult>() { in switchUser() local
362 mService.switchUser(targetUserId, HAL_TIMEOUT_MS, future); in switchUser()
363 return new AndroidAsyncFuture<>(future); in switchUser()
367 AsyncFuture<UserSwitchResult> future = in switchUser()
369 return handleExceptionFromCarService(e, future); in switchUser()
375 AndroidFuture<UserSwitchResult> future = new AndroidFuture<>(); in newSwitchResuiltForFailure() local
376 future.complete(new UserSwitchResult(status, null)); in newSwitchResuiltForFailure()
377 return new AndroidAsyncFuture<>(future); in newSwitchResuiltForFailure()
391 AndroidFuture<UserCreationResult> future = new AndroidFuture<UserCreationResult>() { in createUser() local
410 mService.createUser(name, userType, flags, HAL_TIMEOUT_MS, future); in createUser()
[all …]
DExperimentalCarUserManager.java85 AndroidFuture<UserCreationResult> future = new AndroidFuture<>(); in createDriver()
86 future.complete(new UserCreationResult(UserCreationResult.STATUS_HAL_INTERNAL_FAILURE)); in createDriver()
88 return future; in createDriver()
125 AndroidFuture<UserSwitchResult> future = new AndroidFuture<>() { in switchDriver() local
134 mService.switchDriver(driverId, future); in switchDriver()
135 return future; in switchDriver()
137 AndroidFuture<UserSwitchResult> future = new AndroidFuture<>(); in switchDriver()
138 future.complete( in switchDriver()
141 return future; in switchDriver()
/packages/modules/Permission/service/java/com/android/role/
DRoleShellCommand.java115 CallbackFuture future = new CallbackFuture(); in runAddRoleHolder() local
117 future.createCallback()); in runAddRoleHolder()
118 return future.waitForResult(); in runAddRoleHolder()
127 CallbackFuture future = new CallbackFuture(); in runRemoveRoleHolder() local
129 future.createCallback()); in runRemoveRoleHolder()
130 return future.waitForResult(); in runRemoveRoleHolder()
138 CallbackFuture future = new CallbackFuture(); in runClearRoleHolders() local
139 mRoleManager.clearRoleHoldersAsUser(roleName, flags, userId, future.createCallback()); in runClearRoleHolders()
140 return future.waitForResult(); in runClearRoleHolders()
/packages/services/Car/car-lib/src/android/car/admin/
DCarDevicePolicyManager.java147 AndroidFuture<UserRemovalResult> future = new AndroidFuture<UserRemovalResult>(); in removeUser() local
148 mService.removeUser(userId, future); in removeUser()
149 UserRemovalResult result = future.get(DEVICE_POLICY_MANAGER_TIMEOUT_MS, in removeUser()
190 AndroidFuture<UserCreationResult> future = new AndroidFuture<UserCreationResult>(); in createUser() local
191 mService.createUser(name, type, future); in createUser()
192 UserCreationResult result = future.get(DEVICE_POLICY_MANAGER_TIMEOUT_MS, in createUser()
229 AndroidFuture<UserStartResult> future = new AndroidFuture<>(); in startUserInBackground() local
230 mService.startUserInBackground(userId, future); in startUserInBackground()
231 UserStartResult result = future.get(DEVICE_POLICY_MANAGER_TIMEOUT_MS, in startUserInBackground()
268 AndroidFuture<UserStopResult> future = new AndroidFuture<>(); in stopUser() local
[all …]
/packages/services/Car/tests/EmbeddedKitchenSinkApp/src/com/google/android/car/kitchensink/users/
DUserFragment.java156 AsyncFuture<UserCreationResult> future; in createUser() local
159 future = mCarUserManager.createGuest(name); in createUser()
173 future = mCarUserManager.createUser(name, UserManager.USER_TYPE_FULL_SECONDARY, flags); in createUser()
175 UserCreationResult result = getResult(future); in createUser()
214 AsyncFuture<UserSwitchResult> future = mCarUserManager.switchUser(userId); in switchUser() local
215 UserSwitchResult result = getResult(future); in switchUser()
295 AsyncFuture<UserIdentificationAssociationResponse> future = mCarUserManager in associateKeyFob() local
297 UserIdentificationAssociationResponse result = getResult(future); in associateKeyFob()
331 private static <T> T getResult(AsyncFuture<T> future) { in getResult() argument
332 future.whenCompleteAsync((r, e) -> { in getResult()
[all …]
/packages/services/Telecomm/src/com/android/server/telecom/
DPhoneAccountSuggestionHelper.java72 final CompletableFuture<List<PhoneAccountSuggestion>> future = new CompletableFuture<>(); in bindAndGetSuggestions() local
91 future.complete( in bindAndGetSuggestions()
94 future.complete( in bindAndGetSuggestions()
105 future.complete(getDefaultSuggestions(availablePhoneAccounts)); in bindAndGetSuggestions()
117 if (!future.isDone()) { in bindAndGetSuggestions()
120 future.complete(getDefaultSuggestions(availablePhoneAccounts)); in bindAndGetSuggestions()
129 future.complete(getDefaultSuggestions(availablePhoneAccounts)); in bindAndGetSuggestions()
138 if (!future.isDone()) { in bindAndGetSuggestions()
141 future.complete(getDefaultSuggestions(availablePhoneAccounts)); in bindAndGetSuggestions()
147 return future; in bindAndGetSuggestions()
/packages/apps/Dialer/java/com/android/dialer/metrics/
DFutureTimer.java75 public <T> void applyTiming(ListenableFuture<T> future, String eventName) { in applyTiming() argument
76 applyTiming(future, unused -> eventName, LogCatMode.DONT_LOG_VALUES); in applyTiming()
84 ListenableFuture<T> future, String eventName, @LogCatMode int logCatMode) { in applyTiming() argument
85 applyTiming(future, unused -> eventName, logCatMode); in applyTiming()
95 ListenableFuture<T> future, Function<T, String> eventNameFromResultFunction) { in applyTiming() argument
96 applyTiming(future, eventNameFromResultFunction, LogCatMode.DONT_LOG_VALUES); in applyTiming()
100 ListenableFuture<T> future, in applyTiming() argument
106 future, in applyTiming()
/packages/apps/Contacts/src/com/android/contacts/util/concurrent/
DFuturesUtil.java26 public static <V> ListenableFuture<V> withTimeout(final ListenableFuture<V> future, long time, in withTimeout() argument
28 return withTimeout(future, time, unit, ContactsExecutors.newHandlerExecutor(handler)); in withTimeout()
39 public static <V> ListenableFuture<V> withTimeout(final ListenableFuture<V> future, long time, in withTimeout() argument
45 didTimeout.set(!future.isDone() && !future.isCancelled()); in withTimeout()
46 future.cancel(true); in withTimeout()
50 return Futures.catchingAsync(future, Throwable.class, new AsyncFunction<Throwable, V>() { in withTimeout()
DContactsExecutors.java112 final HandlerFuture<Void> future = HandlerFuture in schedule() local
114 mHandler.postDelayed(future, unit.toMillis(delay)); in schedule()
115 return future; in schedule()
121 final HandlerFuture<V> future = new HandlerFuture<>(mHandler, delay, unit, callable); in schedule() local
122 mHandler.postDelayed(future, unit.toMillis(delay)); in schedule()
123 return future; in schedule()
/packages/services/Car/tests/carservice_unit_test/src/android/car/test/mocks/
DJavaMockitoHelperTest.java78 Future<String> future = mock(Future.class); in testGetResult() local
79 when(future.get(anyLong(), any())).thenReturn("done"); in testGetResult()
81 assertThat(JavaMockitoHelper.getResult(future)).isEqualTo("done"); in testGetResult()
87 Future<String> future = mock(Future.class); in testGetResult_withCustomTimeout() local
88 when(future.get(anyLong(), any(TimeUnit.class))).thenReturn("done"); in testGetResult_withCustomTimeout()
90 assertThat(JavaMockitoHelper.getResult(future, TIMEOUT_MS)).isEqualTo("done"); in testGetResult_withCustomTimeout()
91 verify(future).get(TIMEOUT_MS, TimeUnit.MILLISECONDS); in testGetResult_withCustomTimeout()
/packages/apps/Car/libs/car-arch-common/src/com/android/car/arch/common/
DFutureData.java49 public static <T> T getData(@Nullable FutureData<T> future) { in getData() argument
50 return (future != null) ? future.getData() : null; in getData()
55 public static <T> T getPastData(@Nullable FutureData<T> future) { in getPastData() argument
56 return (future != null) ? future.getPastData() : null; in getPastData()
/packages/apps/Dialer/java/com/android/voicemail/impl/protocol/
DVvm3Subscriber.java246 RequestFuture<String> future = RequestFuture.newFuture(); in getSelfProvisionResponse() local
249 new StringRequest(Request.Method.POST, url, future, future) { in getSelfProvisionResponse()
266 return future.get(REQUEST_TIMEOUT_SECONDS, TimeUnit.SECONDS); in getSelfProvisionResponse()
275 RequestFuture<String> future = RequestFuture.newFuture(); in clickSubscribeLink() local
278 new StringRequest(Request.Method.POST, subscribeLink, future, future); in clickSubscribeLink()
282 future.get(REQUEST_TIMEOUT_SECONDS, TimeUnit.SECONDS); in clickSubscribeLink()
304 RequestFuture<String> future = RequestFuture.newFuture(); in vvm3XmlRequest() local
306 new StringRequest(Request.Method.POST, voicemailManagementGateway, future, future) { in vvm3XmlRequest()
315 String response = future.get(REQUEST_TIMEOUT_SECONDS, TimeUnit.SECONDS); in vvm3XmlRequest()
/packages/apps/Car/Settings/tests/robotests/src/com/android/car/settings/profiles/
DProfileHelperTest.java520 AndroidFuture<UserCreationResult> future = new AndroidFuture<>(); in mockCreateUserFail() local
521 future.complete(new UserCreationResult(UserCreationResult.STATUS_ANDROID_FAILURE, in mockCreateUserFail()
523 AndroidAsyncFuture<UserCreationResult> asyncFuture = new AndroidAsyncFuture<>(future); in mockCreateUserFail()
529 AndroidFuture<UserCreationResult> future = new AndroidFuture<>(); in mockCreateUser() local
530 future.complete(new UserCreationResult(status, userInfo, null)); in mockCreateUser()
532 .thenReturn(new AndroidAsyncFuture<>(future)); in mockCreateUser()
536 AndroidFuture<UserCreationResult> future = new AndroidFuture<>(); in mockCreateGuest() local
537 future.complete(new UserCreationResult(status, userInfo, null)); in mockCreateGuest()
538 when(mMockCarUserManager.createGuest(name)).thenReturn(new AndroidAsyncFuture<>(future)); in mockCreateGuest()
542 AndroidFuture<UserSwitchResult> future = new AndroidFuture<>(); in mockSwitchUserSuccess() local
[all …]
/packages/services/Car/tests/carservice_unit_test/src/com/android/car/
DCarLocationServiceTest.java334 CompletableFuture<Void> future = new CompletableFuture<>(); in testStoresLocationUponShutdownPrepare() local
336 mCarLocationService.onStateChanged(CarPowerStateListener.SHUTDOWN_PREPARE, future); in testStoresLocationUponShutdownPrepare()
340 assertTrue(future.isDone()); in testStoresLocationUponShutdownPrepare()
380 CompletableFuture<Void> future = new CompletableFuture<>(); in testDoesNotStoreNullLocation() local
382 mCarLocationService.onStateChanged(CarPowerStateListener.SHUTDOWN_PREPARE, future); in testDoesNotStoreNullLocation()
385 assertTrue(future.isDone()); in testDoesNotStoreNullLocation()
425 CompletableFuture<Void> future = new CompletableFuture<>(); in testDeletesCacheFileUponSuspendExitWhileMoving() local
428 mCarLocationService.onStateChanged(CarPowerStateListener.SUSPEND_EXIT, future); in testDeletesCacheFileUponSuspendExitWhileMoving()
430 assertTrue(future.isDone()); in testDeletesCacheFileUponSuspendExitWhileMoving()
445 CompletableFuture<Void> future = new CompletableFuture<>(); in testRegistersForDrivingStateChangesUponSuspendExit() local
[all …]
/packages/services/Car/tests/carservice_unit_test/src/android/car/admin/
DCarDevicePolicyManagerUnitTest.java187 AndroidFuture<UserRemovalResult> future = in mockRemoveUser() local
189 future.complete(new UserRemovalResult(status)); in mockRemoveUser()
197 AndroidFuture<UserCreationResult> future = in mockCreateUser() local
199 future.complete(new UserCreationResult(status, user, /* errorMessage= */ null)); in mockCreateUser()
207 AndroidFuture<UserStartResult> future = in mockStartUserInBackground() local
209 future.complete(new UserStartResult(status)); in mockStartUserInBackground()
217 AndroidFuture<UserStopResult> future = in mockStopUser() local
219 future.complete(new UserStopResult(status)); in mockStopUser()
/packages/services/Telephony/tests/src/com/android/services/telephony/rcs/
DSipDelegateControllerTest.java99 CompletableFuture<Boolean> future = controller.create(request.getFeatureTags(), in testCreateDelegate() local
105 assertFalse(future.isDone()); in testCreateDelegate()
107 assertTrue(future.get()); in testCreateDelegate()
124 CompletableFuture<Boolean> future = controller.create(request.getFeatureTags(), in testCreateDeniedFeatures() local
130 assertFalse(future.isDone()); in testCreateDeniedFeatures()
135 assertTrue(future.get()); in testCreateDeniedFeatures()
153 CompletableFuture<Boolean> future = controller.create(request.getFeatureTags(), in testCreateDelegateTransportDied() local
156 assertFalse(future.get()); in testCreateDelegateTransportDied()
258 CompletableFuture<Boolean> future = controller.create(request.getFeatureTags(), in createSipDelegate() local
264 assertTrue(future.get()); in createSipDelegate()
/packages/apps/Gallery2/src/com/android/gallery3d/util/
DJobLimiter.java53 public synchronized void setFuture(Future<T> future) { in setFuture() argument
55 mDelegate = future; in setFuture()
137 JobWrapper<T> future = new JobWrapper<T>(Utils.checkNotNull(job), listener); in submit() local
138 mJobs.addLast(future); in submit()
140 return future; in submit()
155 public synchronized void onFutureDone(Future future) { in onFutureDone() argument
/packages/services/Car/service/src/com/android/car/garagemode/
DController.java83 public void onStateChanged(int state, CompletableFuture<Void> future) { in onStateChanged() argument
95 handleShutdownPrepare(future); in onStateChanged()
152 void initiateGarageMode(CompletableFuture<Void> future) { in initiateGarageMode() argument
154 mGarageMode.enterGarageMode(future); in initiateGarageMode()
196 private void handleShutdownPrepare(CompletableFuture<Void> future) { in handleShutdownPrepare() argument
197 initiateGarageMode(future); in handleShutdownPrepare()
/packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/metadatasynchronizer/
DMetadataPoolImpl.java71 ListenableFuture<TotalCaptureResultProxy> future = getOrCreateFuture(timestamp); in removeMetadataFuture() local
73 Futures.addCallback(future, new FutureCallback<TotalCaptureResultProxy>() { in removeMetadataFuture()
86 return Futures2.nonCancellationPropagating(future); in removeMetadataFuture()
92 SettableFuture<TotalCaptureResultProxy> future = getOrCreateFuture(timestamp); in update() local
93 future.set(metadata); in update()
/packages/services/Car/car-test-lib/src/android/car/testapi/
DCarTestingHelper.java38 public static <T> T getResult(@NonNull AsyncFuture<T> future) in getResult() argument
40 return getResult(future, ASYNC_TIMEOUT_MS); in getResult()
47 public static <T> T getResult(@NonNull AsyncFuture<T> future, long timeoutMs) { in getResult() argument
49 return future.get(timeoutMs, TimeUnit.MILLISECONDS); in getResult()
/packages/apps/Dialer/java/com/android/dialer/common/concurrent/
DDialerFutures.java58 for (final ListenableFuture<? extends T> future : output.futures) { in firstMatchingImpl()
59 future.addListener( in firstMatchingImpl()
69 value = Futures.getDone(future); in firstMatchingImpl()
137 for (ListenableFuture<? extends T> future : localFutures) { in afterDone()
138 future.cancel(interrupt); in afterDone()

123456