| /packages/services/Telephony/src/com/android/services/telephony/rcs/ |
| D | UceControllerManager.java | 56 private final ExecutorService mExecutorService; field in UceControllerManager
66 mExecutorService = Executors.newSingleThreadExecutor(); in UceControllerManager()
79 mExecutorService = executor; in UceControllerManager()
86 mExecutorService.submit(() -> { in onRcsConnected()
98 mExecutorService.submit(() -> { in onRcsDisconnected()
110 mExecutorService.submit(() -> { in onDestroy()
117 mExecutorService.shutdown(); in onDestroy()
126 mExecutorService.submit(() -> { in onAssociatedSubscriptionUpdated()
147 mExecutorService.submit(() -> { in onCarrierConfigChanged()
166 Future future = mExecutorService.submit(() -> { in requestCapabilities()
[all …]
|
| D | SipTransportController.java | 188 mExecutorService.execute(() -> { in onCallbackDied()
320 private final ScheduledExecutorService mExecutorService; field in SipTransportController
376 mExecutorService = Executors.newSingleThreadScheduledExecutor(); in SipTransportController()
393 mExecutorService = executor; in SipTransportController()
400 mExecutorService.submit(() -> onRcsManagerChanged(manager)); in onRcsConnected()
405 mExecutorService.submit(() -> onRcsManagerChanged(null)); in onRcsDisconnected()
410 mExecutorService.submit(()-> onSubIdChanged(subId)); in onAssociatedSubscriptionUpdated()
415 mExecutorService.submit(this::onCarrierConfigChangedInternal); in onCarrierConfigChanged()
420 mExecutorService.submit(()-> { in onDestroy()
426 .thenRun(mExecutorService::shutdown); in onDestroy()
[all …]
|
| D | SipDelegateController.java | 76 requestedConfig, transportDeniedTags, mExecutorService, stateCallbacks); in create()
84 private final ScheduledExecutorService mExecutorService; field in SipDelegateController
102 mExecutorService = executorService; in SipDelegateController()
125 mExecutorService = executorService; in SipDelegateController()
251 }, mExecutorService);
280 }, mExecutorService);
359 }, mExecutorService);
390 new DelegateRequest(supportedSet), deniedSet, mExecutorService, stateCallbacks);
|
| /packages/services/Telephony/src/com/android/phone/callcomposer/ |
| D | CallComposerPictureTransfer.java | 102 private final ExecutorService mExecutorService; field in CallComposerPictureTransfer
110 mExecutorService = executorService; in CallComposerPictureTransfer()
123 .thenApplyAsync((network) -> prepareInitialPost(network, mUrl), mExecutorService) in uploadPicture()
124 .thenComposeAsync(this::obtainAuthenticateHeader, mExecutorService) in uploadPicture()
128 credentialsSupplier.getCredentials(header.getRealm(), mExecutorService), in uploadPicture()
129 mExecutorService); in uploadPicture()
136 mExecutorService) in uploadPicture()
139 mExecutorService); in uploadPicture()
144 mExecutorService); in uploadPicture()
147 }, mExecutorService).exceptionally((ex) -> { in uploadPicture()
[all …]
|
| /packages/services/Telephony/tests/src/com/android/services/telephony/rcs/ |
| D | SipTransportControllerTest.java | 124 private ScheduledExecutorService mExecutorService = null; field in SipTransportControllerTest
151 boolean isShutdown = mExecutorService == null || mExecutorService.isShutdown(); in tearDown()
153 mExecutorService.shutdownNow(); in tearDown()
352 waitForExecutorAction(mExecutorService, TIMEOUT_MS); in createDestroyAppDied()
441 waitForExecutorAction(mExecutorService, TIMEOUT_MS); in createTwoAndTriggerRoleChange()
448 waitForExecutorAction(mExecutorService, TIMEOUT_MS); in createTwoAndTriggerRoleChange()
451 waitForExecutorAction(mExecutorService, TIMEOUT_MS); in createTwoAndTriggerRoleChange()
455 waitForExecutorAction(mExecutorService, TIMEOUT_MS); in createTwoAndTriggerRoleChange()
495 assertTrue(waitForExecutorAction(mExecutorService, TIMEOUT_MS)); in createTwoAndDestroyOlder()
594 waitForExecutorAction(mExecutorService, TIMEOUT_MS); in testSubIdChangeDestroyTriggered()
[all …]
|
| /packages/apps/Settings/tests/robotests/src/com/android/settings/notification/app/ |
| D | AppConversationListPreferenceControllerTest.java | 67 private PausedExecutorService mExecutorService; field in AppConversationListPreferenceControllerTest
72 mExecutorService = new PausedExecutorService(); in setUp()
73 ShadowPausedAsyncTask.overrideExecutor(mExecutorService); in setUp()
97 mExecutorService.runAll(); in updateState_someConversations_loadsConversations()
117 mExecutorService.runAll(); in updateState_someConversations_loadsNotDemotedOnly()
131 mExecutorService.runAll(); in updateState_noConversations_hides()
143 mExecutorService.runAll(); in updateState_refreshes()
154 mExecutorService.runAll(); in updateState_refreshes()
164 mExecutorService.runAll(); in updateState_refreshes()
|
| D | AppChannelsBypassingDndPreferenceControllerTest.java | 72 private PausedExecutorService mExecutorService; field in AppChannelsBypassingDndPreferenceControllerTest
77 mExecutorService = new PausedExecutorService(); in setUp()
78 ShadowPausedAsyncTask.overrideExecutor(mExecutorService); in setUp()
100 mExecutorService.runAll(); in displayPreference_showsAllAndChannels()
117 mExecutorService.runAll(); in displayPreference_canToggleAllInterrupt()
129 mExecutorService.runAll(); in displayPreference_canToggleInterruptIfChannelEnabled()
147 mExecutorService.runAll(); in displayPreference_appBlocked_cannotToggleAllOrChannelInterrupts()
198 mExecutorService.runAll(); in displayPreference_duplicateChannelName_AddsGroupNameAsSummary()
|
| /packages/apps/Settings/src/com/android/settings/ |
| D | ResetSubscriptionContract.java | 41 private ExecutorService mExecutorService; field in ResetSubscriptionContract
67 mExecutorService = Executors.newSingleThreadExecutor(); in ResetSubscriptionContract()
140 mExecutorService, mSubscriptionsChangedListener);
145 if (mExecutorService == null) {
154 mExecutorService.shutdownNow();
155 mExecutorService = null;
|
| /packages/apps/Settings/tests/robotests/src/com/android/settings/development/ |
| D | OverlayCategoryPreferenceControllerTest.java | 77 private PausedExecutorService mExecutorService; field in OverlayCategoryPreferenceControllerTest
88 mExecutorService = new PausedExecutorService(); in setUp()
89 ShadowPausedAsyncTask.overrideExecutor(mExecutorService); in setUp()
125 mExecutorService.runAll(); in onPreferenceChange_enable()
139 mExecutorService.runAll(); in onPreferenceChange_enable_fails()
152 mExecutorService.runAll(); in onPreferenceChange_disable()
166 mExecutorService.runAll(); in onPreferenceChange_disable_fails()
181 mExecutorService.runAll(); in onPreferenceChange_disable_throws()
227 mExecutorService.runAll(); in onDeveloperOptionsSwitchDisabled()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/common/httpclient/ |
| D | AdServicesHttpsClient.java | 101 private final ListeningExecutorService mExecutorService; field in AdServicesHttpsClient
162 mExecutorService = MoreExecutors.listeningDecorator(executorService); in AdServicesHttpsClient()
341 mExecutorService.submit(() -> mUriConverter.toUrl(request.getUri()))) in fetchPayloadWithLogging()
345 mExecutorService.submit( in fetchPayloadWithLogging()
352 mExecutorService) in fetchPayloadWithLogging()
392 closer.eventuallyClose(new CloseableConnectionWrapper(urlConnection), mExecutorService); in doFetchPayload()
479 return ClosingFuture.from(mExecutorService.submit(() -> mUriConverter.toUrl(uri))) in getAndReadNothing()
483 mExecutorService.submit( in getAndReadNothing()
487 mExecutorService) in getAndReadNothing()
511 closer.eventuallyClose(new CloseableConnectionWrapper(urlConnection), mExecutorService); in doGetAndReadNothing()
[all …]
|
| /packages/modules/DeviceLock/DeviceLockController/src/com/android/devicelockcontroller/policy/ |
| D | StartLockTaskModeWorker.java | 55 private final ListeningExecutorService mExecutorService; field in StartLockTaskModeWorker
80 mExecutorService = executorService; in StartLockTaskModeWorker()
94 mExecutorService); in startWork()
137 }, mExecutorService); in startWork()
138 }, mExecutorService); in startWork()
149 mExecutorService); in startWork()
150 }, mExecutorService); in startWork() field in StartLockTaskModeWorker
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/js/ |
| D | JSScriptEngine.java | 85 private final ListeningExecutorService mExecutorService; field in JSScriptEngine
348 mExecutorService)
356 mExecutorService);
370 this.mExecutorService = executorService;
481 mExecutorService)
507 closer.eventuallyClose(new CloseableIsolateWrapper(jsIsolate, mLogger), mExecutorService);
527 mExecutorService,
562 mExecutorService)
596 mExecutorService);
631 .transform(this::isConsoleCallbackSupported, mExecutorService);
[all …]
|
| /packages/modules/DeviceLock/DeviceLockController/tests/robolectric/src/com/android/devicelockcontroller/provision/worker/ |
| D | ReportDeviceProvisionStateWorkerTest.java | 93 private final ListeningExecutorService mExecutorService = field in ReportDeviceProvisionStateWorkerTest
127 mSetupParametersClient = SetupParametersClient.getInstance(mTestApp, mExecutorService); in setUp()
131 DeviceLockNotificationManager.createAndSetDeviceLockNotificationManager(mExecutorService); in setUp()
215 waitUntilExecutorIdle(mExecutorService); in doWork_deferred_dismissibleUiState_schedulesAlarmAndSendsNotification()
216 waitUntilExecutorIdle(mExecutorService); in doWork_deferred_dismissibleUiState_schedulesAlarmAndSendsNotification()
218 waitUntilExecutorIdle(mExecutorService); in doWork_deferred_dismissibleUiState_schedulesAlarmAndSendsNotification()
245 waitUntilExecutorIdle(mExecutorService); in doWork_deferred_persistentUiState_schedulesAlarmAndSendsOngoingNotification()
246 waitUntilExecutorIdle(mExecutorService); in doWork_deferred_persistentUiState_schedulesAlarmAndSendsOngoingNotification()
248 waitUntilExecutorIdle(mExecutorService); in doWork_deferred_persistentUiState_schedulesAlarmAndSendsOngoingNotification()
275 waitUntilExecutorIdle(mExecutorService); in doWork_deferred_factoryResetState_schedulesResetDeviceAlarm()
|
| /packages/apps/Settings/tests/robotests/src/com/android/settings/deviceinfo/ |
| D | PrivateVolumeUnmountTest.java | 44 private PausedExecutorService mExecutorService; field in PrivateVolumeUnmountTest
48 mExecutorService = new PausedExecutorService(); in setUp()
49 ShadowPausedAsyncTask.overrideExecutor(mExecutorService); in setUp()
72 mExecutorService.runAll(); in OnClickListener_shouldCallUnmount()
|
| /packages/apps/Contacts/src/com/android/contacts/vcard/ |
| D | VCardService.java | 92 private final ExecutorService mExecutorService = Executors.newSingleThreadExecutor(); field in VCardService
227 Log.d(LOG_TAG, "Executor service status: shutdown: " + mExecutorService.isShutdown() in tryExecute()
228 + ", terminated: " + mExecutorService.isTerminated()); in tryExecute()
230 mExecutorService.execute(processor); in tryExecute()
317 mExecutorService.shutdown(); in stopServiceIfAppropriate()
326 if (mExecutorService.isShutdown()) { in updateMediaScanner()
389 mExecutorService.shutdown(); in cancelAllRequestsAndShutdown()
|
| /packages/modules/AdServices/adservices/libraries/cobalt/java/com/android/cobalt/data/ |
| D | DataService.java | 54 private final ExecutorService mExecutorService; field in DataService
59 this.mExecutorService = Objects.requireNonNull(executor); in DataService()
84 mExecutorService); in loggerDisabled()
97 mExecutorService); in loggerEnabled()
134 mExecutorService); in generateObservations()
206 mExecutorService); in aggregateCount()
247 mExecutorService); in aggregateString()
269 mExecutorService); in cleanup() field in DataService
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/common/ |
| D | RetryStrategyFactory.java | 28 private final ExecutorService mExecutorService; field in RetryStrategyFactory
32 mExecutorService = executorService; in RetryStrategyFactory()
55 ? new RetryStrategyImpl(maxRetryAttempts, mExecutorService) in createRetryStrategy()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/customaudience/ |
| D | FetchCustomAudienceImpl.java | 108 @NonNull private final ListeningExecutorService mExecutorService; field in FetchCustomAudienceImpl
168 mExecutorService = MoreExecutors.listeningDecorator(executor); in FetchCustomAudienceImpl()
268 .transformAsync(ignoredVoid -> performFetch(devContext), mExecutorService) in doFetchCustomAudience()
269 .transformAsync(this::validateResponse, mExecutorService) in doFetchCustomAudience()
271 ignoredVoid -> persistResponse(devContext), mExecutorService) in doFetchCustomAudience()
306 mExecutorService); in doFetchCustomAudience()
317 mExecutorService.submit( in filterAndValidateRequest()
405 mExecutorService.submit( in validateResponse()
451 mExecutorService.submit(
529 mExecutorService.submit(
[all …]
|
| /packages/modules/DeviceLock/tests/cts/src/com/android/cts/devicelock/ |
| D | DeviceLockManagerTest.java | 57 private final ExecutorService mExecutorService = Executors.newCachedThreadPool(); field in DeviceLockManagerTest
87 mDeviceLockManager.isDeviceLocked(mExecutorService, in getIsDeviceLockedFuture()
107 mDeviceLockManager.lockDevice(mExecutorService,
127 mDeviceLockManager.unlockDevice(mExecutorService,
147 mDeviceLockManager.getDeviceId(mExecutorService,
167 mDeviceLockManager.getKioskApps(mExecutorService,
|
| /packages/services/Car/tests/BugReportApp/src/com/android/car/bugreport/ |
| D | ExpireOldBugReportsJob.java | 37 private ExecutorService mExecutorService; field in ExpireOldBugReportsJob
43 mExecutorService = Executors.newSingleThreadExecutor(); in onCreate()
55 mExecutorService.submit(() -> run(params)); in onStartJob()
|
| /packages/apps/Settings/tests/robotests/src/com/android/settings/ |
| D | ResetNetworkConfirmTest.java | 58 private PausedExecutorService mExecutorService; field in ResetNetworkConfirmTest
62 mExecutorService = new PausedExecutorService(); in setUp()
63 ShadowPausedAsyncTask.overrideExecutor(mExecutorService); in setUp()
88 mExecutorService.runAll(); in testResetNetworkData_notResetEsim()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/adselection/ |
| D | UpdateAdCounterHistogramWorker.java | 70 @NonNull private final ListeningExecutorService mExecutorService; field in UpdateAdCounterHistogramWorker
99 mExecutorService = MoreExecutors.listeningDecorator(executor); in UpdateAdCounterHistogramWorker()
123 FluentFuture.from(mExecutorService.submit(() -> validateRequest(inputParams))) in updateAdCounterHistogram()
127 mExecutorService) in updateAdCounterHistogram()
149 mExecutorService); in updateAdCounterHistogram()
154 return mExecutorService.submit( in submitUpdateAdCounterHistogram()
|
| /packages/modules/Virtualization/demo/java/com/android/microdroid/demo/ |
| D | MainActivity.java | 154 private ExecutorService mExecutorService; field in MainActivity.VirtualMachineModel
164 mExecutorService = Executors.newFixedThreadPool(4); in run()
169 private final ExecutorService mService = mExecutorService; in run()
271 mExecutorService.execute(new Reader("console", mConsoleOutput, console)); in run()
272 mExecutorService.execute(new Reader("log", mLogOutput, log)); in run()
287 mExecutorService.shutdownNow(); in stop()
|
| /packages/modules/AppSearch/testing/servicestests/src/com/android/server/appsearch/ |
| D | RateLimitedExecutorTest.java | 33 private final ExecutorService mExecutorService = field in RateLimitedExecutorTest
46 RateLimitedExecutor rateLimitedExecutor = new RateLimitedExecutor(mExecutorService, in testAddTaskToQueue_addOk()
73 RateLimitedExecutor rateLimitedExecutor = new RateLimitedExecutor(mExecutorService, in testAddTaskToQueue_exceedsPerPackageCapacity_cannotAddTask()
112 RateLimitedExecutor rateLimitedExecutor = new RateLimitedExecutor(mExecutorService, in testAddTaskToQueue_otherPackageExceedsPerPackageCapacity_canAddTask()
149 RateLimitedExecutor rateLimitedExecutor = new RateLimitedExecutor(mExecutorService, in testAddTaskToQueue_exceedsTotalCapacity_cannotAddTask()
192 RateLimitedExecutor rateLimitedExecutor = new RateLimitedExecutor(mExecutorService, in testRemoveTaskFromQueue_removeOk()
237 RateLimitedExecutor rateLimitedExecutor = new RateLimitedExecutor(mExecutorService, in testCanAddMoreTasksAfterQueueClearsUp()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/shell/ |
| D | ShellCommandServiceImpl.java | 57 private final ListeningExecutorService mExecutorService; field in ShellCommandServiceImpl
72 mExecutorService = executorService; in ShellCommandServiceImpl()
96 FluentFuture.from(mExecutorService.submit(() -> handler.run(param.getCommandArgs()))) in runShellCommand()
136 mExecutorService); in runShellCommand()
|