| /packages/services/Telephony/tests/src/com/android/services/telephony/rcs/ |
| D | TransportSipMessageValidatorTest.java | 92 TestExecutorService executor = new TestExecutorService(); in testTransportOpening() local
93 TransportSipMessageValidator tracker = getTestTracker(executor); in testTransportOpening()
110 TestExecutorService executor = new TestExecutorService(); in testTransportOpenConfigChange() local
111 TransportSipMessageValidator tracker = openTransport(executor); in testTransportOpenConfigChange()
121 TestExecutorService executor = new TestExecutorService(); in testSessionTrackerFiltering() local
122 TransportSipMessageValidator tracker = openTransport(executor); in testSessionTrackerFiltering()
149 TestExecutorService executor = new TestExecutorService(true /*wait*/); in testTransportClosingGracefullyNoPendingSessions() local
150 TransportSipMessageValidator tracker = openTransport(executor); in testTransportClosingGracefullyNoPendingSessions()
169 TestExecutorService executor = new TestExecutorService(true /*wait*/); in testTransportClosingGracefullyCloseCallIds() local
170 TransportSipMessageValidator tracker = openTransport(executor); in testTransportClosingGracefullyCloseCallIds()
[all …]
|
| /packages/apps/Settings/src/com/android/settings/sim/smartForwarding/ |
| D | EnableSmartForwardingTask.java | 84 Executor executor = Executors.newSingleThreadExecutor(); in initObject() local
110 new QueryCallWaitingCommand(tm, executor, subId); in initObject()
112 new QueryCallForwardingCommand(tm, executor, subId); in initObject()
114 new UpdateCallWaitingCommand(tm, executor, queryCallWaitingCommand, subId); in initObject()
116 new UpdateCallForwardingCommand(tm, executor, queryCallForwardingCommand, in initObject()
245 Executor executor; field in EnableSmartForwardingTask.QueryCommand
247 public QueryCommand(TelephonyManager tm, Executor executor, int subId) { in QueryCommand() argument
250 this.executor = executor; in QueryCommand()
264 Executor executor; field in EnableSmartForwardingTask.UpdateCommand
266 public UpdateCommand(TelephonyManager tm, Executor executor, int subId) { in UpdateCommand() argument
[all …]
|
| /packages/apps/TV/src/com/android/tv/util/ |
| D | AsyncDbTask.java | 91 @DbExecutor Executor executor, in AsyncQueryTask()
98 super(executor); in AsyncQueryTask()
202 Executor executor, in AsyncQueryListTask() argument
209 this(executor, context, uri, projection, selection, selectionArgs, orderBy, null); in AsyncQueryListTask()
213 Executor executor, in AsyncQueryListTask() argument
221 super(executor, context, uri, projection, selection, selectionArgs, orderBy); in AsyncQueryListTask()
267 Executor executor, in AsyncQueryItemTask() argument
274 super(executor, context, uri, projection, selection, selectionArgs, orderBy); in AsyncQueryItemTask()
314 public AsyncChannelQueryTask(Executor executor, Context context) { in AsyncChannelQueryTask() argument
316 executor, in AsyncChannelQueryTask()
[all …]
|
| /packages/modules/Wifi/framework/java/android/net/wifi/ |
| D | WifiManager.java | 2029 NetworkRequestMatchCallbackProxy(Executor executor, NetworkRequestMatchCallback callback) { in NetworkRequestMatchCallbackProxy() argument
2030 mExecutor = executor; in NetworkRequestMatchCallbackProxy()
2113 public void registerNetworkRequestMatchCallback(@NonNull @CallbackExecutor Executor executor, in registerNetworkRequestMatchCallback() argument
2115 if (executor == null) throw new IllegalArgumentException("executor cannot be null"); in registerNetworkRequestMatchCallback()
2118 + ", executor=" + executor); in registerNetworkRequestMatchCallback()
2123 new NetworkRequestMatchCallbackProxy(executor, callback); in registerNetworkRequestMatchCallback()
3066 OnWifiActivityEnergyInfoProxy(Executor executor, in OnWifiActivityEnergyInfoProxy() argument
3068 mExecutor = executor; in OnWifiActivityEnergyInfoProxy()
3074 Executor executor; in onWifiActivityEnergyInfo() local
3080 executor = mExecutor; in onWifiActivityEnergyInfo()
[all …]
|
| D | WifiScanner.java | 1089 public void registerScanListener(@NonNull @CallbackExecutor Executor executor, in registerScanListener() argument
1091 Objects.requireNonNull(executor, "executor cannot be null"); in registerScanListener()
1093 int key = addListener(listener, executor); in registerScanListener()
1240 public void startScan(ScanSettings settings, @Nullable @CallbackExecutor Executor executor, in startScan() argument
1243 int key = addListener(listener, executor); in startScan()
1314 @NonNull @CallbackExecutor Executor executor, PnoScanListener listener) { in startConnectedPnoScan() argument
1317 int key = addListener(listener, executor); in startConnectedPnoScan()
1336 @NonNull @CallbackExecutor Executor executor, PnoScanListener listener) { in startDisconnectedPnoScan() argument
1339 int key = addListener(listener, executor); in startDisconnectedPnoScan()
1650 private int addListener(ActionListener listener, Executor executor) { in addListener() argument
[all …]
|
| /packages/services/Car/service/src/com/android/car/systeminterface/ |
| 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()
|
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| 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()
|
| /packages/modules/Permission/framework-s/java/android/app/role/ |
| D | RoleManager.java | 340 @CallbackExecutor @NonNull Executor executor, @NonNull Consumer<Boolean> callback) { in addRoleHolderAsUser() argument
344 Objects.requireNonNull(executor, "executor cannot be null"); in addRoleHolderAsUser()
348 createRemoteCallback(executor, callback)); in addRoleHolderAsUser()
378 @CallbackExecutor @NonNull Executor executor, @NonNull Consumer<Boolean> callback) { in removeRoleHolderAsUser() argument
382 Objects.requireNonNull(executor, "executor cannot be null"); in removeRoleHolderAsUser()
386 createRemoteCallback(executor, callback)); in removeRoleHolderAsUser()
414 @NonNull UserHandle user, @CallbackExecutor @NonNull Executor executor, in clearRoleHoldersAsUser() argument
418 Objects.requireNonNull(executor, "executor cannot be null"); in clearRoleHoldersAsUser()
422 createRemoteCallback(executor, callback)); in clearRoleHoldersAsUser()
429 private static RemoteCallback createRemoteCallback(@NonNull Executor executor, in createRemoteCallback() argument
[all …]
|
| D | RoleControllerManager.java | 139 public void grantDefaultRoles(@NonNull @CallbackExecutor Executor executor, in grantDefaultRoles() argument
146 propagateCallback(operation, "grantDefaultRoles", executor, callback); in grantDefaultRoles()
204 @NonNull @CallbackExecutor Executor executor, @NonNull Consumer<Boolean> callback) { in isApplicationVisibleForRole() argument
211 propagateCallback(operation, "isApplicationVisibleForRole", executor, callback); in isApplicationVisibleForRole()
221 @NonNull @CallbackExecutor Executor executor, @NonNull Consumer<Boolean> callback) { in isRoleVisible() argument
227 propagateCallback(operation, "isRoleVisible", executor, callback); in isRoleVisible()
231 @CallbackExecutor @NonNull Executor executor, in propagateCallback() argument
234 .whenComplete((res, err) -> executor.execute(() -> { in propagateCallback()
|
| /packages/services/Car/car-lib/src/android/car/evs/ |
| D | CarEvsManager.java | 286 final Executor executor; in handleServiceStatusChanged() local
289 executor = mStatusListenerExecutor; in handleServiceStatusChanged()
293 executor.execute(() -> listener.onStatusChanged(status)); in handleServiceStatusChanged()
309 public void setStatusListener(@NonNull @CallbackExecutor Executor executor, in setStatusListener() argument
316 Objects.requireNonNull(executor); in setStatusListener()
324 mStatusListenerExecutor = executor; in setStatusListener()
423 final Executor executor; in handleStreamEvent() local
426 executor = mStreamCallbackExecutor; in handleStreamEvent()
430 executor.execute(() -> callback.onStreamEvent(event)); in handleStreamEvent()
450 final Executor executor; in handleNewFrame() local
[all …]
|
| /packages/modules/Connectivity/framework/src/android/net/ |
| D | DnsResolver.java | 188 @NonNull @CallbackExecutor Executor executor, in rawQuery() argument
200 executor.execute(() -> callback.onError(new DnsException(ERROR_SYSTEM, e))); in rawQuery()
205 registerFDListener(executor, queryfd, callback, cancellationSignal, lock); in rawQuery()
229 @NonNull @CallbackExecutor Executor executor, in rawQuery() argument
241 executor.execute(() -> callback.onError(new DnsException(ERROR_SYSTEM, e))); in rawQuery()
245 registerFDListener(executor, queryfd, callback, cancellationSignal, lock); in rawQuery()
337 @NonNull @CallbackExecutor Executor executor, in query() argument
348 executor.execute(() -> callback.onError(new DnsException(ERROR_SYSTEM, e))); in query()
357 executor.execute(() -> callback.onError( in query()
372 executor.execute(() -> callback.onError(new DnsException(ERROR_SYSTEM, e))); in query()
[all …]
|
| /packages/services/Car/car-lib/src/android/car/watchdog/ |
| D | CarWatchdogManager.java | 185 public void registerClient(@NonNull @CallbackExecutor Executor executor, in registerClient() argument
188 Objects.requireNonNull(executor, "Executor must be non-null"); in registerClient()
198 mCallbackExecutor = executor; in registerClient()
480 @NonNull @CallbackExecutor Executor executor, in addResourceOveruseListener()
484 Objects.requireNonNull(executor, "Executor must be non-null"); in addResourceOveruseListener()
491 new ResourceOveruseListenerInfo(listener, executor, resourceOveruseFlag); in addResourceOveruseListener()
560 @NonNull @CallbackExecutor Executor executor, in addResourceOveruseListenerForSystem()
564 Objects.requireNonNull(executor, "Executor must be non-null"); in addResourceOveruseListenerForSystem()
571 new ResourceOveruseListenerInfo(listener, executor, resourceOveruseFlag); in addResourceOveruseListenerForSystem()
747 Executor executor; in checkClientStatus() local
[all …]
|
| /packages/apps/Dialer/java/com/android/incallui/ringtone/ |
| 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()
|
| /packages/apps/DocumentsUI/src/com/android/documentsui/ |
| D | ProviderExecutor.java | 36 ProviderExecutor executor = sExecutors.get(authority); in forAuthority() local
37 if (executor == null) { in forAuthority()
38 executor = new ProviderExecutor(); in forAuthority()
39 executor.setName("ProviderExecutor: " + authority); in forAuthority()
40 executor.start(); in forAuthority()
41 sExecutors.put(authority, executor); in forAuthority()
43 return executor; in forAuthority()
|
| /packages/modules/Connectivity/tests/cts/net/src/android/net/cts/ |
| D | DnsResolverTest.java | 328 public void doTestRawQuery(Executor executor) throws InterruptedException { in doTestRawQuery() argument
333 executor, null, callback); in doTestRawQuery()
341 public void doTestRawQueryBlob(Executor executor) throws InterruptedException { in doTestRawQueryBlob() argument
359 mDns.rawQuery(network, blob, FLAG_NO_CACHE_LOOKUP, executor, null, callback); in doTestRawQueryBlob()
367 public void doTestRawQueryRoot(Executor executor) throws InterruptedException { in doTestRawQueryRoot() argument
373 executor, null, callback); in doTestRawQueryRoot()
382 public void doTestRawQueryNXDomain(Executor executor) throws InterruptedException { in doTestRawQueryNXDomain() argument
396 executor, null, callback); in doTestRawQueryNXDomain()
404 public void doTestRawQueryNXDomainWithPrivateDns(Executor executor) in doTestRawQueryNXDomainWithPrivateDns() argument
418 executor, null, callback); in doTestRawQueryNXDomainWithPrivateDns()
[all …]
|
| /packages/services/Telephony/src/com/android/phone/callcomposer/ |
| D | CallComposerPictureManager.java | 97 Executor executor, in storeCallComposerPictureAsUser() argument
100 input, executor, callback); in storeCallComposerPictureAsUser() local
161 (realm, executor) -> in handleUploadToServer()
162 getGbaCredentials(credentialRefresh, carrierConfig, executor); in handleUploadToServer()
179 (realm, executor) -> getGbaCredentials(false, carrierConfig, executor)); in handleUploadToServer()
212 (realm, executor) -> in handleDownloadFromServer()
213 getGbaCredentials(credentialRefresh, carrierConfig, executor); in handleDownloadFromServer()
243 transfer.downloadPicture(((realm, executor) -> in handleDownloadFromServer()
244 getGbaCredentials(false, carrierConfig, executor))); in handleDownloadFromServer()
305 boolean forceRefresh, PersistableBundle config, Executor executor) { in getGbaCredentials() argument
[all …]
|
| /packages/modules/Wifi/framework/java/android/net/wifi/rtt/ |
| D | WifiRttManager.java | 114 @NonNull @CallbackExecutor Executor executor, @NonNull RangingResultCallback callback) { in startRanging() argument
115 startRanging(null, request, executor, callback); in startRanging()
134 @NonNull @CallbackExecutor Executor executor, @NonNull RangingResultCallback callback) { in startRanging() argument
137 + ", callback=" + callback + ", executor=" + executor); in startRanging()
140 if (executor == null) { in startRanging()
154 executor.execute(() -> callback.onRangingFailure(status)); in startRanging()
161 executor.execute(() -> callback.onRangingResults(results)); in startRanging()
|
| /packages/apps/UniversalMediaPlayer/java/com/android/pump/util/ |
| D | ImageLoader.java | 75 public ImageLoader(@NonNull ContentResolver contentResolver, @NonNull Executor executor) { in ImageLoader() argument
77 mExecutor = executor; in ImageLoader()
84 public void addCallback(@NonNull Callback callback, @NonNull Executor executor) { in addCallback() argument
86 if (!mCallbacks.add(new SimpleEntry<>(executor, callback))) { in addCallback()
96 public void removeCallback(@NonNull Callback callback, @NonNull Executor executor) { in removeCallback() argument
98 if (!mCallbacks.remove(new SimpleEntry<>(executor, callback))) { in removeCallback()
109 @NonNull Executor executor) { in loadImage() argument
121 callbacks.add(new SimpleEntry<>(executor, callback)); in loadImage()
125 executor.execute(() -> callback.onImageLoaded(uri, bitmap)); in loadImage()
|
| /packages/apps/Settings/src/com/android/settings/utils/ |
| D | SensorPrivacyManagerHelper.java | 73 CallbackInfo(Callback callback, Executor executor, int sensor, int userId) { in CallbackInfo() argument
75 mExecutor = executor; in CallbackInfo()
203 public void addSensorBlockedListener(int sensor, Callback callback, Executor executor) { in addSensorBlockedListener() argument
205 mCallbacks.add(new CallbackInfo(callback, executor, sensor, CallbackInfo.CURRENT_USER)); in addSensorBlockedListener()
216 Executor executor) { in addSensorBlockedListener() argument
218 mCallbacks.add(new CallbackInfo(callback, executor, sensor, userId)); in addSensorBlockedListener()
267 Executor executor = callbackInfo.mExecutor; in dispatchStateChangedLocked() local
269 executor.execute(() -> callback.onSensorPrivacyChanged(sensor, blocked)); in dispatchStateChangedLocked()
|
| /packages/apps/Camera2/src/com/android/camera/processing/imagebackend/ |
| D | ImageBackend.java | 250 public void releaseSemaphoreReference(final ImageToProcess img, Executor executor) { in releaseSemaphoreReference() argument
273 closeImageExecutorSafe(img, executor); in releaseSemaphoreReference()
482 public boolean receiveImage(ImageToProcess img, Executor executor, in receiveImage() argument
504 tasksToExecute.add(new TaskPreviewChainedJpeg(img, executor, this, session, in receiveImage()
509 tasksToExecute.add(new TaskCompressImageToJpeg(img, executor, this, session, in receiveImage()
516 tasksToExecute.add(new TaskConvertImageToRGBPreview(img, executor, in receiveImage()
555 ImageToProcess image, Executor executor, ImageBackend imageBackend, in createTaskConvertImageToRGBPreview() argument
558 return new TaskConvertImageToRGBPreview(image, executor, imageBackend, in createTaskConvertImageToRGBPreview()
564 Executor executor, ImageBackend imageBackend, CaptureSession session) { in createTaskCompressImageToJpeg() argument
565 return new TaskCompressImageToJpeg(image, executor, imageBackend, session, in createTaskCompressImageToJpeg()
[all …]
|
| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
| D | MockNamedTaskExecutorFactory.java | 33 for (MockNamedTaskExecutor executor : mExecutors) { in runNext()
34 executor.runNext(); in runNext()
39 MockNamedTaskExecutor executor = new MockNamedTaskExecutor(); in create() local
40 mExecutors.add(executor); in create()
41 return executor; in create()
|
| /packages/services/Telephony/testapps/TestRcsApp/aosp_test_rcsclient/src/com/android/libraries/rcs/simpleclient/filetransfer/requestexecutor/ |
| D | GbaRequestExecutor.java | 44 private final ListeningExecutorService executor = field in GbaRequestExecutor
77 return executor.submit(() -> httpClient.execute(request, context)); in executeAuthenticatedRequest()
79 executor); in executeAuthenticatedRequest()
109 executor); in executeAuthenticatedRequest()
111 executor); in executeAuthenticatedRequest()
113 executor); in executeAuthenticatedRequest()
|
| /packages/apps/Dialer/java/com/android/dialer/common/concurrent/ |
| D | AsyncTaskExecutors.java | 79 private final Executor executor; field in AsyncTaskExecutors.SimpleAsyncTaskExecutor
81 public SimpleAsyncTaskExecutor(Executor executor) { in SimpleAsyncTaskExecutor() argument
82 this.executor = executor; in SimpleAsyncTaskExecutor()
89 return task.executeOnExecutor(executor, params); in submit()
|
| /packages/apps/Launcher3/src/com/android/launcher3/model/ |
| D | BaseLoaderResults.java | 107 protected void executeCallbacksTask(CallbackTask task, Executor executor) { in executeCallbacksTask() argument
108 executor.execute(() -> { in executeCallbacksTask()
238 final ArrayList<ItemInfo> workspaceItems, final Executor executor) { in bindWorkspaceItems() argument
246 executor); in bindWorkspaceItems()
250 private void bindAppWidgets(List<LauncherAppWidgetInfo> appWidgets, Executor executor) { in bindAppWidgets() argument
256 c -> c.bindItems(Collections.singletonList(widget), false), executor); in bindAppWidgets()
260 protected void executeCallbacksTask(CallbackTask task, Executor executor) { in executeCallbacksTask() argument
261 executor.execute(() -> { in executeCallbacksTask()
|
| /packages/services/Car/car-lib/src/android/car/vms/ |
| D | VmsClientManager.java | 107 @NonNull @CallbackExecutor Executor executor, in registerVmsClientCallback()
109 registerVmsClientCallback(executor, callback, false); in registerVmsClientCallback()
117 @NonNull @CallbackExecutor Executor executor, in registerVmsClientCallback()
120 Objects.requireNonNull(executor, "executor cannot be null"); in registerVmsClientCallback()
129 client = new VmsClient(mBrokerService, executor, callback, legacyClient, in registerVmsClientCallback()
149 executor.execute(() -> { in registerVmsClientCallback()
|