| /packages/services/Telephony/src/com/android/services/telephony/rcs/ |
| D | UceControllerManager.java | 86 mExecutorService.submit(() -> { in onRcsConnected()
98 mExecutorService.submit(() -> { in onRcsDisconnected()
110 mExecutorService.submit(() -> { in onDestroy()
126 mExecutorService.submit(() -> { in onAssociatedSubscriptionUpdated()
147 mExecutorService.submit(() -> { in onCarrierConfigChanged()
166 Future future = mExecutorService.submit(() -> { in requestCapabilities()
191 Future future = mExecutorService.submit(() -> { in requestNetworkAvailability()
215 Future<Integer> future = mExecutorService.submit(() -> { in getUcePublishState()
237 Future<RcsContactUceCapability> future = mExecutorService.submit(() -> { in addUceRegistrationOverride()
259 Future<RcsContactUceCapability> future = mExecutorService.submit(() -> { in removeUceRegistrationOverride()
[all …]
|
| /packages/apps/Launcher3/tests/src/com/android/launcher3/util/ |
| D | ItemInflaterTest.kt | 118 MAIN_EXECUTOR.submit(Callable { underTest.inflateItem(itemInfo, modelWriter) }).get() in <lambda>()
130 VIEW_PREINFLATION_EXECUTOR.submit( in <lambda>()
147 MAIN_EXECUTOR.submit(Callable { underTest.inflateItem(itemInfo, modelWriter) }).get() in <lambda>()
163 VIEW_PREINFLATION_EXECUTOR.submit( in <lambda>()
180 MAIN_EXECUTOR.submit(Callable { underTest.inflateItem(itemInfo, modelWriter) }).get() in <lambda>()
196 VIEW_PREINFLATION_EXECUTOR.submit( in <lambda>()
210 MAIN_EXECUTOR.submit(Callable { underTest.inflateItem(itemInfo, modelWriter) }).get() in <lambda>()
222 VIEW_PREINFLATION_EXECUTOR.submit( in <lambda>()
236 MAIN_EXECUTOR.submit(Callable { underTest.inflateItem(itemInfo, modelWriter) }).get() in <lambda>()
252 VIEW_PREINFLATION_EXECUTOR.submit( in <lambda>()
[all …]
|
| /packages/modules/DeviceLock/DeviceLockController/tests/robolectric/src/com/android/devicelockcontroller/provision/grpc/impl/ |
| D | DeviceCheckinClientImplTest.java | 162 mBgExecutor.submit(() -> response.set( in getCheckInStatus_succeeds()
184 mBgExecutor.submit(() -> response.set( in getCheckInStatus_noFcmToken_succeeds()
207 mBgExecutor.submit(() -> response.set( in getCheckInStatus_emptyFcmToken_succeeds()
229 mBgExecutor.submit(() -> response.set( in getCheckInStatus_blankFcmToken_succeeds()
268 mBgExecutor.submit(() -> response.set( in getCheckInStatus_noDefaultConnectivity_fallsBackToNonVpn()
296 mBgExecutor.submit(() -> response.set( in getCheckInStatus_noConnectivityOrNonVpnNetwork_isNotSuccessful()
330 mBgExecutor.submit(() -> response.set( in getCheckInStatus_lostNonVpnConnection_isNotSuccessful()
352 mBgExecutor.submit(() -> response.set( in isDeviceInApprovedCountry_succeeds()
390 mBgExecutor.submit(() -> response.set( in isDeviceInApprovedCountry_noDefaultConnectivity_fallsBackToNonVpn()
418 mBgExecutor.submit(() -> response.set( in isDeviceInApprovedCountry_noConnectivityOrNonVpnNetwork_isNotSuccessful()
[all …]
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/devapi/ |
| D | AdSelectionOverrider.java | 130 mLightweightExecutorService.submit( in addOverride()
180 mLightweightExecutorService.submit( in removeOverride()
225 mLightweightExecutorService.submit( in removeAllOverridesForAdSelectionConfig()
275 mLightweightExecutorService.submit( in addOverride()
322 mLightweightExecutorService.submit( in removeOverride()
368 mLightweightExecutorService.submit( in removeAllOverridesForAdSelectionFromOutcomes()
410 mBackgroundExecutorService.submit( in callAddOverride()
429 mBackgroundExecutorService.submit( in callRemoveOverride()
445 mBackgroundExecutorService.submit(
463 mBackgroundExecutorService.submit(
[all …]
|
| D | CustomAudienceOverrider.java | 125 mListeningExecutorService.submit( in addOverride()
184 mListeningExecutorService.submit( in removeOverride()
231 mListeningExecutorService.submit( in removeAllOverrides()
265 mListeningExecutorService.submit( in callAddOverride()
287 mListeningExecutorService.submit(
301 mListeningExecutorService.submit(
|
| /packages/modules/AdServices/shared/tests/device-side/java/com/android/adservices/shared/testing/common/ |
| D | BlockingCallableWrapperTest.java | 55 ListenableFuture<Integer> asyncWork = mLightWeightExecutor.submit(toTest); in testRunsDelegate()
65 ListenableFuture<Integer> asyncWork = mLightWeightExecutor.submit(toTest); in testMarksTaskAsCompleted()
89 ListenableFuture<Integer> asyncWork = mLightWeightExecutor.submit(toTest); in testCommandExecutionDoesNotStartsIfNotTriggered()
106 ListenableFuture<Integer> asyncWork = mLightWeightExecutor.submit(toTest); in testCommandExecutionStartsWhenTriggered()
128 ListenableFuture<Integer> asyncWork = mLightWeightExecutor.submit(toTest); in testBlocksCallerUntilCompleted()
144 ListenableFuture<Integer> asyncWork = mLightWeightExecutor.submit(toTest); in testBlocksCallerUntilTimeoutIfNotCompleted()
|
| /packages/modules/AppSearch/service/java/com/android/server/appsearch/util/ |
| D | RateLimitedExecutor.java | 231 public <T> Future<T> submit(Callable<T> task) { in submit() method in RateLimitedExecutor
232 return mExecutor.submit(task); in submit()
236 public <T> Future<T> submit(Runnable task, T result) { in submit() method in RateLimitedExecutor
237 return mExecutor.submit(task, result); in submit()
241 public Future<?> submit(Runnable task) { in submit() method in RateLimitedExecutor
242 return mExecutor.submit(task); in submit()
|
| /packages/modules/OnDevicePersonalization/src/com/android/ondevicepersonalization/services/serviceflow/ |
| D | ServiceFlowOrchestrator.java | 45 .submit(serviceFlowTask::run); in schedule()
47 .submit(serviceFlowTask::run); in schedule()
49 .submit(serviceFlowTask::run); in schedule()
|
| /packages/apps/Dialer/java/com/android/dialer/phonelookup/cp2/ |
| D | Cp2DefaultDirectoryPhoneLookup.java | 102 return backgroundExecutorService.submit(() -> lookupInternal(dialerPhoneNumber)); in lookup()
173 backgroundExecutorService.submit( in isDirty()
275 return backgroundExecutorService.submit(
321 return backgroundExecutorService.submit(
348 return backgroundExecutorService.submit(
369 return backgroundExecutorService.submit(
406 return backgroundExecutorService.submit(
428 return backgroundExecutorService.submit(
469 backgroundExecutorService.submit(
571 return backgroundExecutorService.submit(
[all …]
|
| /packages/apps/Launcher3/tests/src/com/android/launcher3/model/ |
| D | AsyncBindingTest.kt | 128 MAIN_EXECUTOR.submit(callbacks.pendingTasks!!::executeAllAndDestroy).get() in <lambda>()
144 MAIN_EXECUTOR.submit { in <lambda>()
172 MAIN_EXECUTOR.submit { in <lambda>()
182 MAIN_EXECUTOR.submit {}.get() in <lambda>()
183 MODEL_EXECUTOR.submit {}.get() in <lambda>()
184 MAIN_EXECUTOR.submit {}.get() in <lambda>()
|
| /packages/modules/DeviceLock/DeviceLockController/tests/robolectric/src/com/android/devicelockcontroller/policy/ |
| D | StartLockTaskModeWorkerTest.java | 135 final Result result = mBgExecutor.submit(() -> mWorker.startWork().get()).get(); in doWork_launchesActivityInLockedTaskMode()
160 final Result result = mBgExecutor.submit(() -> mWorker.startWork().get()).get(); in doWork_hitsException_failsAndEnforcesCriticalFailure()
174 final Result result = mBgExecutor.submit(() -> mWorker.startWork().get()).get(); in doWork_alreadyLockedDoesNothing()
190 final Result result = mBgExecutor.submit(() -> mWorker.startWork().get()).get(); in doWork_failsWhenNoLaunchIntent()
204 final Result result = mBgExecutor.submit(() -> mWorker.startWork().get()).get(); in doWork_failsLaunchIntentNotPermitted()
|
| /packages/modules/OnDevicePersonalization/tests/servicetests/src/com/android/ondevicepersonalization/services/ |
| D | OnDevicePersonalizationExecutorsTests.java | 42 OnDevicePersonalizationExecutors.getBackgroundExecutor().submit(task).get(); in testBackgroundExecutorSettings()
53 OnDevicePersonalizationExecutors.getLightweightExecutor().submit(task).get(); in testLightweightExecutorSettings()
65 OnDevicePersonalizationExecutors.getBlockingExecutor().submit(task).get(); in testBlockingExecutorSettings()
|
| /packages/modules/OnDevicePersonalization/tests/federatedcomputetests/src/com/android/federatedcompute/services/common/ |
| D | FederatedComputeExecutorsTest.java | 46 FederatedComputeExecutors.getBackgroundExecutor().submit(task).get(); in testBackgroundExecutorSettings()
60 FederatedComputeExecutors.getLightweightExecutor().submit(task).get(); in testLightweightExecutorSettings()
74 FederatedComputeExecutors.getBlockingExecutor().submit(task).get(); in testBlockingExecutorSettings()
|
| /packages/modules/OnDevicePersonalization/tests/frameworktests/src/com/android/ondevicepersonalization/internal/util/ |
| D | ByteArrayParceledSliceTest.java | 64 Executors.newSingleThreadExecutor().submit(() -> service.echo( in runTest()
80 Executors.newSingleThreadExecutor().submit(() -> service.echo( in runTestForNullArray()
97 Executors.newSingleThreadExecutor().submit(() -> service.echo( in runTestForEmptyArray()
126 Executors.newSingleThreadExecutor().submit(() -> run(input, callback)); in echo()
|
| /packages/services/Car/service/src/com/android/car/oem/ |
| D | CarOemProxyServiceHelper.java | 171 Future<T> result = mThreadPool.submit(callable); in doBinderTimedCallWithDefaultValue()
211 Future<T> result = mThreadPool.submit(callable); in doBinderTimedCallWithTimeout()
267 Future<T> result = mThreadPool.submit(callable); in doBinderCallWithDefaultValueAndDelayedWaitAndCrash()
388 Future<T> result = mThreadPool.submit(callable); in doBinderCallWithTimeoutCrash()
426 Future<?> result = mThreadPool.submit(runnable); in doBinderOneWayCall()
460 Future<String> result = mThreadPool.submit(oemStackTracer); in crashCarService()
|
| /packages/services/Car/tests/carservice_unit_test/src/com/android/car/internal/util/ |
| D | ConcurrentUtilsTest.java | 37 Future<Boolean> future = service.submit(() -> { in testWaitForFutureNoInterruptNormal()
59 Future<Boolean> future = service.submit(() -> { in testWaitForFutureNoInterruptRuntimeException()
71 service.submit(() -> { in testWaitForCountDownNoInterruptNormal()
|
| /packages/apps/Launcher3/tests/multivalentTests/src/com/android/launcher3/util/ |
| D | CancellableTaskTest.kt | 82 Executors.UI_HELPER_EXECUTOR.submit { lock.lock() } in run_and_cancel_cancelTaskAndCallback()
99 Executors.VIEW_PREINFLATION_EXECUTOR.submit { lock.lock() } in run_and_cancel_cancelCallback()
124 executor.submit<Any> { null }.get() in awaitExecutorCompleted()
|
| /packages/modules/AdServices/adservices/libraries/cobalt/java/com/android/cobalt/data/ |
| D | DataService.java | 80 return Futures.submit( in loggerDisabled()
95 return Futures.submit( in loggerEnabled()
125 return Futures.submit( in generateObservations()
195 return Futures.submit( in aggregateCount()
235 return Futures.submit( in aggregateString()
259 return Futures.submit( in cleanup()
|
| /packages/modules/Uwb/generic_ranging/src/com/android/ranging/generic/ranging/ |
| D | UwbAdapter.java | 133 return Futures.submit(() -> { in isEnabled()
180 return Futures.submit(() -> { in getLocalAddress()
194 return Futures.submit(() -> {
209 return Futures.submit(() -> {
226 var future = Futures.submit(() -> {
255 Futures.submit(() -> {
|
| /packages/modules/ExtServices/java/src/android/ext/services/notification/ |
| D | Assistant.java | 150 Future<?> ignored = mMachineLearningExecutor.submit(() -> { in onNotificationEnqueued()
288 mSingleThreadExecutor.submit( in onNotificationExpansionChanged()
297 mSingleThreadExecutor.submit( in onNotificationDirectReplied()
308 mSingleThreadExecutor.submit( in onSuggestedReplySent()
320 mSingleThreadExecutor.submit( in onActionInvoked()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/adselection/ |
| D | JsFetcher.java | 127 mBackgroundExecutorService.submit( in getBiddingLogic()
169 mBackgroundExecutorService.submit( in getBuyerDecisionLogicWithLogger()
213 mBackgroundExecutorService.submit(
257 mBackgroundExecutorService.submit(
291 mBackgroundExecutorService.submit(
326 mBackgroundExecutorService.submit(
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/common/httpclient/ |
| D | AdServicesHttpsClient.java | 341 mExecutorService.submit(() -> mUriConverter.toUrl(request.getUri()))) in fetchPayloadWithLogging()
345 mExecutorService.submit( in fetchPayloadWithLogging()
479 return ClosingFuture.from(mExecutorService.submit(() -> mUriConverter.toUrl(uri))) in getAndReadNothing()
483 mExecutorService.submit( in getAndReadNothing()
538 return ClosingFuture.from(mExecutorService.submit(() -> mUriConverter.toUrl(uri))) in postPlainText()
542 mExecutorService.submit( in postPlainText()
613 mExecutorService.submit(() -> mUriConverter.toUrl(request.getUri()))) in performRequestGetResponseInBase64StringWithLogging()
617 mExecutorService.submit( in performRequestGetResponseInBase64StringWithLogging()
640 mExecutorService.submit(() -> mUriConverter.toUrl(request.getUri()))) in performRequestGetResponseInPlainString()
644 mExecutorService.submit( in performRequestGetResponseInPlainString()
|
| /packages/apps/Dialer/java/com/android/dialer/rtt/ |
| D | RttTranscriptUtil.java | 38 .submit(() -> checkRttTranscriptAvailability(context, transcriptIds)); in getAvailableRttTranscriptIds()
76 .submit(() -> getRttTranscript(context, transcriptId)); in loadRttTranscript()
112 .submit( in saveRttTranscript()
|
| /packages/apps/Dialer/java/com/android/dialer/calllog/ |
| D | ClearMissedCalls.java | 67 uiThreadExecutor.submit( in clearAll()
96 uiThreadExecutor.submit( in clearBySystemCallLogId()
125 return backgroundExecutor.submit(
|
| /packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/util/ |
| D | ThreadPool.java | 97 public <T> Future<T> submit(Job<T> job, FutureListener<T> listener) { in submit() method in ThreadPool
103 public <T> Future<T> submit(Job<T> job) { in submit() method in ThreadPool
104 return submit(job, null); in submit()
|