| /aosp12/frameworks/base/core/java/android/hardware/camera2/impl/ |
| H A D | CameraCaptureSessionImpl.java | 197 if (executor == null) { in captureSingleRequest()
207 executor = CameraDeviceImpl.checkExecutor(executor, callback); in captureSingleRequest()
211 " executor " + executor); in captureSingleRequest()
254 if (executor == null) { in captureBurstRequests()
264 executor = CameraDeviceImpl.checkExecutor(executor, callback); in captureBurstRequests()
321 if (executor == null) { in setSingleRepeatingRequest()
331 executor = CameraDeviceImpl.checkExecutor(executor, callback); in setSingleRepeatingRequest()
376 if (executor == null) { in setRepeatingBurstRequests()
386 executor = CameraDeviceImpl.checkExecutor(executor, callback); in setRepeatingBurstRequests()
392 " executor" + "" + executor); in setRepeatingBurstRequests()
[all …]
|
| /aosp12/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/privacy/ |
| H A D | PrivacyItemControllerTest.kt | 108 executor,
109 executor,
136 executor.runAllReady()
145 executor.runAllReady()
149 executor.runAllReady()
162 executor.runAllReady()
174 executor.runAllReady()
182 executor.runAllReady()
191 executor.runAllReady()
198 executor.runAllReady()
[all …]
|
| H A D | PrivacyItemControllerFlagsTest.kt | 75 executor,
76 executor,
93 executor.runAllReady()
104 executor.runAllReady()
114 executor.runAllReady()
124 executor.runAllReady()
136 executor.runAllReady()
144 executor.runAllReady()
152 executor.runAllReady()
160 executor.runAllReady()
[all …]
|
| /aosp12/frameworks/base/telephony/java/android/telephony/euicc/ |
| H A D | EuiccCardManager.java | 165 public void requestAllProfiles(String cardId, @CallbackExecutor Executor executor, in requestAllProfiles() argument
225 @CallbackExecutor Executor executor, ResultCallback<Void> callback) { in disableProfile() argument
286 @CallbackExecutor Executor executor, ResultCallback<Void> callback) { in setNickname() argument
345 @CallbackExecutor Executor executor, ResultCallback<Void> callback) { in resetMemory() argument
430 @CallbackExecutor Executor executor, ResultCallback<Void> callback) { in setDefaultSmdpAddress() argument
583 @CallbackExecutor Executor executor, ResultCallback<byte[]> callback) { in authenticateServer() argument
664 @CallbackExecutor Executor executor, ResultCallback<byte[]> callback) { in loadBoundProfilePackage() argument
739 executor.execute(() -> callback.onComplete( in listNotifications()
769 executor.execute(() -> callback.onComplete( in retrieveNotificationList()
799 executor.execute(() -> callback.onComplete( in retrieveNotification()
[all …]
|
| /aosp12/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/controls/controller/ |
| H A D | ControlsProviderLifecycleManagerTest.kt | 88 executor,
103 executor.runAllReady()
124 executor,
131 executor.runAllReady()
139 executor.runAllReady()
142 executor.runAllReady()
150 executor.runAllReady()
160 executor.runAllReady()
163 executor.runAllReady()
170 executor.runAllReady()
[all …]
|
| H A D | StatefulControlSubscriberTest.kt | 54 private val executor = FakeExecutor(FakeSystemClock()) regex
70 scs = StatefulControlSubscriber(controller, provider, executor, REQUEST_LIMIT)
77 executor.runAllReady()
85 executor.runAllReady()
94 executor.runAllReady()
105 executor.runAllReady()
113 executor.runAllReady()
120 executor.runAllReady()
125 executor.runAllReady()
135 executor.runAllReady()
[all …]
|
| /aosp12/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/media/ |
| H A D | MediaTimeoutListenerTest.kt | 66 private lateinit var executor: FakeExecutor
80 executor = FakeExecutor(FakeSystemClock())
126 assertThat(executor.numPending()).isEqualTo(1)
147 assertThat(executor.numPending()).isEqualTo(1)
151 assertThat(executor.numPending()).isEqualTo(0)
169 assertThat(executor.numPending()).isEqualTo(1)
186 assertThat(executor.numPending()).isEqualTo(1)
196 assertThat(executor.numPending()).isEqualTo(1)
207 assertThat(executor.numPending()).isEqualTo(0)
225 with(executor) {
[all …]
|
| /aosp12/packages/services/Car/service/src/com/android/car/systeminterface/ |
| H A D | TimeInterface.java | 55 ScheduledExecutorService executor; in scheduleAction() local
57 executor = mExecutor; in scheduleAction()
58 if (executor == null) { in scheduleAction()
59 executor = newSingleThreadScheduledExecutor(); in scheduleAction()
60 mExecutor = executor; in scheduleAction()
63 executor.scheduleAtFixedRate(r, delayMs, delayMs, TimeUnit.MILLISECONDS); in scheduleAction()
68 ScheduledExecutorService executor; in cancelAllActions() local
70 executor = mExecutor; in cancelAllActions()
73 if (executor != null) { in cancelAllActions()
74 executor.shutdownNow(); in cancelAllActions()
|
| /aosp12/packages/services/Telephony/tests/src/com/android/services/telephony/rcs/ |
| H A D | TransportSipMessageValidatorTest.java | 99 TestExecutorService executor = new TestExecutorService(); in testTransportOpening() local
117 TestExecutorService executor = new TestExecutorService(); in testTransportOpenConfigChange() local
118 TransportSipMessageValidator tracker = openTransport(executor); in testTransportOpenConfigChange()
133 TestExecutorService executor = new TestExecutorService(); in testMetricsResponse() local
134 TransportSipMessageValidator tracker = openTransport(executor); in testMetricsResponse()
163 TestExecutorService executor = new TestExecutorService(); in testSessionTrackerFiltering() local
295 executor.executePending(); in testTransportClosingGracefullyTimeout()
333 TestExecutorService executor = new TestExecutorService(); in testTransportClosingForcefully() local
386 executor.executePending(); in setRegStateChangedPendingCallIdsMultipleCalls()
409 executor.executePending(); in setRegStateChangedPendingCallIdsTimeout()
[all …]
|
| /aosp12/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| H A D | PerNameExecutor.java | 39 for (NamedTaskExecutor executor : mExecutors.values()) { in cancelPendingTasks()
40 executor.cancelPendingTasks(); in cancelPendingTasks()
46 for (NamedTaskExecutor executor : mExecutors.values()) { in close()
47 executor.close(); in close()
56 NamedTaskExecutor executor = mExecutors.get(name); in execute() local
57 if (executor == null) { in execute()
58 executor = mExecutorFactory.create(); in execute()
59 mExecutors.put(name, executor); in execute()
61 executor.execute(task); in execute()
|
| /aosp12/packages/apps/Settings/src/com/android/settings/sim/smartForwarding/ |
| H A D | EnableSmartForwardingTask.java | 84 Executor executor = Executors.newSingleThreadExecutor(); in initObject() local
110 new QueryCallWaitingCommand(tm, executor, subId); in initObject()
245 Executor executor; field in EnableSmartForwardingTask.QueryCommand
250 this.executor = executor; in QueryCommand()
264 Executor executor; field in EnableSmartForwardingTask.UpdateCommand
269 this.executor = executor; in UpdateCommand()
285 super(tm, executor, subId); in QueryCallWaitingCommand()
318 super(tm, executor, subId); in QueryCallForwardingCommand()
324 .getCallForwarding(REASON_NOT_REACHABLE, executor, in process()
354 super(tm, executor, subId); in UpdateCallWaitingCommand()
[all …]
|
| /aosp12/packages/apps/TV/src/com/android/tv/util/ |
| H A D | AsyncDbTask.java | 91 @DbExecutor Executor executor, in AsyncQueryTask()
98 super(executor); in AsyncQueryTask()
202 Executor executor, in AsyncQueryListTask() argument
213 Executor executor, in AsyncQueryListTask() argument
267 Executor executor, in AsyncQueryItemTask() argument
316 executor, in AsyncChannelQueryTask()
337 executor, in AsyncProgramQueryTask()
347 Executor executor, in AsyncProgramQueryTask() argument
355 executor, in AsyncProgramQueryTask()
404 executor, in LoadProgramsForChannelTask()
[all …]
|
| /aosp12/frameworks/base/telephony/java/android/telephony/ims/ |
| H A D | ImsRcsManager.java | 116 mExecutor = executor; in CapabilityBinder()
148 AvailabilityCallbackAdapter(@NonNull Executor executor, in AvailabilityCallbackAdapter() argument
150 mBinder = new CapabilityBinder(listener, executor); in AvailabilityCallbackAdapter()
205 @NonNull @CallbackExecutor Executor executor, in registerImsRegistrationCallback()
211 if (executor == null) { in registerImsRegistrationCallback()
222 c.setExecutor(executor); in registerImsRegistrationCallback()
288 if (executor == null) { in getRegistrationState()
312 executor.execute(() -> stateCallback.accept( in getRegistrationState()
338 if (executor == null) { in getRegistrationTransportType()
363 executor.execute(() -> transportTypeCallback.accept( in getRegistrationTransportType()
[all …]
|
| H A D | RcsUceAdapter.java | 380 mExecutor = executor; in PublishStateBinder()
400 public PublishStateCallbackAdapter(@NonNull Executor executor, in PublishStateCallbackAdapter() argument
402 mBinder = new PublishStateBinder(executor, listener); in PublishStateCallbackAdapter()
502 @NonNull @CallbackExecutor Executor executor, in requestCapabilities() argument
507 if (executor == null) { in requestCapabilities()
535 executor.execute(() -> c.onComplete()); in requestCapabilities()
544 executor.execute(() -> c.onError(errorCode, retryAfterMilliseconds)); in requestCapabilities()
596 @NonNull @CallbackExecutor Executor executor, in requestAvailability() argument
598 if (executor == null) { in requestAvailability()
629 executor.execute(() -> c.onComplete()); in requestAvailability()
[all …]
|
| /aosp12/frameworks/base/core/java/android/service/carrier/ |
| H A D | CarrierMessagingServiceWrapper.java | 80 @NonNull @CallbackExecutor Executor executor, in bindToCarrierMessagingService() argument
85 Objects.requireNonNull(executor); in bindToCarrierMessagingService()
92 mServiceReadyCallbackExecutor = executor; in bindToCarrierMessagingService()
174 @NonNull @CallbackExecutor final Executor executor, in sendTextSms() argument
203 @NonNull @CallbackExecutor final Executor executor, in sendDataSms() argument
209 callback, executor)); in sendDataSms()
233 @NonNull @CallbackExecutor final Executor executor, in sendMultipartTextSms() argument
259 @NonNull @CallbackExecutor final Executor executor, in sendMms() argument
284 @NonNull @CallbackExecutor final Executor executor, in downloadMms() argument
395 final Executor executor) { in CarrierMessagingCallbackInternal() argument
[all …]
|
| /aosp12/frameworks/base/apex/appsearch/framework/java/android/app/appsearch/ |
| H A D | AppSearchSession.java | 82 searchSession.initialize(executor, callback); in createSearchSession()
98 executor.execute(() -> { in initialize()
193 Objects.requireNonNull(executor); in getSchema()
230 Objects.requireNonNull(executor); in getNamespaces()
281 Objects.requireNonNull(executor); in put()
330 Objects.requireNonNull(executor); in getByDocumentId()
386 executor.execute( in getByDocumentId()
485 Objects.requireNonNull(executor); in reportUsage()
536 Objects.requireNonNull(executor); in remove()
591 Objects.requireNonNull(executor); in remove()
[all …]
|
| /aosp12/frameworks/base/core/java/android/permission/ |
| H A D | LegacyPermissionManager.java | 133 @NonNull @CallbackExecutor Executor executor, @NonNull Consumer<Boolean> callback) { in grantDefaultPermissionsToLuiApp() argument
137 executor.execute(() -> callback.accept(true)); in grantDefaultPermissionsToLuiApp()
154 @NonNull @CallbackExecutor Executor executor, @NonNull Consumer<Boolean> callback) { in revokeDefaultPermissionsFromLuiApps() argument
158 executor.execute(() -> callback.accept(true)); in revokeDefaultPermissionsFromLuiApps()
175 @NonNull @CallbackExecutor Executor executor, @NonNull Consumer<Boolean> callback) { in grantDefaultPermissionsToEnabledImsServices() argument
179 executor.execute(() -> callback.accept(true)); in grantDefaultPermissionsToEnabledImsServices()
196 @NonNull @CallbackExecutor Executor executor, @NonNull Consumer<Boolean> callback) { in grantDefaultPermissionsToEnabledTelephonyDataServices() argument
200 executor.execute(() -> callback.accept(true)); in grantDefaultPermissionsToEnabledTelephonyDataServices()
221 executor.execute(() -> callback.accept(true)); in revokeDefaultPermissionsFromDisabledTelephonyDataServices()
237 @NonNull UserHandle user, @NonNull @CallbackExecutor Executor executor, in grantDefaultPermissionsToEnabledCarrierApps() argument
[all …]
|
| /aosp12/frameworks/base/core/java/android/hardware/camera2/ |
| H A D | CameraManager.java | 365 if (executor == null) { in registerAvailabilityCallback()
425 if (executor == null) { in registerTorchCallback()
673 executor, in openCameraDeviceUserAsync()
854 if (executor == null) { in openCamera()
918 if (executor == null) { in openCamera()
1853 final Executor executor) { in postSingleAccessPriorityChangeUpdate() argument
1856 executor.execute( in postSingleAccessPriorityChangeUpdate()
1872 executor.execute( in postSingleCameraOpenedUpdate()
1888 executor.execute( in postSingleCameraClosedUpdate()
1905 executor.execute( in postSingleUpdate()
[all …]
|
| /aosp12/frameworks/base/core/java/android/net/ |
| H A D | EthernetManager.java | 55 li.executor.execute(() ->
64 public final Executor executor; field in EthernetManager.ListenerInfo
68 private ListenerInfo(@NonNull Executor executor, @NonNull Listener listener) { in ListenerInfo() argument
69 this.executor = executor; in ListenerInfo()
173 public void addListener(@NonNull Listener listener, @NonNull Executor executor) { in addListener() argument
174 if (listener == null || executor == null) { in addListener()
178 mListeners.add(new ListenerInfo(executor, listener)); in addListener()
295 public TetheredInterfaceRequest requestTetheredInterface(@NonNull final Executor executor, in requestTetheredInterface() argument
298 Objects.requireNonNull(executor, "Executor must be non-null"); in requestTetheredInterface()
302 executor.execute(() -> callback.onAvailable(iface)); in requestTetheredInterface()
[all …]
|
| /aosp12/art/tools/dexfuzz/src/dexfuzz/fuzzers/ |
| H A D | Fuzzer.java | 108 for (Executor executor : executors) { in shutdown()
109 executor.shutdown(); in shutdown()
231 executor.reset(); in execute()
233 executor.execute(programName); in execute()
234 if (!executor.didTargetVerify()) { in execute()
312 for (Executor executor : executors) { in analyseResults()
314 timedOut.add(executor); in analyseResults()
316 didNotTimeOut.add(executor); in analyseResults()
329 for (Executor executor : executors) { in analyseResults()
333 executor.getResult().getFlattenedOutputWithNewlines(), executor); in analyseResults() local
[all …]
|
| /aosp12/frameworks/base/core/tests/coretests/src/android/widget/ |
| H A D | AppWidgetHostViewTest.java | 86 RunnableList executor = new RunnableList(); in asyncInflation() local
87 mHostView.setExecutor(executor); in asyncInflation()
93 assertEquals(1, executor.size()); in asyncInflation()
96 executor.get(0).run(); in asyncInflation()
103 RunnableList executor = new RunnableList(); in asyncInflation_cancelled() local
104 mHostView.setExecutor(executor); in asyncInflation_cancelled()
111 assertEquals(2, executor.size()); in asyncInflation_cancelled()
113 assertTrue(((Future) executor.get(0)).isCancelled()); in asyncInflation_cancelled()
116 executor.get(0).run(); in asyncInflation_cancelled()
117 executor.get(1).run(); in asyncInflation_cancelled()
|
| /aosp12/frameworks/base/tools/aapt2/xml/ |
| H A D | XmlActionExecutor_test.cpp | 27 XmlActionExecutor executor; in TEST() local
28 XmlNodeAction& manifest_action = executor["manifest"]; in TEST()
47 ASSERT_TRUE(executor.Execute(XmlActionExecutorPolicy::kNone, &diag, doc.get())); in TEST()
56 XmlActionExecutor executor; in TEST() local
57 executor["manifest"]["application"]; in TEST()
63 ASSERT_FALSE(executor.Execute(XmlActionExecutorPolicy::kAllowList, &diag, doc.get())); in TEST()
66 ASSERT_FALSE(executor.Execute(XmlActionExecutorPolicy::kAllowList, &diag, doc.get())); in TEST()
|
| /aosp12/packages/services/Car/car-lib/src/android/car/evs/ |
| H A D | CarEvsManager.java | 286 final Executor executor; in handleServiceStatusChanged() local
289 executor = mStatusListenerExecutor; in handleServiceStatusChanged()
316 Objects.requireNonNull(executor); in setStatusListener()
324 mStatusListenerExecutor = executor; in setStatusListener()
423 final Executor executor; in handleStreamEvent() local
426 executor = mStreamCallbackExecutor; in handleStreamEvent()
450 final Executor executor; in handleNewFrame() local
453 executor = mStreamCallbackExecutor; in handleNewFrame()
539 @NonNull @CallbackExecutor Executor executor, in startVideoStream() argument
545 Objects.requireNonNull(executor); in startVideoStream()
[all …]
|
| /aosp12/packages/apps/Dialer/java/com/android/incallui/ringtone/ |
| H A D | InCallTonePlayer.java | 40 @NonNull private final PausableExecutor executor; field in InCallTonePlayer
53 @NonNull ToneGeneratorFactory toneGeneratorFactory, @NonNull PausableExecutor executor) { in InCallTonePlayer() argument
55 this.executor = Objects.requireNonNull(executor); in InCallTonePlayer()
76 executor.execute( in play()
115 executor.milestone(); in playOnBackgroundThread()
119 executor.milestone(); in playOnBackgroundThread()
131 executor.milestone(); in playOnBackgroundThread()
|
| /aosp12/packages/modules/Permission/framework-s/java/android/app/role/ |
| H A D | RoleManager.java | 344 Objects.requireNonNull(executor, "executor cannot be null"); in addRoleHolderAsUser()
348 createRemoteCallback(executor, callback)); in addRoleHolderAsUser()
382 Objects.requireNonNull(executor, "executor cannot be null"); in removeRoleHolderAsUser()
386 createRemoteCallback(executor, callback)); in removeRoleHolderAsUser()
418 Objects.requireNonNull(executor, "executor cannot be null"); in clearRoleHoldersAsUser()
422 createRemoteCallback(executor, callback)); in clearRoleHoldersAsUser()
431 return new RemoteCallback(result -> executor.execute(() -> { in createRemoteCallback()
462 Objects.requireNonNull(executor, "executor cannot be null"); in addOnRoleHoldersChangedListenerAsUser()
780 getRoleControllerManager().isRoleVisible(roleName, executor, callback); in isRoleVisible()
824 OnRoleHoldersChangedListenerDelegate(@NonNull Executor executor, in OnRoleHoldersChangedListenerDelegate() argument
[all …]
|