| /aosp12/packages/apps/Car/SystemUI/tests/src/com/android/systemui/car/userswitcher/ |
| H A D | UserSwitchTransitionViewControllerTest.java | 72 mExecutor, in setUp()
86 mExecutor.runAllReady(); in onHandleShow_newUserSelected_showsDialog()
96 mExecutor.runAllReady(); in onHandleShow_alreadyShowing_ignoresRequest()
99 mExecutor.runAllReady(); in onHandleShow_alreadyShowing_ignoresRequest()
110 mExecutor.runAllReady(); in onHandleShow_sameUserSelected_ignoresRequest()
113 mExecutor.runAllReady(); in onHandleShow_sameUserSelected_ignoresRequest()
116 mExecutor.runAllReady(); in onHandleShow_sameUserSelected_ignoresRequest()
127 mExecutor.runAllReady(); in onHide_currentlyShowing_hidesDialog()
130 mExecutor.runAllReady(); in onHide_currentlyShowing_hidesDialog()
140 mExecutor.runAllReady(); in onHide_notShowing_ignoresRequest()
[all …]
|
| /aosp12/frameworks/base/apex/appsearch/testing/java/com/android/server/appsearch/testing/ |
| H A D | AppSearchSessionShimImpl.java | 61 private final ExecutorService mExecutor; field in AppSearchSessionShimImpl
98 mExecutor = Objects.requireNonNull(executor); in AppSearchSessionShimImpl()
105 mAppSearchSession.setSchema(request, mExecutor, mExecutor, future::set); in setSchema()
106 return Futures.transformAsync(future, this::transformResult, mExecutor); in setSchema()
113 mAppSearchSession.getSchema(mExecutor, future::set); in getSchema()
121 mAppSearchSession.getNamespaces(mExecutor, future::set); in getNamespaces()
131 request, mExecutor, new BatchResultCallbackAdapter<>(future)); in put()
142 request, mExecutor, new BatchResultCallbackAdapter<>(future)); in getByDocumentId()
151 return new SearchResultsShimImpl(searchResults, mExecutor); in search()
158 mAppSearchSession.reportUsage(request, mExecutor, future::set); in reportUsage()
[all …]
|
| /aosp12/packages/apps/Camera2/src/com/android/camera/one/v2/commands/ |
| H A 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 …]
|
| /aosp12/frameworks/base/core/java/android/telephony/ |
| H A D | TelephonyCallback.java | 1401 private Executor mExecutor; field in TelephonyCallback.IPhoneStateListenerStub
1405 mExecutor = executor; in IPhoneStateListenerStub()
1533 () -> mExecutor.execute( in onPreciseDataConnectionStateChanged()
1556 () -> mExecutor.execute( in onVoiceActivationStateChanged()
1566 () -> mExecutor.execute( in onDataActivationStateChanged()
1576 () -> mExecutor.execute( in onUserMobileDataStateChanged()
1585 () -> mExecutor.execute( in onDisplayInfoChanged()
1608 () -> mExecutor.execute( in onEmergencyNumberListChanged()
1619 () -> mExecutor.execute( in onOutgoingEmergencyCall()
1631 () -> mExecutor.execute( in onOutgoingEmergencySms()
[all …]
|
| H A D | PhoneStateListener.java | 1335 private Executor mExecutor; field in PhoneStateListener.IPhoneStateListenerStub
1339 mExecutor = executor; in IPhoneStateListenerStub()
1466 () -> mExecutor.execute( in onPreciseDataConnectionStateChanged()
1475 () -> mExecutor.execute( in onDataConnectionRealTimeInfoChanged()
1492 () -> mExecutor.execute( in onVoiceActivationStateChanged()
1501 () -> mExecutor.execute( in onDataActivationStateChanged()
1510 () -> mExecutor.execute( in onUserMobileDataStateChanged()
1519 () -> mExecutor.execute( in onDisplayInfoChanged()
1544 () -> mExecutor.execute( in onEmergencyNumberListChanged()
1554 () -> mExecutor.execute( in onOutgoingEmergencyCall()
[all …]
|
| /aosp12/frameworks/base/core/tests/coretests/src/android/app/appsearch/ |
| H A D | AppSearchSessionUnitTest.java | 45 private final Executor mExecutor = mContext.getMainExecutor(); field in AppSearchSessionUnitTest
61 new SetSchemaRequest.Builder().setForceOverride(true).build(), mExecutor, mExecutor, in setUp()
86 mExecutor, new BatchResultCallback<String, Void>() { in testPutDocument_throwsNullException()
117 mExecutor, mExecutor, schemaFuture::complete); in testGetEmptyNextPage()
127 mExecutor, new BatchResultCallback<String, Void>() { in testGetEmptyNextPage()
149 searchResults.getNextPage(mExecutor, getNextPageFuture::complete); in testGetEmptyNextPage()
156 searchResults.getNextPage(mExecutor, getNextPageFuture::complete); in testGetEmptyNextPage()
170 mExecutor, mExecutor, schemaFuture::complete); in testGetEmptyNextPage_multiPages()
185 mExecutor, new BatchResultCallback<String, Void>() { in testGetEmptyNextPage_multiPages()
209 searchResults.getNextPage(mExecutor, getNextPageFuture::complete); in testGetEmptyNextPage_multiPages()
[all …]
|
| /aosp12/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/util/concurrency/ |
| H A D | RepeatableExecutorTest.java | 40 private RepeatableExecutor mExecutor; field in RepeatableExecutorTest
48 mExecutor = new RepeatableExecutorImpl(mFakeExecutor); in setUp()
56 mExecutor.execute(mCountingTask); in testExecute()
64 mExecutor.executeRepeatedly(mCountingTask, DELAY, DELAY); in testRepeats()
76 mExecutor.executeRepeatedly(mCountingTask, 2 * DELAY, DELAY); in testNoExecutionBeforeStartDelay()
86 mExecutor.executeRepeatedly(mCountingTask, 2 * DELAY, DELAY); in testExecuteAfterStartDelay()
98 mExecutor.executeRepeatedly(mCountingTask, 0L, DELAY); in testExecuteWithZeroStartDelay()
108 mExecutor.executeRepeatedly(mCountingTask, DELAY, DELAY); in testAdvanceTimeTwice()
122 Runnable cancel = mExecutor.executeRepeatedly(mCountingTask, DELAY, DELAY); in testCancel()
135 Runnable cancel = mExecutor.executeRepeatedly(mCountingTask, DELAY, DELAY); in testCancelAfterStart()
|
| /aosp12/frameworks/base/core/java/android/hardware/camera2/impl/ |
| H A D | CallbackProxies.java | 40 private final Executor mExecutor; field in CallbackProxies.SessionStateCallbackProxy
45 mExecutor = checkNotNull(executor, "executor must not be null"); in SessionStateCallbackProxy()
53 mExecutor.execute(() -> mCallback.onConfigured(session)); in onConfigured()
64 mExecutor.execute(() -> mCallback.onConfigureFailed(session)); in onConfigureFailed()
74 mExecutor.execute(() -> mCallback.onReady(session)); in onReady()
84 mExecutor.execute(() -> mCallback.onActive(session)); in onActive()
94 mExecutor.execute(() -> mCallback.onCaptureQueueEmpty(session)); in onCaptureQueueEmpty()
104 mExecutor.execute(() -> mCallback.onClosed(session)); in onClosed()
114 mExecutor.execute(() -> mCallback.onSurfacePrepared(session, surface)); in onSurfacePrepared()
|
| /aosp12/packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
| H A 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()
|
| H A D | PerNameExecutorTest.java | 33 private NamedTaskExecutor mExecutor; field in PerNameExecutorTest
40 mExecutor = new PerNameExecutor(mExecutorFactory); in setUp()
70 mExecutor.cancelPendingTasks(); // cancel a2 in testCancelPendingTasks()
91 mExecutor.execute(a1); in testClose()
94 mExecutor.close(); in testClose()
96 mExecutor.close(); in testClose()
102 mExecutor.execute(task); in addTask()
|
| /aosp12/packages/apps/DocumentsUI/tests/functional/com/android/documentsui/services/ |
| H A D | FileOperationServiceTest.java | 117 mExecutor.runAll(); in tearDown()
129 mExecutor.runAll(); in testRunsCopyJobs()
144 mExecutor.runAll(); in testRunsCopyJobs_AfterExceptionInJobCreation()
154 mExecutor.runAll(); in testRunsCopyJobs_AfterFailure()
162 mExecutor.runAll(); in testRunsCopyJobs_notRunsDeleteJobs()
183 mExecutor.runAll(); in testUpdatesNotification()
193 mExecutor.runAll(); in testStopsUpdatingNotificationAfterFinished()
214 mExecutor.runAll(); in testReleasesWakeLock_AfterSuccess()
267 mExecutor.run(0); in testRunsInForeground_MultipleJobs()
278 mExecutor.run(0); in testFinishesInBackground_MultipleJobs()
[all …]
|
| /aosp12/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/keyguard/ |
| H A D | KeyguardIndicationRotateTextViewControllerTest.java | 64 private DelayableExecutor mExecutor; field in KeyguardIndicationRotateTextViewControllerTest
124 verify(mExecutor).executeDelayed(any(), anyLong()); in testShowTwoRotatingMessages()
154 reset(mExecutor); in testUpdateRotatingMessageForUndisplayedIndication()
178 reset(mExecutor); in testUpdateImmediately()
189 verify(mExecutor).executeDelayed(any(), anyLong()); in testUpdateImmediately()
193 reset(mExecutor); in testUpdateImmediately()
202 verify(mExecutor).executeDelayed(any(), anyLong()); in testUpdateImmediately()
211 reset(mExecutor); in testSameMessage_noIndicationUpdate()
231 reset(mExecutor); in testTransientIndication()
240 verify(mExecutor).executeDelayed(any(), anyLong()); in testTransientIndication()
[all …]
|
| /aosp12/frameworks/base/telephony/java/android/service/euicc/ |
| H A D | EuiccService.java | 310 private ThreadPoolExecutor mExecutor; field in EuiccService
383 mExecutor = new ThreadPoolExecutor( in onCreate()
397 mExecutor.allowCoreThreadTimeOut(true); in onCreate()
403 mExecutor.shutdownNow(); in onDestroy()
662 mExecutor.execute(new Runnable() { in downloadSubscription()
691 mExecutor.execute(new Runnable() { in getEid()
707 mExecutor.execute(new Runnable() { in startOtaIfNecessary()
726 mExecutor.execute(new Runnable() { in getOtaStatus()
744 mExecutor.execute(new Runnable() { in getDownloadableSubscriptionMetadata()
762 mExecutor.execute(new Runnable() { in getDefaultDownloadableSubscriptionList()
[all …]
|
| /aosp12/frameworks/base/core/java/android/window/ |
| H A D | TaskOrganizer.java | 46 private final Executor mExecutor; field in TaskOrganizer
55 mExecutor = executor != null ? executor : Runnable::run; in TaskOrganizer()
246 return mExecutor; in getExecutor()
258 mExecutor.execute(() -> TaskOrganizer.this.removeStartingWindow(removalInfo));
263 mExecutor.execute(() -> TaskOrganizer.this.copySplashScreenView(taskId));
268 mExecutor.execute(() -> TaskOrganizer.this.onAppSplashScreenViewRemoved(taskId));
273 mExecutor.execute(() -> TaskOrganizer.this.onTaskAppeared(taskInfo, leash));
278 mExecutor.execute(() -> TaskOrganizer.this.onTaskVanished(taskInfo));
283 mExecutor.execute(() -> TaskOrganizer.this.onTaskInfoChanged(info));
288 mExecutor.execute(() -> TaskOrganizer.this.onBackPressedOnTaskRoot(info));
[all …]
|
| H A D | TaskFragmentOrganizer.java | 56 private final Executor mExecutor; field in TaskFragmentOrganizer
59 mExecutor = executor; in TaskFragmentOrganizer()
67 return mExecutor; in getExecutor()
172 mExecutor.execute(
178 mExecutor.execute(
184 mExecutor.execute(
191 mExecutor.execute(
199 mExecutor.execute(() -> TaskFragmentOrganizer.this.onTaskFragmentError(
|
| /aosp12/frameworks/base/telephony/java/android/telephony/ims/aidl/ |
| H A D | SipDelegateConnectionAidlWrapper.java | 62 mExecutor.execute(() ->
74 mExecutor.execute(() ->
86 mExecutor.execute(() ->
97 mExecutor.execute(() ->
109 mExecutor.execute(() ->
123 mExecutor.execute(() ->
134 mExecutor.execute(() ->
145 mExecutor.execute(() ->
154 private final Executor mExecutor; field in SipDelegateConnectionAidlWrapper
167 mExecutor = executor; in SipDelegateConnectionAidlWrapper()
[all …]
|
| /aosp12/frameworks/base/packages/SystemUI/src/com/android/systemui/util/sensors/ |
| H A D | AsyncSensorManager.java | 59 private final Executor mExecutor; field in AsyncSensorManager
66 mExecutor = threadFactory.buildExecutorOnNewThread("async_sensor"); in AsyncSensorManager()
89 mExecutor.execute(() -> { in registerListenerImpl()
121 mExecutor.execute(() -> mInner.registerDynamicSensorCallback(callback, handler)); in registerDynamicSensorCallbackImpl()
126 mExecutor.execute(() -> mInner.unregisterDynamicSensorCallback(callback)); in unregisterDynamicSensorCallbackImpl()
137 mExecutor.execute(() -> { in requestTriggerSensorImpl()
150 mExecutor.execute(() -> { in cancelTriggerSensorImpl()
170 mExecutor.execute(() -> { in registerPluginListener()
186 mExecutor.execute(() -> { in unregisterPluginListener()
206 mExecutor.execute(() -> mInner.setOperationParameter(parameter)); in setOperationParameterImpl()
[all …]
|
| /aosp12/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/telephony/ |
| H A D | TelephonyListenerManagerTest.java | 49 private FakeExecutor mExecutor = new FakeExecutor(new FakeSystemClock()); field in TelephonyListenerManagerTest
59 mTelephonyManager, mExecutor, mTelephonyCallback); in setUp()
71 .registerTelephonyCallback(mExecutor, mTelephonyCallback); in testAddListenerRegisters_ActiveDataSubscriptionIdListener()
83 .registerTelephonyCallback(mExecutor, mTelephonyCallback); in testAddListenerRegisters_CallStateListener()
95 .registerTelephonyCallback(mExecutor, mTelephonyCallback); in testAddListenerRegisters_ServiceStateListener()
109 .registerTelephonyCallback(mExecutor, mTelephonyCallback); in testAddListenerRegisters_mixed()
120 .registerTelephonyCallback(mExecutor, mTelephonyCallback); in testRemoveListenerUnregisters_ActiveDataSubscriptionIdListener()
140 .registerTelephonyCallback(mExecutor, mTelephonyCallback); in testRemoveListenerUnregisters_CallStateListener()
160 .registerTelephonyCallback(mExecutor, mTelephonyCallback); in testRemoveListenerUnregisters_ServiceStateListener()
182 .registerTelephonyCallback(mExecutor, mTelephonyCallback); in testRemoveListenerUnregisters_mixed()
[all …]
|
| /aosp12/frameworks/base/telephony/java/android/telephony/mbms/ |
| H A D | InternalStreamingServiceCallback.java | 27 private final Executor mExecutor; field in InternalStreamingServiceCallback
33 mExecutor = executor; in InternalStreamingServiceCallback()
44 mExecutor.execute(new Runnable() { in onError()
63 mExecutor.execute(new Runnable() { in onStreamStateUpdated()
82 mExecutor.execute(new Runnable() { in onMediaDescriptionUpdated()
101 mExecutor.execute(new Runnable() { in onBroadcastSignalStrengthUpdated()
120 mExecutor.execute(new Runnable() { in onStreamMethodUpdated()
|
| H A D | InternalGroupCallSessionCallback.java | 26 private final Executor mExecutor; field in InternalGroupCallSessionCallback
33 mExecutor = executor; in InternalGroupCallSessionCallback()
44 mExecutor.execute(new Runnable() { in onError()
63 mExecutor.execute(new Runnable() { in onAvailableSaisUpdated()
82 mExecutor.execute(new Runnable() { in onServiceInterfaceAvailable()
101 mExecutor.execute(new Runnable() { in onMiddlewareReady()
|
| /aosp12/frameworks/base/services/tests/wmtests/src/com/android/server/wm/ |
| H A D | WindowManagerConstantsTest.java | 48 ExecutorService mExecutor; field in WindowManagerConstantsTest
55 mExecutor = Executors.newSingleThreadExecutor(); in setUp()
64 mExecutor.shutdown(); in tearDown()
75 mConstants.start(mExecutor); in test_constantsAreLoaded_initially()
84 mConstants.start(mExecutor); in test_constantsAreLoaded_afterChange()
100 mConstants.start(mExecutor); in test_changedGestureExclusionLimit_invokesCallback()
110 mConstants.start(mExecutor); in test_changedPreQStickyImmersive_invokesCallback()
122 mConstants.start(mExecutor); in test_minimumExclusionLimitIs_200dp()
|
| /aosp12/packages/apps/Car/SystemUI/tests/src/com/android/systemui/car/systembar/ |
| H A D | PrivacyChipViewControllerTest.java | 99 private Executor mExecutor; field in PrivacyChipViewControllerTest
123 when(mContext.getMainExecutor()).thenReturn(mExecutor); in setUp()
147 verify(mExecutor).execute(mRunnableArgumentCaptor.capture()); in addPrivacyChipView_privacyChipViewPresent_micStatusSet()
206 verify(mExecutor, times(3)) in onPrivacyItemsChanged_micIsNotPartOfPrivacyItems_animateOutCalled()
225 verify(mExecutor, times(3)) in onPrivacyItemsChanged_micIsNotPartOfPrivacyItemsTwice_animateOutCalledOnce()
242 verify(mExecutor).execute(mRunnableArgumentCaptor.capture()); in onPrivacyItemsChanged_qsTileNotifyUpdateRunnableExecuted()
254 reset(mExecutor); in onSensorPrivacyChanged_argTrue_setMicrophoneEnabledWithFalseCalled()
270 reset(mExecutor); in onSensorPrivacyChanged_argFalse_setMicrophoneEnabledWithTrueCalled()
287 reset(mExecutor); in onSensorPrivacyChanged_qsTileNotifyUpdateRunnableExecuted()
305 reset(mExecutor); in onUserUpdateReceive_setMicrophoneEnabledCalled()
[all …]
|
| /aosp12/packages/services/Mtp/src/com/android/mtp/ |
| H A 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()
|
| /aosp12/packages/services/Mtp/tests/src/com/android/mtp/ |
| H A D | PipeManagerTest.java | 33 private ExecutorService mExecutor; field in PipeManagerTest
40 mExecutor = Executors.newSingleThreadExecutor(); in setUp()
42 mPipeManager = new PipeManager(mDatabase, mExecutor); in setUp()
83 mExecutor.shutdown(); in assertDescriptor()
84 assertTrue(mExecutor.awaitTermination(1000, TimeUnit.MILLISECONDS)); in assertDescriptor()
97 mExecutor.shutdown(); in assertDescriptorError()
98 assertTrue(mExecutor.awaitTermination(1000, TimeUnit.MILLISECONDS)); in assertDescriptorError()
|
| /aosp12/packages/services/Telephony/src/com/android/services/telephony/rcs/ |
| H A D | SipDelegateBinderConnection.java | 58 protected final Executor mExecutor; field in SipDelegateBinderConnection
72 mExecutor.execute(() ->
84 mExecutor.execute(() -> {
100 mExecutor.execute(() -> {
117 mExecutor.execute(() -> {
132 mExecutor.execute(() -> notifySipDelegateDestroyed(reason));
171 mExecutor = executor; in SipDelegateBinderConnection()
197 mExecutor.execute(() -> notifySipDelegateDestroyed(reason)); in destroy()
202 mExecutor.execute(() -> notifySipDelegateDestroyed(reason)); in destroy()
261 mExecutor.execute(() -> { in binderDied()
|