Home
last modified time | relevance | path

Searched refs:subscriber (Results 1 – 25 of 26) sorted by relevance

12

/packages/modules/Wifi/tests/hostsidetests/multidevices/test/aware/
Dwifi_aware_test.py46 self.publisher, self.subscriber = self.register_controller(
60 setup_device, ((self.publisher,), (self.subscriber,)),
67 ads=[self.publisher, self.subscriber],
76 self.subscriber.wifi_aware_snippet.attach()
80 self.subscriber.wifi_aware_snippet.subscribe(is_unsolicited, is_ranging_required, False)
82 self.subscriber.wifi_aware_snippet.sendMessage(MESSAGE_ID, TEST_MESSAGE)
91 self.subscriber.wifi_aware_snippet.checkIfPairingSupported()
96 self.subscriber.wifi_aware_snippet.attach()
100 self.subscriber.wifi_aware_snippet.subscribe(is_unsolicited, is_ranging_required, True)
103 (self.subscriber, False, True, True)),
[all …]
/packages/services/Car/service/src/com/android/car/telemetry/publisher/
DStatsPublisher.java218 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber() argument
219 TelemetryProto.Publisher publisherParam = subscriber.getPublisherParam(); in addDataSubscriber()
224 long configKey = buildConfigKey(subscriber); in addDataSubscriber()
225 mConfigKeyToSubscribers.put(configKey, subscriber); in addDataSubscriber()
226 addStatsConfig(configKey, subscriber); in addDataSubscriber()
243 DataSubscriber subscriber = mConfigKeyToSubscribers.get(configKey); in processReport() local
244 if (subscriber == null) { in processReport()
261 switch (subscriber.getPublisherParam().getStats().getSystemMetric()) { in processReport()
295 + subscriber.getPublisherParam().getStats().getSystemMetric() in processReport()
300 subscriber.push(bundle, isBundleLargeData(bundle)); in processReport()
[all …]
DConnectivityPublisher.java143 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber() argument
144 TelemetryProto.Publisher publisherParam = subscriber.getPublisherParam(); in addDataSubscriber()
149 mSubscribers.get(QueryParam.forSubscriber(subscriber)).add(subscriber); in addDataSubscriber()
153 public void removeDataSubscriber(@NonNull DataSubscriber subscriber) { in removeDataSubscriber() argument
154 mSubscribers.get(QueryParam.forSubscriber(subscriber)).remove(subscriber); in removeDataSubscriber()
165 public boolean hasDataSubscriber(@NonNull DataSubscriber subscriber) { in hasDataSubscriber() argument
166 return mSubscribers.get(QueryParam.forSubscriber(subscriber)).contains(subscriber); in hasDataSubscriber()
217 for (DataSubscriber subscriber : subscribers) { in processPreviousSession()
218 subscriber.push(data); in processPreviousSession()
316 static QueryParam forSubscriber(@NonNull DataSubscriber subscriber) { in forSubscriber() argument
[all …]
DMemoryPublisher.java145 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber() argument
150 subscriber.getPublisherParam().getPublisherCase() == PublisherCase.MEMORY, in addDataSubscriber()
153 if (subscriber.getPublisherParam().getMemory().getReadIntervalSec() <= 0) { in addDataSubscriber()
156 if (subscriber.getPublisherParam().getMemory().getMaxPendingTasks() <= 0) { in addDataSubscriber()
162 int numSnapshotsLeft = subscriber.getPublisherParam().getMemory().getMaxSnapshots(); in addDataSubscriber()
175 subscriber, numSnapshotsLeft, collectIndefinitely); in addDataSubscriber()
180 public void removeDataSubscriber(@NonNull DataSubscriber subscriber) { in removeDataSubscriber() argument
181 if (mSubscriber == null || !mSubscriber.mDataSubscriber.equals(subscriber)) { in removeDataSubscriber()
193 public boolean hasDataSubscriber(@NonNull DataSubscriber subscriber) { in hasDataSubscriber() argument
194 return mSubscriber != null && mSubscriber.mDataSubscriber.equals(subscriber); in hasDataSubscriber()
DCarTelemetrydPublisher.java200 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber() argument
201 TelemetryProto.Publisher publisherParam = subscriber.getPublisherParam(); in addDataSubscriber()
221 currentSubscribers.add(subscriber); in addDataSubscriber()
247 public void removeDataSubscriber(@NonNull DataSubscriber subscriber) { in removeDataSubscriber() argument
248 int idToRemove = subscriber.getPublisherParam().getCartelemetryd().getId(); in removeDataSubscriber()
260 currentSubscribers.remove(subscriber); in removeDataSubscriber()
293 public boolean hasDataSubscriber(@NonNull DataSubscriber subscriber) { in hasDataSubscriber() argument
294 int id = subscriber.getPublisherParam().getCartelemetryd().getId(); in hasDataSubscriber()
296 subscriber); in hasDataSubscriber()
DVehiclePropertyPublisher.java101 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber() argument
102 TelemetryProto.Publisher publisherParam = subscriber.getPublisherParam(); in addDataSubscriber()
140 propertyData.subscribers.add(subscriber); in addDataSubscriber()
144 public void removeDataSubscriber(@NonNull DataSubscriber subscriber) { in removeDataSubscriber() argument
145 TelemetryProto.Publisher publisherParam = subscriber.getPublisherParam(); in removeDataSubscriber()
157 propertyData.subscribers.remove(subscriber); in removeDataSubscriber()
178 public boolean hasDataSubscriber(@NonNull DataSubscriber subscriber) { in hasDataSubscriber() argument
179 TelemetryProto.Publisher publisherParam = subscriber.getPublisherParam(); in hasDataSubscriber()
185 && mPropertyDataLookup.get(propertyId).subscribers.contains(subscriber); in hasDataSubscriber()
223 for (DataSubscriber subscriber : propertyData.subscribers) { in pushPendingDataToSubscribers()
[all …]
DAbstractPublisher.java82 public abstract void addDataSubscriber(@NonNull DataSubscriber subscriber); in addDataSubscriber() argument
89 public abstract void removeDataSubscriber(@NonNull DataSubscriber subscriber); in removeDataSubscriber() argument
99 public abstract boolean hasDataSubscriber(@NonNull DataSubscriber subscriber); in hasDataSubscriber() argument
/packages/apps/Car/Settings/tests/robotests/src/com/android/car/settings/testutils/
DShadowNetworkPolicyManager.java40 public static boolean verifyFactoryResetCalled(String subscriber, int numTimes) { in verifyFactoryResetCalled() argument
41 if (!sResetCalledForSubscriberCount.containsKey(subscriber)) return false; in verifyFactoryResetCalled()
42 return sResetCalledForSubscriberCount.get(subscriber) == numTimes; in verifyFactoryResetCalled()
46 protected void factoryReset(String subscriber) { in factoryReset() argument
47 sResetCalledForSubscriberCount.put(subscriber, in factoryReset()
48 sResetCalledForSubscriberCount.getOrDefault(subscriber, 0) + 1); in factoryReset()
/packages/services/Car/service/src/com/android/car/telemetry/databroker/
DScriptExecutionTask.java43 @NonNull DataSubscriber subscriber, in ScriptExecutionTask()
49 mSubscriber = subscriber; in ScriptExecutionTask()
56 @NonNull DataSubscriber subscriber, in ScriptExecutionTask()
61 mSubscriber = subscriber; in ScriptExecutionTask()
DDataBrokerImpl.java316 for (TelemetryProto.Subscriber subscriber : metricsConfig.getSubscribersList()) { in addMetricsConfig()
317 if (subscriber.getPriority() < 0) { in addMetricsConfig()
322 subscriber.getPublisher().getPublisherCase()); in addMetricsConfig()
327 subscriber); in addMetricsConfig()
344 for (DataSubscriber subscriber : dataSubscribers) { in removeMetricsConfig()
346 subscriber.getPublisherParam().getPublisherCase()); in removeMetricsConfig()
348 publisher.removeDataSubscriber(subscriber); in removeMetricsConfig()
DDataSubscriber.java46 @NonNull TelemetryProto.Subscriber subscriber) { in DataSubscriber() argument
49 mSubscriber = subscriber; in DataSubscriber()
/packages/apps/Settings/tests/robotests/src/com/android/settings/datausage/
DDataUsageUtilsTest.java89 final String subscriber = "TestSub"; in hasEthernet_shouldQueryEthernetSummaryForUser() local
90 when(mTelephonyManager.getSubscriberId()).thenReturn(subscriber); in hasEthernet_shouldQueryEthernetSummaryForUser()
95 eq(subscriber), anyLong() /* startTime */, anyLong() /* endTime */); in hasEthernet_shouldQueryEthernetSummaryForUser()
/packages/services/Car/service/src/com/android/car/vms/
DVmsBrokerService.java268 for (VmsClientInfo subscriber : subscribers) { in deliverToSubscribers()
270 callbackConsumer.accept(subscriber.getCallback()); in deliverToSubscribers()
271 mStatsService.getVmsClientLogger(subscriber.getUid()) in deliverToSubscribers()
274 mStatsService.getVmsClientLogger(subscriber.getUid()) in deliverToSubscribers()
276 Slogf.e(TAG, e, "Unable to publish to listener: %s", subscriber.getPackageName()); in deliverToSubscribers()
/packages/apps/CarrierConfig/
DREADME5 based on the subscriber's network. It replaced many XML resource overlays in frameworks/base and
/packages/services/Car/tests/carservice_unit_test/src/com/android/car/telemetry/publisher/
DStatsPublisherTest.java504 DataSubscriber subscriber = spy(new DataSubscriber(null, METRICS_CONFIG, SUBSCRIBER_1)); in testOnInvalidConfig_notifiesPublisherFailureListener() local
505 mPublisher.addDataSubscriber(subscriber); in testOnInvalidConfig_notifiesPublisherFailureListener()
520 verify(subscriber, times(0)).push(any(), anyBoolean()); in testOnInvalidConfig_notifiesPublisherFailureListener()
DConnectivityPublisherTest.java549 TelemetryProto.MetricsConfig metricsConfig, TelemetryProto.Subscriber subscriber) { in FakeDataSubscriber() argument
550 super(/* dataBroker= */ null, metricsConfig, subscriber); in FakeDataSubscriber()
/packages/modules/StatsD/statsd/
DAndroid.bp122 "src/subscriber/IncidentdReporter.cpp",
123 "src/subscriber/SubscriberReporter.cpp",
437 "tests/subscriber/SubscriberReporter_test.cpp",
/packages/modules/StatsD/tests/src/android/cts/statsd/subscriber/
DShellSubscriberTest.java16 package android.cts.statsd.subscriber;
/packages/services/Car/car-lib/src/android/car/telemetry/
Dtelemetry.proto208 // Priority of the subscriber, which affects the order of when it receives data.
/packages/apps/ManagedProvisioning/studio-dev/StubGenerator/
DStubGenerator.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/jf/ org/ ...
/packages/apps/TV/libs/m2/
Dguava-28.0-android.jarMETA-INF/MANIFEST.MF META-INF/ META-INF/maven/ META- ...
Dguava-28.0-jre.jarMETA-INF/MANIFEST.MF META-INF/ META-INF/maven/ META- ...
/packages/apps/TV/libs/
Dgoogle-java-format-1.7-all-deps.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/ ...
/packages/inputmethods/LatinIME/dictionaries/
Den_GB_wordlist.combined.gz
Den_US_wordlist.combined.gz

12