| /packages/apps/Car/SystemUI/tests/src/com/android/systemui/car/userswitcher/ |
| D | UserSwitchTransitionViewControllerTest.java | 77 private FakeExecutor mExecutor; field in UserSwitchTransitionViewControllerTest
98 mExecutor = new FakeExecutor(mClock); in setUp()
104 mExecutor, in setUp()
123 mExecutor.advanceClockToLast(); in onHandleShow_newUserSelected_showsDialog()
124 mExecutor.runAllReady(); in onHandleShow_newUserSelected_showsDialog()
133 mExecutor.advanceClockToLast(); in onHandleShow_showsDefaultLoadingMessage()
134 mExecutor.runAllReady(); in onHandleShow_showsDefaultLoadingMessage()
147 mExecutor.advanceClockToLast(); in onHandleShow_showsUserSwitchingMessage()
148 mExecutor.runAllReady(); in onHandleShow_showsUserSwitchingMessage()
157 mExecutor.advanceClockToLast(); in onHandleShow_alreadyShowing_ignoresRequest()
[all …]
|
| /packages/modules/Bluetooth/framework/tests/unit/src/android/bluetooth/ |
| D | CallbackWrapperTest.java | 66 private Executor mExecutor; field in CallbackWrapperTest
73 mExecutor = mLooper.getNewExecutor(); in setUp()
91 () -> mCallbackWrapper.registerCallback(mUnusedCounter, null, mExecutor)); in registerCallback_enforceValidParams()
94 mCallbackWrapper.registerCallback(null, mCallback, mExecutor); in registerCallback_enforceValidParams()
95 assertThat(mCallbackExecutorMap).containsExactly(mCallback, mExecutor); in registerCallback_enforceValidParams()
114 mCallbackWrapper.registerCallback(counter, mCallback, mExecutor); in registerCallback_whenEmpty_callConsumer()
117 assertThat(mCallbackExecutorMap).containsExactly(mCallback, mExecutor); in registerCallback_whenEmpty_callConsumer()
122 mCallbackWrapper.registerCallback(mUnusedCounter, mCallback, mExecutor); in unregisterCallback_whenRegistered_callConsumer()
133 mCallbackWrapper.registerCallback(mUnusedCounter, mCallback, mExecutor); in unregisterCallbackWithNoService_whenRegistered_stillRemovedFromMap()
142 mCallbackWrapper.registerCallback(mUnusedCounter, mCallback, mExecutor); in registerCallback_whenWrapperAlreadyRegisteredToService_doNothing()
[all …]
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/appsearch/ |
| D | AppSearchConsentWorker.java | 92 private final Executor mExecutor = AdServicesExecutors.getBackgroundExecutor(); field in AppSearchConsentWorker
170 mGlobalSearchSession, mExecutor, mUid, apiType, mAdservicesPackageName); in getConsent()
185 mGlobalSearchSession, mExecutor, mUid, apiType, mAdservicesPackageName); in getConsentNullable()
210 dao.writeData(mConsentSearchSession, mPackageIdentifiers, mExecutor); in setConsent()
228 mExecutor, in getAppsWithConsent()
246 mExecutor, in clearAppsWithConsent()
266 mExecutor, in addAppWithConsent()
289 dao.writeData(mAppConsentSearchSession, mPackageIdentifiers, mExecutor); in addAppWithConsent()
316 mExecutor, in removeAppWithConsent()
328 dao.writeData(mAppConsentSearchSession, mPackageIdentifiers, mExecutor); in removeAppWithConsent()
[all …]
|
| /packages/modules/ImsMedia/framework/src/android/telephony/imsmedia/ |
| D | AudioSessionCallback.java | 52 private Executor mExecutor; field in AudioSessionCallback.CallbackBinder
64 mExecutor.execute(() in onOpenSessionSuccess()
77 mExecutor.execute(() -> mLocalCallback.onOpenSessionFailure(error)); in onOpenSessionFailure()
89 mExecutor.execute(() -> mLocalCallback.onSessionClosed()); in onSessionClosed()
102 mExecutor.execute(() -> mLocalCallback.onModifySessionResponse(config, result)); in onModifySessionResponse()
115 mExecutor.execute(() -> mLocalCallback.onAddConfigResponse(config, result)); in onAddConfigResponse()
128 mExecutor.execute(() -> mLocalCallback.onConfirmConfigResponse(config, result)); in onConfirmConfigResponse()
140 mExecutor.execute(() -> mLocalCallback.onFirstMediaPacketReceived(config)); in onFirstMediaPacketReceived()
152 mExecutor.execute(() -> mLocalCallback.onHeaderExtensionReceived(extensions)); in onHeaderExtensionReceived()
164 mExecutor.execute(() -> mLocalCallback.notifyMediaQualityStatus(status)); in notifyMediaQualityStatus()
[all …]
|
| D | VideoSessionCallback.java | 49 private Executor mExecutor; field in VideoSessionCallback.CallbackBinder
61 mExecutor.execute(() in onOpenSessionSuccess()
74 mExecutor.execute(() -> mLocalCallback.onOpenSessionFailure(error)); in onOpenSessionFailure()
86 mExecutor.execute(() -> mLocalCallback.onSessionClosed()); in onSessionClosed()
99 mExecutor.execute(() -> mLocalCallback.onModifySessionResponse(config, result)); in onModifySessionResponse()
111 mExecutor.execute(() -> mLocalCallback.onFirstMediaPacketReceived(config)); in onFirstMediaPacketReceived()
123 mExecutor.execute(() -> mLocalCallback.onPeerDimensionChanged(width, height)); in onPeerDimensionChanged()
135 mExecutor.execute(() -> mLocalCallback.onHeaderExtensionReceived(extensions)); in onHeaderExtensionReceived()
147 mExecutor.execute(() -> mLocalCallback.notifyMediaInactivity(packetType)); in notifyMediaInactivity()
159 mExecutor.execute(() -> mLocalCallback.notifyBitrate(bitrate)); in notifyBitrate()
[all …]
|
| D | TextSessionCallback.java | 47 private Executor mExecutor; field in TextSessionCallback.CallbackBinder
59 mExecutor.execute(() in onOpenSessionSuccess()
72 mExecutor.execute(() -> mLocalCallback.onOpenSessionFailure(error)); in onOpenSessionFailure()
84 mExecutor.execute(() -> mLocalCallback.onSessionClosed()); in onSessionClosed()
97 mExecutor.execute(() -> mLocalCallback.onModifySessionResponse(config, result)); in onModifySessionResponse()
109 mExecutor.execute(() -> mLocalCallback.notifyMediaInactivity(packetType)); in notifyMediaInactivity()
121 mExecutor.execute(() -> mLocalCallback.onRttReceived(text)); in onRttReceived()
128 mExecutor = executor; in setExecutor()
|
| /packages/modules/AppSearch/service/java/com/android/server/appsearch/util/ |
| D | RateLimitedExecutor.java | 41 private final ExecutorService mExecutor; field in RateLimitedExecutor
67 mExecutor = Objects.requireNonNull(executor); in RateLimitedExecutor()
90 mExecutor.execute( in execute()
103 return mExecutor; in getExecutor()
202 mExecutor.execute(lambda); in execute()
207 mExecutor.shutdown(); in shutdown()
212 return mExecutor.shutdownNow(); in shutdownNow()
217 return mExecutor.isShutdown(); in isShutdown()
222 return mExecutor.isTerminated(); in isTerminated()
227 return mExecutor.awaitTermination(timeout, unit); in awaitTermination()
[all …]
|
| /packages/modules/AppSearch/testing/coretests/src/android/app/appsearch/ |
| D | AppSearchSessionUnitTest.java | 41 private final Executor mExecutor = mContext.getMainExecutor(); field in AppSearchSessionUnitTest
51 mAppSearch.createSearchSession(searchContext, mExecutor, future::complete); in setUp()
57 new SetSchemaRequest.Builder().setForceOverride(true).build(), mExecutor, mExecutor, in setUp()
72 mExecutor, mExecutor, schemaFuture::complete); in testGetEmptyNextPage()
82 mExecutor, new BatchResultCallback<String, Void>() { in testGetEmptyNextPage()
104 searchResults.getNextPage(mExecutor, getNextPageFuture::complete); in testGetEmptyNextPage()
111 searchResults.getNextPage(mExecutor, getNextPageFuture::complete); in testGetEmptyNextPage()
125 mExecutor, mExecutor, schemaFuture::complete); in testGetEmptyNextPage_multiPages()
140 mExecutor, new BatchResultCallback<String, Void>() { in testGetEmptyNextPage_multiPages()
164 searchResults.getNextPage(mExecutor, getNextPageFuture::complete); in testGetEmptyNextPage_multiPages()
[all …]
|
| /packages/modules/RemoteKeyProvisioning/system-server/tests/unit/src/android/security/rkp/service/test/ |
| D | RegistrationProxyTests.java | 89 ExecutorService mExecutor; field in RegistrationProxyTests
93 mExecutor = Executors.newSingleThreadExecutor(); in setUp()
158 RegistrationProxy.createAsync(context, FAKE_CALLER_UID, FAKE_IRPC, BIND_TIMEOUT, mExecutor, in serviceNotFound()
160 mExecutor.shutdown(); in serviceNotFound()
176 RegistrationProxy.createAsync(context, FAKE_CALLER_UID, FAKE_IRPC, BIND_TIMEOUT, mExecutor, in tooManyServicesFound()
178 mExecutor.shutdown(); in tooManyServicesFound()
193 RegistrationProxy.createAsync(context, FAKE_CALLER_UID, FAKE_IRPC, BIND_TIMEOUT, mExecutor, in bindServiceAsUserReturnsFalse()
195 mExecutor.shutdown(); in bindServiceAsUserReturnsFalse()
213 RegistrationProxy.createAsync(context, FAKE_CALLER_UID, FAKE_IRPC, BIND_TIMEOUT, mExecutor, in boundRegistrationServiceIsNull()
215 mExecutor.shutdown(); in boundRegistrationServiceIsNull()
[all …]
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/commands/ |
| D | CameraCommandExecutor.java | 83 private ExecutorService mExecutor; field in CameraCommandExecutor
105 if (mExecutor == null) { in execute()
107 mExecutor = mExecutorProvider.get(); in execute()
109 checkNotNull(mExecutor); in execute()
110 return mExecutor.submit(new CommandRunnable(command)); in execute()
121 if (mExecutor != null) { in flush()
122 mExecutor.shutdownNow(); in flush()
125 mExecutor = null; in flush()
136 if (mExecutor != null) { in close()
137 mExecutor.shutdownNow(); in close()
[all …]
|
| /packages/modules/Connectivity/thread/tests/cts/src/android/net/thread/cts/ |
| D | ThreadNetworkControllerTest.java | 157 private ExecutorService mExecutor; field in ThreadNetworkControllerTest
192 mExecutor = Executors.newSingleThreadExecutor(); in setUp()
240 () -> mController.registerStateCallback(mExecutor, callback)); in registerStateCallback_permissionsGranted_returnsCurrentStates()
270 mController.setEnabled(false, mExecutor, newOutcomeReceiver(setFuture1)); in registerStateCallback_returnsUpdatedEnabledStates()
277 mController.setEnabled(true, mExecutor, newOutcomeReceiver(setFuture2)); in registerStateCallback_returnsUpdatedEnabledStates()
296 () -> mController.registerStateCallback(mExecutor, role -> {})); in registerStateCallback_noPermissions_throwsSecurityException()
306 mController.registerStateCallback(mExecutor, callback); in registerStateCallback_alreadyRegistered_throwsIllegalArgumentException()
310 () -> mController.registerStateCallback(mExecutor, callback)); in registerStateCallback_alreadyRegistered_throwsIllegalArgumentException()
318 ACCESS_NETWORK_STATE, () -> mController.registerStateCallback(mExecutor, callback)); in unregisterStateCallback_noPermissions_throwsSecurityException()
335 assertDoesNotThrow(() -> mController.registerStateCallback(mExecutor, callback)); in unregisterStateCallback_callbackRegistered_success()
[all …]
|
| /packages/apps/Car/SystemUI/tests/src/com/android/systemui/car/hvac/ |
| D | HvacControllerTest.java | 92 private FakeExecutor mExecutor; field in HvacControllerTest
101 mExecutor = new FakeExecutor(new FakeSystemClock()); in setUp()
102 mHvacController = new HvacController(mCarServiceProvider, mExecutor, in setUp()
106 mExecutor.advanceClockToLast(); in setUp()
107 mExecutor.runAllReady(); in setUp()
121 mExecutor.advanceClockToLast(); in registerHvacView_viewRegisteredInMapBySubscribingProperty()
122 mExecutor.runAllReady(); in registerHvacView_viewRegisteredInMapBySubscribingProperty()
136 mExecutor.advanceClockToLast(); in registerHvacView_skipHvacPropertiesToGetOnInit()
137 mExecutor.runAllReady(); in registerHvacView_skipHvacPropertiesToGetOnInit()
163 mExecutor.advanceClockToLast(); in registerHvacView_retrieveHvacPropertiesToGetOnInit()
[all …]
|
| /packages/apps/DocumentsUI/tests/functional/com/android/documentsui/services/ |
| D | FileOperationServiceTest.java | 65 private TestScheduledExecutorService mExecutor; field in FileOperationServiceTest
80 mExecutor = new TestScheduledExecutorService(); in setUp()
96 mService.executor = mExecutor; in setUp()
119 mExecutor.runAll(); in tearDown()
131 mExecutor.runAll(); in testRunsCopyJobs()
146 mExecutor.runAll(); in testRunsCopyJobs_AfterExceptionInJobCreation()
156 mExecutor.runAll(); in testRunsCopyJobs_AfterFailure()
164 mExecutor.runAll(); in testRunsCopyJobs_notRunsDeleteJobs()
185 mExecutor.runAll(); in testUpdatesNotification()
195 mExecutor.runAll(); in testStopsUpdatingNotificationAfterFinished()
[all …]
|
| /packages/modules/AdServices/adservices/clients/java/android/adservices/clients/adselection/ |
| D | TestAdSelectionClient.java | 44 private Executor mExecutor; field in TestAdSelectionClient
51 mExecutor = executor; in TestAdSelectionClient()
70 mExecutor, in overrideAdSelectionConfigRemoteInfo()
102 mExecutor,
132 mExecutor,
164 mExecutor,
196 mExecutor,
226 mExecutor,
246 private Executor mExecutor;
270 mExecutor = executor;
[all …]
|
| D | AdSelectionClient.java | 54 private Executor mExecutor; field in AdSelectionClient
61 mExecutor = executor; in AdSelectionClient()
76 mExecutor, in selectAds()
103 mExecutor,
130 mExecutor,
153 mExecutor,
182 mExecutor,
209 mExecutor,
237 mExecutor,
265 mExecutor,
[all …]
|
| /packages/modules/AdServices/adservices/clients/java/android/adservices/clients/customaudience/ |
| D | AdvertisingCustomAudienceClient.java | 50 private final Executor mExecutor; field in AdvertisingCustomAudienceClient
57 mExecutor = executor; in AdvertisingCustomAudienceClient()
70 return mExecutor; in getExecutor()
84 mExecutor, in joinCustomAudience()
110 mExecutor, in fetchAndJoinCustomAudience()
136 mExecutor,
167 mExecutor,
188 private Executor mExecutor;
211 mExecutor = executor;
232 Objects.requireNonNull(mExecutor);
[all …]
|
| D | TestAdvertisingCustomAudienceClient.java | 42 private final Executor mExecutor; field in TestAdvertisingCustomAudienceClient
47 mExecutor = executor; in TestAdvertisingCustomAudienceClient()
66 mExecutor, in overrideCustomAudienceRemoteInfo()
95 mExecutor,
122 mExecutor,
143 private Executor mExecutor;
164 mExecutor = executor;
172 Objects.requireNonNull(mExecutor);
174 return new TestAdvertisingCustomAudienceClient(mContext, mExecutor);
|
| /packages/modules/AdServices/adservices/clients/java/android/adservices/clients/measurement/ |
| D | MeasurementClient.java | 42 private Executor mExecutor; field in MeasurementClient
46 mExecutor = executor; in MeasurementClient()
67 mExecutor, in registerSource()
97 mExecutor,
127 mExecutor,
158 mExecutor,
188 mExecutor,
209 private Executor mExecutor;
222 mExecutor = executor;
231 return new MeasurementClient(mContext, mExecutor);
|
| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
| D | MockNamedTaskExecutor.java | 29 private final MockExecutor mExecutor = new MockExecutor(); field in MockNamedTaskExecutor
32 mExecutor.execute(task); in execute()
36 mExecutor.cancelPendingTasks(); in cancelPendingTasks()
40 mExecutor.close(); in close()
44 return mExecutor.runNext(); in runNext()
49 expected, mExecutor.countPendingTasks()); in assertPendingTaskCount()
|
| /packages/modules/AdServices/adservices/clients/java/android/adservices/clients/signals/ |
| D | ProtectedSignalsClient.java | 41 private final Executor mExecutor; field in ProtectedSignalsClient
48 mExecutor = executor; in ProtectedSignalsClient()
61 return mExecutor; in getExecutor()
71 mExecutor, in updateSignals()
92 private Executor mExecutor;
114 mExecutor = executor;
135 Objects.requireNonNull(mExecutor);
138 return new ProtectedSignalsClient(mContext, mExecutor, protectedSignalsManager);
|
| /packages/modules/Connectivity/thread/framework/java/android/net/thread/ |
| D | ThreadNetworkController.java | 384 private final Executor mExecutor; field in ThreadNetworkController.StateCallbackProxy
388 mExecutor = executor; in StateCallbackProxy()
396 mExecutor.execute(() -> mCallback.onDeviceRoleChanged(deviceRole)); in onDeviceRoleChanged()
406 mExecutor.execute(() -> mCallback.onPartitionIdChanged(partitionId)); in onPartitionIdChanged()
416 mExecutor.execute(() -> mCallback.onThreadEnableStateChanged(enabled)); in onThreadEnableStateChanged()
434 mExecutor.execute( in onEphemeralKeyStateChanged()
525 private final Executor mExecutor; field in ThreadNetworkController.OperationalDatasetCallbackProxy
530 mExecutor = executor; in OperationalDatasetCallbackProxy()
539 mExecutor.execute(() -> mCallback.onActiveOperationalDatasetChanged(activeDataset)); in onActiveOperationalDatasetChanged()
550 mExecutor.execute( in onPendingOperationalDatasetChanged()
[all …]
|
| /packages/modules/Nfc/framework/tests/src/android/nfc/ |
| D | NfcVendorNciCallbackListenerTest.java | 49 @Mock private Executor mExecutor; field in NfcVendorNciCallbackListenerTest
74 mListener.register(mExecutor, mCallback); in testRegisterSingleCallback()
83 mListener.register(mExecutor, mCallback); in testRegisterMultipleCallbacks()
91 mListener.register(mExecutor, mCallback); in testUnregisterSingleCallback()
102 mListener.register(mExecutor, mCallback); in testUnregisterOneOfMultipleCallbacks()
111 mListener.register(mExecutor, mCallback); in testOnVendorResponseReceived()
116 verify(mExecutor).execute(runnableCaptor.capture()); in testOnVendorResponseReceived()
123 mListener.register(mExecutor, mCallback); in testOnVendorNotificationReceived()
128 verify(mExecutor).execute(runnableCaptor.capture()); in testOnVendorNotificationReceived()
|
| /packages/services/Mtp/src/com/android/mtp/ |
| D | RootScanner.java | 58 ExecutorService mExecutor; field in RootScanner
82 if (mExecutor == null) { in resume()
84 mExecutor = Executors.newSingleThreadExecutor(); in resume()
91 mExecutor.execute(mCurrentTask); in resume()
100 if (mExecutor == null) { in pause()
103 mExecutor.shutdownNow(); in pause()
105 if (!mExecutor.awaitTermination(AWAIT_TERMINATION_TIMEOUT, TimeUnit.MILLISECONDS)) { in pause()
110 mExecutor = null; in pause()
|
| /packages/modules/AdServices/adservices/clients/java/android/adservices/clients/topics/ |
| D | AdvertisingTopicsClient.java | 43 private Executor mExecutor; field in AdvertisingTopicsClient
54 mExecutor = executor; in AdvertisingTopicsClient()
73 return mExecutor; in getExecutor()
96 mExecutor, in getTopics()
119 private Executor mExecutor; field in Builder
160 mExecutor = executor; in setExecutor()
179 if (mExecutor == null) { in build()
189 mContext, mExecutor, mSdkName, mRecordObservation, topicsManager); in build()
|
| /packages/modules/Wifi/framework/java/android/net/wifi/usd/ |
| D | UsdManager.java | 145 private final Executor mExecutor; field in UsdManager.PublishSessionCallbackProxy
152 mExecutor = executor; in PublishSessionCallbackProxy()
160 mExecutor.execute(() -> mPublishSessionCallback.onPublishFailed(reasonCode)); in onPublishFailed()
167 mExecutor.execute(() -> mPublishSessionCallback.onPublishStarted( in onPublishStarted()
182 mExecutor.execute(() -> mPublishSessionCallback.onPublishReplied(discoveryResult)); in onPublishReplied()
189 mExecutor.execute(() -> mPublishSessionCallback.onSessionTerminated(reasonCode)); in onPublishSessionTerminated()
196 mExecutor.execute(() -> mPublishSessionCallback.onMessageReceived(peerId, message)); in onMessageReceived()
237 private final Executor mExecutor; field in UsdManager.SubscribeSessionCallbackProxy
243 mExecutor = executor; in SubscribeSessionCallbackProxy()
251 mExecutor.execute(() -> mSubscribeSessionCallback.onSubscribeFailed(reasonCode)); in onSubscribeFailed()
[all …]
|