/aosp12/packages/services/Telephony/src/com/android/services/telephony/rcs/ |
H A D | UceControllerManager.java | 55 private final ExecutorService mExecutorService; field in UceControllerManager 76 mExecutorService = executor; in UceControllerManager() 82 mExecutorService.submit(() -> { in onRcsConnected() 94 mExecutorService.submit(() -> { in onRcsDisconnected() 106 mExecutorService.submit(() -> { in onDestroy() 113 mExecutorService.shutdown(); in onDestroy() 122 mExecutorService.submit(() -> { in onAssociatedSubscriptionUpdated() 143 mExecutorService.submit(() -> { in onCarrierConfigChanged() 162 Future future = mExecutorService.submit(() -> { in requestCapabilities() 187 Future future = mExecutorService.submit(() -> { in requestNetworkAvailability() [all …]
|
H A D | SipTransportController.java | 182 mExecutorService.execute(() -> { in onCallbackDied() 255 private final ScheduledExecutorService mExecutorService; field in SipTransportController 322 mExecutorService = executor; in SipTransportController() 329 mExecutorService.submit(() -> onRcsManagerChanged(manager)); in onRcsConnected() 334 mExecutorService.submit(() -> onRcsManagerChanged(null)); in onRcsDisconnected() 339 mExecutorService.submit(()-> onSubIdChanged(subId)); in onAssociatedSubscriptionUpdated() 349 mExecutorService.submit(()-> { in onDestroy() 355 .thenRun(mExecutorService::shutdown); in onDestroy() 693 mExecutorService); in reevaluateDelegates() 742 }, mExecutorService); in reevaluateDelegates() [all …]
|
H A D | SipDelegateController.java | 76 requestedConfig, transportDeniedTags, mExecutorService, stateCallbacks); in create() 83 private final ScheduledExecutorService mExecutorService; field in SipDelegateController 100 mExecutorService = executorService; in SipDelegateController() 121 mExecutorService = executorService; in SipDelegateController() 247 }, mExecutorService); 276 }, mExecutorService); 355 }, mExecutorService); 386 new DelegateRequest(supportedSet), deniedSet, mExecutorService, stateCallbacks);
|
/aosp12/packages/services/Telephony/src/com/android/phone/callcomposer/ |
H A D | CallComposerPictureTransfer.java | 102 private final ExecutorService mExecutorService; field in CallComposerPictureTransfer 110 mExecutorService = executorService; in CallComposerPictureTransfer() 129 mExecutorService); in uploadPicture() 136 mExecutorService) in uploadPicture() 139 mExecutorService); in uploadPicture() 144 mExecutorService); in uploadPicture() 147 }, mExecutorService).exceptionally((ex) -> { in uploadPicture() 170 }, mExecutorService); in downloadPicture() 189 mExecutorService), mExecutorService); in downloadPicture() 201 }, mExecutorService); in downloadPicture() [all …]
|
/aosp12/packages/services/Telephony/tests/src/com/android/services/telephony/rcs/ |
H A D | SipTransportControllerTest.java | 123 private ScheduledExecutorService mExecutorService = null; field in SipTransportControllerTest 150 boolean isShutdown = mExecutorService == null || mExecutorService.isShutdown(); in tearDown() 152 mExecutorService.shutdownNow(); in tearDown() 351 waitForExecutorAction(mExecutorService, TIMEOUT_MS); in createDestroyAppDied() 440 waitForExecutorAction(mExecutorService, TIMEOUT_MS); in createTwoAndTriggerRoleChange() 447 waitForExecutorAction(mExecutorService, TIMEOUT_MS); in createTwoAndTriggerRoleChange() 450 waitForExecutorAction(mExecutorService, TIMEOUT_MS); in createTwoAndTriggerRoleChange() 454 waitForExecutorAction(mExecutorService, TIMEOUT_MS); in createTwoAndTriggerRoleChange() 593 waitForExecutorAction(mExecutorService, TIMEOUT_MS); in testSubIdChangeDestroyTriggered() 613 waitForExecutorAction(mExecutorService, TIMEOUT_MS); in testRcsManagerGoneDestroyTriggered() [all …]
|
H A D | SipDelegateControllerTest.java | 76 private ScheduledExecutorService mExecutorService; field in SipDelegateControllerTest 82 mExecutorService = new TestExecutorService(); in setUp() 87 mExecutorService.shutdownNow(); in tearDown() 294 return new SipDelegateController(TEST_SUB_ID, request, "", mExecutorService, in getTestDelegateController()
|
/aosp12/packages/services/Car/tests/BugReportApp/src/com/android/car/bugreport/ |
H A D | ExpireOldBugReportsJob.java | 37 private ExecutorService mExecutorService; field in ExpireOldBugReportsJob 43 mExecutorService = Executors.newSingleThreadExecutor(); in onCreate() 55 mExecutorService.submit(() -> run(params)); in onStartJob()
|
/aosp12/packages/apps/Contacts/src/com/android/contacts/vcard/ |
H A D | VCardService.java | 91 private final ExecutorService mExecutorService = Executors.newSingleThreadExecutor(); field in VCardService 222 Log.d(LOG_TAG, "Executor service status: shutdown: " + mExecutorService.isShutdown() in tryExecute() 223 + ", terminated: " + mExecutorService.isTerminated()); in tryExecute() 225 mExecutorService.execute(processor); in tryExecute() 309 mExecutorService.shutdown(); in stopServiceIfAppropriate() 318 if (mExecutorService.isShutdown()) { in updateMediaScanner() 381 mExecutorService.shutdown(); in cancelAllRequestsAndShutdown()
|
/aosp12/frameworks/base/services/core/java/com/android/server/am/ |
H A D | BatteryExternalStatsWorker.java | 82 private final ScheduledExecutorService mExecutorService = field in BatteryExternalStatsWorker 268 if (!mExecutorService.isShutdown()) { in scheduleReadProcStateCpuTimes() 287 if (!mExecutorService.isShutdown()) { in scheduleCopyFromAllUidsCpuTimes() 366 if (mExecutorService.isShutdown()) { in scheduleDelayedSyncLocked() 384 if (mExecutorService.isShutdown()) { in scheduleWrite() 391 return mExecutorService.submit(mWriteTask); in scheduleWrite() 399 if (!mExecutorService.isShutdown()) { in scheduleRunnable() 400 mExecutorService.submit(runnable); in scheduleRunnable() 405 mExecutorService.shutdownNow(); in shutdown() 410 if (mExecutorService.isShutdown()) { in scheduleSyncLocked() [all …]
|
/aosp12/frameworks/base/services/core/java/com/android/server/apphibernation/ |
H A D | HibernationStateDiskStore.java | 53 private final ScheduledExecutorService mExecutorService; field in HibernationStateDiskStore 77 mExecutorService = executorService; in HibernationStateDiskStore() 90 if (mExecutorService.isShutdown()) { in scheduleWriteHibernationStates() 101 mFuture = mExecutorService.schedule(this::writeHibernationStates, DISK_WRITE_DELAY, in scheduleWriteHibernationStates()
|
/aosp12/packages/apps/SettingsIntelligence/src/com/android/settings/intelligence/search/ |
H A D | SearchFeatureProviderImpl.java | 53 private ExecutorService mExecutorService; field in SearchFeatureProviderImpl 143 if (mExecutorService == null) { in getExecutorService() 144 mExecutorService = Executors.newCachedThreadPool(); in getExecutorService() 146 return mExecutorService; in getExecutorService()
|
/aosp12/packages/apps/Car/SettingsIntelligence/src/com/android/settings/intelligence/search/car/ |
H A D | CarSearchFeatureProviderImpl.java | 54 private ExecutorService mExecutorService; field in CarSearchFeatureProviderImpl 143 if (mExecutorService == null) { in getExecutorService() 144 mExecutorService = Executors.newCachedThreadPool(); in getExecutorService() 146 return mExecutorService; in getExecutorService()
|
/aosp12/frameworks/base/services/core/java/com/android/server/pm/ |
H A D | ParallelPackageParser.java | 56 private final ExecutorService mExecutorService; field in ParallelPackageParser 60 mExecutorService = executorService; in ParallelPackageParser() 103 mExecutorService.submit(() -> { in submit()
|
/aosp12/packages/apps/ThemePicker/src/com/android/customization/model/themedicon/ |
H A D | ThemedIconSwitchProvider.java | 46 private final ExecutorService mExecutorService = Executors.newSingleThreadExecutor(); field in ThemedIconSwitchProvider 93 mExecutorService.submit(() -> { in fetchThemedIconEnabled() 122 mExecutorService.submit(() -> { in setThemedIconEnabled()
|
/aosp12/frameworks/base/packages/SystemUI/src/com/android/systemui/ |
H A D | UiOffloadThread.java | 34 private final ExecutorService mExecutorService = Executors.newSingleThreadExecutor(); field in UiOffloadThread 41 return mExecutorService.submit(runnable); in execute()
|
/aosp12/packages/services/Car/service/src/com/android/car/systeminterface/ |
H A D | SystemStateInterface.java | 89 private ScheduledExecutorService mExecutorService; field in SystemStateInterface.DefaultImpl 95 mExecutorService.schedule(action.first, 165 mExecutorService = Executors.newScheduledThreadPool(corePoolSize); in scheduleActionForBootCompleted()
|
/aosp12/frameworks/base/packages/BackupEncryption/src/com/android/server/backup/encryption/tasks/ |
H A D | EncryptedFullBackupDataProcessor.java | 51 private final ExecutorService mExecutorService; field in EncryptedFullBackupDataProcessor 71 mExecutorService = Objects.requireNonNull(executorService); in EncryptedFullBackupDataProcessor() 100 mBackupTaskFuture = mExecutorService.submit(mBackupTask); in start()
|
/aosp12/packages/apps/Car/Dialer/src/com/android/car/dialer/ui/common/ |
H A D | UiCallLogLiveData.java | 51 private final ExecutorService mExecutorService; field in UiCallLogLiveData 60 mExecutorService = Executors.newSingleThreadExecutor(); in UiCallLogLiveData() 73 mRunnableFuture = mExecutorService.submit(runnable); in onCallHistoryChanged()
|
/aosp12/frameworks/base/packages/BackupEncryption/test/robolectric/src/com/android/server/backup/encryption/tasks/ |
H A D | EncryptedFullBackupDataProcessorTest.java | 85 private QueuingNonAutomaticExecutorService mExecutorService; field in EncryptedFullBackupDataProcessorTest 93 mExecutorService = new QueuingNonAutomaticExecutorService(); in setUp() 97 mExecutorService, in setUp() 343 mExecutorService.runNext(); in finishBackupTask()
|
/aosp12/packages/modules/GeoTZ/data_pipeline/src/main/java/com/android/timezone/location/data_pipeline/steps/ |
H A D | TzS2PolygonsToTzS2CellUnions.java | 59 private final ExecutorService mExecutorService; field in TzS2PolygonsToTzS2CellUnions 71 this.mExecutorService = Objects.requireNonNull(executorService); in TzS2PolygonsToTzS2CellUnions() 144 mExecutorService.submit(() -> processFile(file, mMaxS2Level, mOutputDir)); in execute()
|
H A D | TzS2CellUnionsToTzS2Ranges.java | 57 private final ExecutorService mExecutorService; field in TzS2CellUnionsToTzS2Ranges 69 this.mExecutorService = Objects.requireNonNull(executorService); in TzS2CellUnionsToTzS2Ranges() 142 mExecutorService.submit(() -> processFile(file)); in execute()
|
H A D | GeoJsonTzToTzS2Polygons.java | 72 private final ExecutorService mExecutorService; field in GeoJsonTzToTzS2Polygons 85 this.mExecutorService = Objects.requireNonNull(executorService); in GeoJsonTzToTzS2Polygons() 172 Future<TzS2Polygons> future = mExecutorService.submit(() -> processFeature(feature)); in execute()
|
H A D | MergeTzS2Ranges.java | 55 private final ExecutorService mExecutorService; field in MergeTzS2Ranges 67 this.mExecutorService = Objects.requireNonNull(executorService); in MergeTzS2Ranges() 171 Future<File> resultFuture = mExecutorService.submit( in createCombinedTzS2Ranges()
|
/aosp12/frameworks/base/core/java/com/android/internal/app/ |
H A D | IntentForwarderActivity.java | 87 protected ExecutorService mExecutorService; field in IntentForwarderActivity 92 mExecutorService.shutdown(); in onDestroy() 99 mExecutorService = Executors.newSingleThreadExecutor(); in onCreate() 157 }, mExecutorService) in onCreate()
|
/aosp12/packages/apps/QuickSearchBox/benchmarks/src/com/android/quicksearchbox/benchmarks/ |
H A D | SourceLatency.java | 42 private ExecutorService mExecutorService; field in SourceLatency 49 mExecutorService = Executors.newSingleThreadExecutor(); in onCreate() 215 mExecutorService.submit(new LiveSourceCheck(src, componentName, query)); in checkLiveSource()
|