| /packages/modules/Bluetooth/framework/java/android/bluetooth/ |
| D | BluetoothLeBroadcastAssistantCallback.java | 49 public void register(@NonNull Executor executor, in register() argument
55 mCallbackMap.put(callback, executor); in register()
108 Executor executor = mCallbackMap.get(cb); in onSearchStarted() local
111 executor.execute(() -> cb.onSearchStarted(reason)); in onSearchStarted()
123 Executor executor = mCallbackMap.get(cb); in onSearchStartFailed() local
126 executor.execute(() -> cb.onSearchStartFailed(reason)); in onSearchStartFailed()
138 Executor executor = mCallbackMap.get(cb); in onSearchStopped() local
141 executor.execute(() -> cb.onSearchStopped(reason)); in onSearchStopped()
153 Executor executor = mCallbackMap.get(cb); in onSearchStopFailed() local
156 executor.execute(() -> cb.onSearchStopFailed(reason)); in onSearchStopFailed()
[all …]
|
| D | BluetoothLeBroadcast.java | 86 Executor executor = callbackExecutorEntry.getValue();
87 executor.execute(() -> callback.onBroadcastStarted(reason, broadcastId));
96 Executor executor = callbackExecutorEntry.getValue();
97 executor.execute(() -> callback.onBroadcastStartFailed(reason));
106 Executor executor = callbackExecutorEntry.getValue();
107 executor.execute(() -> callback.onBroadcastStopped(reason, broadcastId));
116 Executor executor = callbackExecutorEntry.getValue();
117 executor.execute(() -> callback.onBroadcastStopFailed(reason));
126 Executor executor = callbackExecutorEntry.getValue();
127 executor.execute(() -> callback.onPlaybackStarted(reason, broadcastId));
[all …]
|
| /packages/services/Telephony/tests/src/com/android/services/telephony/rcs/ |
| D | TransportSipMessageValidatorTest.java | 99 TestExecutorService executor = new TestExecutorService(); in testTransportOpening() local
100 TransportSipMessageValidator tracker = getTestTracker(executor); in testTransportOpening()
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
164 TransportSipMessageValidator tracker = openTransport(executor); in testSessionTrackerFiltering()
197 TestExecutorService executor = new TestExecutorService(true /*wait*/); in testTransportClosingGracefullyNoPendingSessions() local
198 TransportSipMessageValidator tracker = openTransport(executor); in testTransportClosingGracefullyNoPendingSessions()
[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/modules/AppSearch/framework/java/android/app/appsearch/ |
| D | AppSearchSession.java | 80 @NonNull @CallbackExecutor Executor executor, in createSearchSession() argument
85 searchSession.initialize(executor, callback); in createSearchSession()
91 @NonNull @CallbackExecutor Executor executor, in initialize()
101 safeExecute(executor, callback, () -> { in initialize()
193 @NonNull @CallbackExecutor Executor executor, in getSchema()
195 Objects.requireNonNull(executor); in getSchema()
207 safeExecute(executor, callback, () -> { in getSchema()
231 @NonNull @CallbackExecutor Executor executor, in getNamespaces()
233 Objects.requireNonNull(executor); in getNamespaces()
244 safeExecute(executor, callback, () -> { in getNamespaces()
[all …]
|
| D | GlobalSearchSession.java | 86 @NonNull @CallbackExecutor Executor executor, in createGlobalSearchSession() argument
90 globalSearchSession.initialize(executor, callback); in createGlobalSearchSession()
96 @NonNull @CallbackExecutor Executor executor, in initialize()
106 safeExecute(executor, callback, () -> { in initialize()
156 @NonNull @CallbackExecutor Executor executor, in getByDocumentId() argument
161 Objects.requireNonNull(executor); in getByDocumentId()
175 SearchSessionUtil.createGetDocumentCallback(executor, callback)); in getByDocumentId()
230 @NonNull @CallbackExecutor Executor executor, in reportSystemUsage() argument
233 Objects.requireNonNull(executor); in reportSystemUsage()
250 executor, in reportSystemUsage()
[all …]
|
| /packages/modules/Uwb/framework/java/android/uwb/ |
| D | UwbManager.java | 236 /*package*/ void initProxy(@NonNull Executor executor, in initProxy() argument
239 mExecutor = executor; in initProxy()
255 Executor executor; in onProfileAdfsProvisioned() local
257 executor = mExecutor; in onProfileAdfsProvisioned()
260 if (callback == null || executor == null) { in onProfileAdfsProvisioned()
264 executor.execute(() -> callback.onProfileAdfsProvisioned(params)); in onProfileAdfsProvisioned()
274 Executor executor; in onProfileAdfsProvisionFailed() local
276 executor = mExecutor; in onProfileAdfsProvisionFailed()
279 if (callback == null || executor == null) { in onProfileAdfsProvisionFailed()
283 executor.execute(() -> callback.onProfileAdfsProvisionFailed(reason, params)); in onProfileAdfsProvisionFailed()
[all …]
|
| /packages/modules/Connectivity/framework-t/src/android/net/ |
| D | EthernetManager.java | 263 public void addListener(@NonNull Listener listener, @NonNull Executor executor) { in addListener() argument
264 addInterfaceStateListener(executor, listener); in addListener()
284 public void addInterfaceStateListener(@NonNull Executor executor, in addInterfaceStateListener() argument
286 if (listener == null || executor == null) { in addInterfaceStateListener()
297 executor.execute(() -> in addInterfaceStateListener()
439 public TetheredInterfaceRequest requestTetheredInterface(@NonNull final Executor executor, in requestTetheredInterface() argument
442 Objects.requireNonNull(executor, "Executor must be non-null"); in requestTetheredInterface()
446 executor.execute(() -> callback.onAvailable(iface)); in requestTetheredInterface()
451 executor.execute(() -> callback.onUnavailable()); in requestTetheredInterface()
471 @NonNull final Executor executor, in NetworkInterfaceOutcomeReceiver()
[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/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/modules/AppSearch/service/java/com/android/server/appsearch/util/ |
| D | ExecutorManager.java | 68 ExecutorService executor = mPerUserExecutorsLocked.get(userHandle); in getOrCreateUserExecutor() local
69 if (executor == null) { in getOrCreateUserExecutor()
70 executor = ExecutorManager.createDefaultExecutorService(); in getOrCreateUserExecutor()
71 mPerUserExecutorsLocked.put(userHandle, executor); in getOrCreateUserExecutor()
73 return executor; in getOrCreateUserExecutor()
83 ExecutorService executor; in shutDownAndRemoveUserExecutor() local
85 executor = mPerUserExecutorsLocked.remove(userHandle); in shutDownAndRemoveUserExecutor()
87 if (executor != null) { in shutDownAndRemoveUserExecutor()
88 executor.shutdown(); in shutDownAndRemoveUserExecutor()
94 executor.awaitTermination(30, TimeUnit.SECONDS); in shutDownAndRemoveUserExecutor()
|
| /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/Wifi/framework/java/android/net/wifi/ |
| D | WifiManager.java | 2440 NetworkRequestMatchCallbackProxy(Executor executor, NetworkRequestMatchCallback callback) { in NetworkRequestMatchCallbackProxy() argument
2441 mExecutor = executor; in NetworkRequestMatchCallbackProxy()
2524 public void registerNetworkRequestMatchCallback(@NonNull @CallbackExecutor Executor executor, in registerNetworkRequestMatchCallback() argument
2526 if (executor == null) throw new IllegalArgumentException("executor cannot be null"); in registerNetworkRequestMatchCallback()
2529 + ", executor=" + executor); in registerNetworkRequestMatchCallback()
2534 new NetworkRequestMatchCallbackProxy(executor, callback); in registerNetworkRequestMatchCallback()
3544 OnWifiActivityEnergyInfoProxy(Executor executor, in OnWifiActivityEnergyInfoProxy() argument
3546 mExecutor = executor; in OnWifiActivityEnergyInfoProxy()
3552 Executor executor; in onWifiActivityEnergyInfo() local
3558 executor = mExecutor; in onWifiActivityEnergyInfo()
[all …]
|
| /packages/modules/Connectivity/nearby/framework/java/android/nearby/ |
| D | NearbyManager.java | 156 @CallbackExecutor @NonNull Executor executor, in startScan() argument
160 Objects.requireNonNull(executor, "executor must not be null"); in startScan()
168 executor); in startScan()
171 transport.setExecutor(executor); in startScan()
231 @CallbackExecutor @NonNull Executor executor, @NonNull BroadcastCallback callback) { in startBroadcast() argument
238 transport = new BroadcastListenerTransport(callback, executor); in startBroadcast()
241 transport.setExecutor(executor); in startBroadcast()
313 @CallbackExecutor Executor executor) { in ScanListenerTransport() argument
321 mExecutor = executor; in ScanListenerTransport()
324 void setExecutor(Executor executor) { in setExecutor() argument
[all …]
|
| /packages/modules/Connectivity/framework-t/src/android/net/nsd/ |
| D | NsdManager.java | 419 Executor executor) { in DelegatingDiscoveryListener() argument
422 mWrappedExecutor = executor; in DelegatingDiscoveryListener()
672 final Executor executor; in handleMessage() local
676 executor = mExecutorMap.get(key); in handleMessage()
688 executor.execute(() -> ((DiscoveryListener) listener).onDiscoveryStarted(s)); in handleMessage()
692 executor.execute(() -> ((DiscoveryListener) listener).onStartDiscoveryFailed( in handleMessage()
696 executor.execute(() -> ((DiscoveryListener) listener).onServiceFound( in handleMessage()
700 executor.execute(() -> ((DiscoveryListener) listener).onServiceLost( in handleMessage()
707 executor.execute(() -> ((DiscoveryListener) listener).onStopDiscoveryFailed( in handleMessage()
712 executor.execute(() -> ((DiscoveryListener) listener).onDiscoveryStopped( in handleMessage()
[all …]
|
| /packages/modules/Permission/framework-s/java/android/app/role/ |
| D | RoleManager.java | 358 @CallbackExecutor @NonNull Executor executor, @NonNull Consumer<Boolean> callback) { in addRoleHolderAsUser() argument
362 Objects.requireNonNull(executor, "executor cannot be null"); in addRoleHolderAsUser()
366 createRemoteCallback(executor, callback)); in addRoleHolderAsUser()
396 @CallbackExecutor @NonNull Executor executor, @NonNull Consumer<Boolean> callback) { in removeRoleHolderAsUser() argument
400 Objects.requireNonNull(executor, "executor cannot be null"); in removeRoleHolderAsUser()
404 createRemoteCallback(executor, callback)); in removeRoleHolderAsUser()
432 @NonNull UserHandle user, @CallbackExecutor @NonNull Executor executor, in clearRoleHoldersAsUser() argument
436 Objects.requireNonNull(executor, "executor cannot be null"); in clearRoleHoldersAsUser()
440 createRemoteCallback(executor, callback)); in clearRoleHoldersAsUser()
447 private static RemoteCallback createRemoteCallback(@NonNull Executor executor, in createRemoteCallback() argument
[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/evs/ |
| D | CarEvsManager.java | 307 final Executor executor; in handleServiceStatusChanged() local
310 executor = mStatusListenerExecutor; in handleServiceStatusChanged()
314 executor.execute(() -> listener.onStatusChanged(status)); in handleServiceStatusChanged()
331 public void setStatusListener(@NonNull @CallbackExecutor Executor executor, in setStatusListener() argument
338 Objects.requireNonNull(executor); in setStatusListener()
346 mStatusListenerExecutor = executor; in setStatusListener()
448 final Executor executor; in handleStreamEvent() local
451 executor = mStreamCallbackExecutor; in handleStreamEvent()
455 executor.execute(() -> callback.onStreamEvent(event)); in handleStreamEvent()
475 final Executor executor; in handleNewFrame() local
[all …]
|
| /packages/services/Car/car-lib/src/android/car/telemetry/ |
| D | CarTelemetryManager.java | 286 @CallbackExecutor @NonNull Executor executor, in addMetricsConfig() argument
295 executor.execute(() -> in addMetricsConfig()
359 @CallbackExecutor @NonNull Executor executor, in getFinishedReport() argument
363 metricsConfigName, new CarTelemetryReportListenerImpl(executor, callback)); in getFinishedReport()
384 @CallbackExecutor @NonNull Executor executor, @NonNull MetricsReportCallback callback) { in getAllFinishedReports()
386 mService.getAllFinishedReports(new CarTelemetryReportListenerImpl(executor, callback)); in getAllFinishedReports()
414 @CallbackExecutor @NonNull Executor executor, @NonNull ReportReadyListener listener) { in setReportReadyListener()
418 mReportReadyListenerExecutor.set(executor); in setReportReadyListener()
468 Executor executor = manager.mReportReadyListenerExecutor.get(); in onReady() local
469 if (executor == null) { in onReady()
[all …]
|
| /packages/services/Car/car-lib/src/android/car/hardware/power/ |
| D | CarPowerManager.java | 447 public void setListener(@NonNull @CallbackExecutor Executor executor, in setListener() argument
449 checkArgument(executor != null, "excutor cannot be null"); in setListener()
457 mExecutor = executor; in setListener()
481 public void setListenerWithCompletion(@NonNull @CallbackExecutor Executor executor, in setListenerWithCompletion() argument
483 checkArgument(executor != null, "executor cannot be null"); in setListenerWithCompletion()
491 mExecutor = executor; in setListenerWithCompletion()
613 public void addPowerPolicyListener(@NonNull @CallbackExecutor Executor executor, in addPowerPolicyListener() argument
616 checkArgument(executor != null, "Null executor"); in addPowerPolicyListener()
625 new Pair<>(executor, new CarPowerPolicyFilter(filterComponents)); in addPowerPolicyListener()
717 Executor executor; in setServiceForListenerLocked()
[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/modules/NetworkStack/apishim/33/com/android/networkstack/apishim/api33/ |
| D | NsdShimImpl.java | 66 int protocolType, @NonNull Executor executor, in registerService() argument
68 nsdManager.registerService(serviceInfo, protocolType, executor, listener); in registerService()
74 @NonNull Executor executor, @NonNull NsdManager.DiscoveryListener listener) in discoverServices() argument
76 nsdManager.discoverServices(serviceType, protocolType, network, executor, listener); in discoverServices()
82 @NonNull Executor executor, @NonNull NsdManager.DiscoveryListener listener) in discoverServices() argument
84 nsdManager.discoverServices(serviceType, protocolType, request, executor, listener); in discoverServices()
89 @NonNull Executor executor, @NonNull NsdManager.ResolveListener resolveListener) in resolveService() argument
91 nsdManager.resolveService(serviceInfo, executor, resolveListener); in resolveService()
|
| /packages/services/Car/car-lib/src/android/car/watchdog/ |
| D | CarWatchdogManager.java | 190 public void registerClient(@NonNull @CallbackExecutor Executor executor, in registerClient() argument
193 Objects.requireNonNull(executor, "Executor must be non-null"); in registerClient()
203 mCallbackExecutor = executor; in registerClient()
503 @NonNull @CallbackExecutor Executor executor, in addResourceOveruseListener()
507 Objects.requireNonNull(executor, "Executor must be non-null"); in addResourceOveruseListener()
514 new ResourceOveruseListenerInfo(listener, executor, resourceOveruseFlag); in addResourceOveruseListener()
585 @NonNull @CallbackExecutor Executor executor, in addResourceOveruseListenerForSystem()
589 Objects.requireNonNull(executor, "Executor must be non-null"); in addResourceOveruseListenerForSystem()
596 new ResourceOveruseListenerInfo(listener, executor, resourceOveruseFlag); in addResourceOveruseListenerForSystem()
781 Executor executor; in checkClientStatus() local
[all …]
|
| /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/AppSearch/service/java/com/android/server/appsearch/ |
| D | FrameworkAppSearchConfig.java | 125 public static FrameworkAppSearchConfig create(@NonNull Executor executor) { in create() argument
126 Objects.requireNonNull(executor); in create()
128 configManager.initialize(executor); in create()
139 public static FrameworkAppSearchConfig getInstance(@NonNull Executor executor) { in getInstance() argument
140 Objects.requireNonNull(executor); in getInstance()
144 sConfig = create(executor); in getInstance()
158 private void initialize(@NonNull Executor executor) { in initialize() argument
159 executor.execute(() -> { in initialize()
162 executor, in initialize()
|