| /packages/services/Telephony/src/com/android/services/telephony/rcs/ |
| D | UceControllerManager.java | 55 private final ExecutorService mExecutorService; field in UceControllerManager
64 mExecutorService = Executors.newSingleThreadExecutor(); 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()
[all …]
|
| D | SipTransportController.java | 182 mExecutorService.execute(() -> { in onCallbackDied()
255 private final ScheduledExecutorService mExecutorService; field in SipTransportController
305 mExecutorService = Executors.newSingleThreadScheduledExecutor(); 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()
344 mExecutorService.submit(this::onCarrierConfigChangedInternal); in onCarrierConfigChanged()
349 mExecutorService.submit(()-> { in onDestroy()
355 .thenRun(mExecutorService::shutdown); in onDestroy()
[all …]
|
| D | SipDelegateController.java | 75 requestedConfig, transportDeniedTags, mExecutorService, stateCallbacks); in create()
82 private final ScheduledExecutorService mExecutorService; field in SipDelegateController
99 mExecutorService = executorService; in SipDelegateController()
120 mExecutorService = executorService; in SipDelegateController()
246 }, mExecutorService);
275 }, mExecutorService);
354 }, mExecutorService);
385 new DelegateRequest(supportedSet), deniedSet, mExecutorService, stateCallbacks);
|
| /packages/services/Telephony/tests/src/com/android/services/telephony/rcs/ |
| 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()
494 assertTrue(waitForExecutorAction(mExecutorService, TIMEOUT_MS)); in createTwoAndDestroyOlder()
593 waitForExecutorAction(mExecutorService, TIMEOUT_MS); in testSubIdChangeDestroyTriggered()
[all …]
|
| D | SipDelegateControllerTest.java | 76 private ScheduledExecutorService mExecutorService; field in SipDelegateControllerTest
82 mExecutorService = new TestExecutorService(); in setUp()
87 mExecutorService.shutdownNow(); in tearDown()
291 return new SipDelegateController(TEST_SUB_ID, request, "", mExecutorService, in getTestDelegateController()
|
| D | UceControllerManagerTest.java | 55 private final ExecutorService mExecutorService = new TestExecutorService(); field in UceControllerManagerTest
262 mExecutorService, mUceController); in getUceControllerManager()
|
| /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/apps/Contacts/src/com/android/contacts/vcard/ |
| 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()
|
| /packages/apps/Car/SettingsIntelligence/src/com/android/settings/intelligence/search/car/ |
| 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()
|
| /packages/apps/SettingsIntelligence/src/com/android/settings/intelligence/search/ |
| 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()
|
| /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/Car/libs/car-telephony-common/src/com/android/car/telephony/common/ |
| D | AsyncQueryLiveData.java | 42 private final ExecutorService mExecutorService; field in AsyncQueryLiveData
55 mExecutorService = executorService; in AsyncQueryLiveData()
87 mCurrentRunnableFuture = mExecutorService.submit(mCurrentCursorRunnable); in onCursorLoaded()
|
| /packages/apps/ThemePicker/src/com/android/customization/model/themedicon/ |
| D | ThemedIconSwitchProvider.java | 46 private final ExecutorService mExecutorService = Executors.newSingleThreadExecutor(); field in ThemedIconSwitchProvider
93 mExecutorService.submit(() -> { in fetchThemedIconEnabled()
122 mExecutorService.submit(() -> { in setThemedIconEnabled()
|
| /packages/services/Car/service/src/com/android/car/systeminterface/ |
| D | SystemStateInterface.java | 89 private ScheduledExecutorService mExecutorService; field in SystemStateInterface.DefaultImpl
95 mExecutorService.schedule(action.first,
165 mExecutorService = Executors.newScheduledThreadPool(corePoolSize); in scheduleActionForBootCompleted()
|
| /packages/apps/Car/Dialer/src/com/android/car/dialer/ui/common/ |
| D | UiCallLogLiveData.java | 52 private final ExecutorService mExecutorService; field in UiCallLogLiveData
61 mExecutorService = Executors.newSingleThreadExecutor(); in UiCallLogLiveData()
74 mRunnableFuture = mExecutorService.submit(runnable); in onCallHistoryChanged()
|
| /packages/modules/GeoTZ/data_pipeline/src/main/java/com/android/timezone/location/data_pipeline/steps/ |
| 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()
|
| 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()
|
| 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()
|
| 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()
|
| /packages/apps/QuickSearchBox/benchmarks/src/com/android/quicksearchbox/benchmarks/ |
| 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()
|
| /packages/services/Telephony/testapps/TestRcsApp/TestApp/src/com/google/android/sample/rcsclient/ |
| D | ProvisioningActivity.java | 64 private final ExecutorService mExecutorService = Executors.newSingleThreadExecutor(); field in ProvisioningActivity
181 mProvisioningManager.registerRcsProvisioningCallback(mExecutorService, in init()
|
| D | GbaActivity.java | 56 private final ExecutorService mExecutorService = Executors.newSingleThreadExecutor(); field in GbaActivity
134 mExecutorService, in initLayout()
|
| D | DelegateActivity.java | 84 private final ExecutorService mExecutorService = Executors.newSingleThreadExecutor(); field in DelegateActivity
232 mExecutorService, mConnectionCallback, mMessageCallback); in init()
|