Home
last modified time | relevance | path

Searched refs:receivers (Results 1 – 25 of 58) sorted by relevance

123

/packages/modules/StatsD/statsd/src/external/
DStatsPullerManager.cpp156 auto& receivers = mReceivers[{.atomTag = tagId, .configKey = configKey}]; in RegisterReceiver() local
157 for (auto it = receivers.begin(); it != receivers.end(); it++) { in RegisterReceiver()
159 VLOG("Receiver already registered of %d", (int)receivers.size()); in RegisterReceiver()
177 receivers.push_back(receiverInfo); in RegisterReceiver()
185 VLOG("Puller for tagId %d registered of %d", tagId, (int)receivers.size()); in RegisterReceiver()
196 std::list<ReceiverInfo>& receivers = receiversIt->second; in UnRegisterReceiver() local
197 for (auto it = receivers.begin(); it != receivers.end(); it++) { in UnRegisterReceiver()
199 receivers.erase(it); in UnRegisterReceiver()
200 VLOG("Puller for tagId %d unregistered of %d", tagId, (int)receivers.size()); in UnRegisterReceiver()
230 vector<ReceiverInfo*> receivers; in OnAlarmFired() local
[all …]
/packages/modules/adb/client/
Dtransport_mdns.cpp90 std::vector<std::unique_ptr<ServiceReceiver>> receivers; member
173 g_state->receivers.push_back(std::move(receiver)); in StartDiscovery()
176 for (auto& r : g_state->receivers) { in StartDiscovery()
251 if (!g_state || g_state->receivers.empty()) { in adb_secure_connect_by_service_name()
260 ForEachService(g_state->receivers[kADBSecureConnectServiceRefIndex], instance_name, cb); in adb_secure_connect_by_service_name()
284 if (!g_state || g_state->receivers.empty()) { in mdns_list_discovered_services()
295 for (const auto& receiver : g_state->receivers) { in mdns_list_discovered_services()
308 if (!g_state || g_state->receivers.empty()) { in mdns_get_connect_service_info()
335 ForEachService(g_state->receivers[*index], mdns_instance->instance_name, cb); in mdns_get_connect_service_info()
346 ForEachService(g_state->receivers[kADBSecureConnectServiceRefIndex], name, cb); in mdns_get_connect_service_info()
[all …]
/packages/modules/StatsD/tests/src/android/cts/statsd/subscriber/
DShellSubscriberTest.java115 CollectingByteOutputReceiver[] receivers = new CollectingByteOutputReceiver[maxSubs + 1]; in testShellMaxSubscriptions() local
135 receivers[i] = new CollectingByteOutputReceiver(); in testShellMaxSubscriptions()
138 new ShellSubscriptionThread(firstSubCmd, receivers[i], firstSubTimeout); in testShellMaxSubscriptions()
141 new ShellSubscriptionThread(cmd, receivers[i], timeout); in testShellMaxSubscriptions()
163 checkOutput(receivers[i]); in testShellMaxSubscriptions()
169 receivers[i] = new CollectingByteOutputReceiver(); in testShellMaxSubscriptions()
171 new ShellSubscriptionThread(cmd, receivers[i], timeout); in testShellMaxSubscriptions()
181 receivers[maxSubs] = new CollectingByteOutputReceiver(); in testShellMaxSubscriptions()
183 new ShellSubscriptionThread(cmd, receivers[maxSubs], timeout); in testShellMaxSubscriptions()
203 checkOutput(receivers[i]); in testShellMaxSubscriptions()
[all …]
/packages/apps/WallpaperPicker2/tests/robotests/src/com/android/wallpaper/picker/broadcast/
DBroadcastDispatcherTest.kt86 val receivers = shadowApplication.registeredReceivers in <lambda>() constant
87 val capturedReceiver = receivers.find { it.broadcastReceiver is BroadcastReceiver } in <lambda>()
108 val receivers = shadowApplication.registeredReceivers in <lambda>() constant
109 val isRegistered = receivers.any { it.broadcastReceiver == broadcastReceiver } in <lambda>()
122 val receivers = shadowApplication.registeredReceivers in <lambda>() constant
123 val isUnregistered = receivers.none { it.broadcastReceiver == broadcastReceiver } in <lambda>()
/packages/modules/AdServices/shared/libraries/host-side/java/com/android/adservices/shared/testing/
DTestDeviceHelper.java184 String receivers = runShellCommand("pm query-receivers --components -a %s", intent); in isActiveReceiver() local
187 if (receivers.contains(packageAndFullClass)) { in isActiveReceiver()
196 return receivers.contains(packageAndShortClass); in isActiveReceiver()
/packages/apps/Contacts/src/com/android/contacts/vcard/
DExportVCardActivity.java113 final List<ResolveInfo> receivers = getPackageManager().queryIntentActivities(intent, in hasExportIntentHandler() local
115 return receivers != null && receivers.size() > 0; in hasExportIntentHandler()
/packages/services/Car/tests/EmbeddedKitchenSinkApp/src/com/google/android/car/kitchensink/admin/
DDevicePolicyFragment.java194 List<ResolveInfo> receivers = pm.queryBroadcastReceivers( in setAdminApps() local
196 if (receivers.isEmpty()) { in setAdminApps()
200 Log.i(TAG, receivers.size() + " receivers for " + ACTION_DEVICE_ADMIN_ENABLED); in setAdminApps()
202 String[] entries = new String[receivers.size()]; in setAdminApps()
204 for (ResolveInfo receiver : receivers) { in setAdminApps()
/packages/apps/Settings/src/com/android/settings/development/
DVerifyAppsOverUsbPreferenceController.java152 final List<ResolveInfo> receivers = mPackageManager.queryBroadcastReceivers( in shouldBeEnabled() local
154 return !receivers.isEmpty(); in shouldBeEnabled()
/packages/services/Car/tests/android_car_api_test/src/android/car/apitest/
DCarApiTestBase.java127 Collection<String> receivers = mContext.getReceiversInfo(); in checkReceiversUnregisters() local
131 assertWithMessage("Broadcast receivers that are not unregistered: %s", receivers) in checkReceiversUnregisters()
132 .that(receivers).isEmpty(); in checkReceiversUnregisters()
/packages/apps/Car/Settings/src/com/android/car/settings/enterprise/
DDeviceAdminAppsPreferenceController.java67 List<ResolveInfo> receivers = mPm.queryBroadcastReceivers( in updateState() local
70 for (ResolveInfo resolveInfo : receivers) { in updateState()
/packages/modules/StatsD/service/java/com/android/server/stats/
DStatsCompanionService.java636 private void registerStatsdDeathRecipient(IStatsd statsd, List<BroadcastReceiver> receivers) { in registerStatsdDeathRecipient() argument
637 StatsdDeathRecipient deathRecipient = new StatsdDeathRecipient(statsd, receivers); in registerStatsdDeathRecipient()
644 for (BroadcastReceiver receiver : receivers) { in registerStatsdDeathRecipient()
798 StatsdDeathRecipient(IStatsd statsd, List<BroadcastReceiver> receivers) { in StatsdDeathRecipient() argument
800 mReceiversToUnregister = receivers; in StatsdDeathRecipient()
/packages/modules/DeviceLock/DeviceLockController/src/com/android/devicelockcontroller/receivers/
DResumeProvisionReceiver.java17 package com.android.devicelockcontroller.receivers;
DTimeChangedBroadcastReceiver.java17 package com.android.devicelockcontroller.receivers;
DRecordBootTimestampReceiver.java17 package com.android.devicelockcontroller.receivers;
DProvisionReadyReceiver.java17 package com.android.devicelockcontroller.receivers;
DFinalizationBootCompletedReceiver.java17 package com.android.devicelockcontroller.receivers;
/packages/apps/Settings/src/com/android/settings/sim/receivers/
DSimCompleteBootReceiver.java17 package com.android.settings.sim.receivers;
DSuwFinishReceiver.java17 package com.android.settings.sim.receivers;
DSimSlotChangeService.kt16 package com.android.settings.sim.receivers
/packages/modules/DeviceLock/DeviceLockController/tests/robolectric/src/com/android/devicelockcontroller/receivers/
DTimeChangedBroadcastReceiverTest.java17 package com.android.devicelockcontroller.receivers;
DResumeProvisionReceiverTest.java17 package com.android.devicelockcontroller.receivers;
DFinalizationBootCompletedReceiverTest.java17 package com.android.devicelockcontroller.receivers;
DRecordBootTimestampReceiverTest.java17 package com.android.devicelockcontroller.receivers;
/packages/modules/DeviceLock/DeviceLockController/src/com/android/devicelockcontroller/debug/
DDeviceLockCommandReceiver.java58 import com.android.devicelockcontroller.receivers.NextProvisionFailedStepReceiver;
59 import com.android.devicelockcontroller.receivers.ResetDeviceReceiver;
60 import com.android.devicelockcontroller.receivers.ResumeProvisionReceiver;
/packages/apps/Settings/tests/unit/src/com/android/settings/sim/receivers/
DSimSlotChangeServiceTest.java17 package com.android.settings.sim.receivers;

123