Searched refs:subscriber (Results 1 – 14 of 14) sorted by relevance
44 public void addDataSubscriber(DataSubscriber subscriber) { in addDataSubscriber() argument46 onDataSubscriberAdded(subscriber); in addDataSubscriber()47 mDataSubscribers.add(subscriber); in addDataSubscriber()55 public void removeDataSubscriber(DataSubscriber subscriber) { in removeDataSubscriber() argument56 if (!mDataSubscribers.remove(subscriber)) { in removeDataSubscriber()59 onDataSubscribersRemoved(Collections.singletonList(subscriber)); in removeDataSubscriber()75 protected abstract void onDataSubscriberAdded(DataSubscriber subscriber); in onDataSubscriberAdded() argument
75 protected void onDataSubscriberAdded(DataSubscriber subscriber) { in onDataSubscriberAdded() argument76 TelemetryProto.Publisher publisherParam = subscriber.getPublisherParam(); in onDataSubscriberAdded()109 for (DataSubscriber subscriber : getDataSubscribers()) { in onVehicleEvent()110 TelemetryProto.Publisher publisherParam = subscriber.getPublisherParam(); in onVehicleEvent()115 subscriber.push(bundle); in onVehicleEvent()
40 public static boolean verifyFactoryResetCalled(String subscriber, int numTimes) { in verifyFactoryResetCalled() argument41 if (!sResetCalledForSubscriberCount.containsKey(subscriber)) return false; in verifyFactoryResetCalled()42 return sResetCalledForSubscriberCount.get(subscriber) == numTimes; in verifyFactoryResetCalled()46 protected void factoryReset(String subscriber) { in factoryReset() argument47 sResetCalledForSubscriberCount.put(subscriber, in factoryReset()48 sResetCalledForSubscriberCount.getOrDefault(subscriber, 0) + 1); in factoryReset()
61 for (TelemetryProto.Subscriber subscriber : metricsConfig.getSubscribersList()) { in addMetricsConfiguration()64 subscriber.getPublisher().getPublisherCase()); in addMetricsConfiguration()67 DataSubscriber dataSubscriber = new DataSubscriber(metricsConfig, subscriber); in addMetricsConfiguration()91 for (DataSubscriber subscriber : dataSubscribers) { in removeMetricsConfiguration()93 subscriber.getPublisherParam().getPublisherCase()); in removeMetricsConfiguration()95 publisher.removeDataSubscriber(subscriber); in removeMetricsConfiguration()
30 TelemetryProto.Subscriber subscriber) { in DataSubscriber() argument31 mSubscriber = subscriber; in DataSubscriber()
241 .filter(subscriber -> subscriber.isSubscribed(providerId, layer)) in deliverToSubscribers()253 for (VmsClientInfo subscriber : subscribers) { in deliverToSubscribers()255 callbackConsumer.accept(subscriber.getCallback()); in deliverToSubscribers()256 mStatsService.getVmsClientLogger(subscriber.getUid()) in deliverToSubscribers()259 mStatsService.getVmsClientLogger(subscriber.getUid()) in deliverToSubscribers()262 subscriber.getPackageName()), e); in deliverToSubscribers()
89 final String subscriber = "TestSub"; in hasEthernet_shouldQueryEthernetSummaryForUser() local90 when(mTelephonyManager.getSubscriberId()).thenReturn(subscriber); in hasEthernet_shouldQueryEthernetSummaryForUser()95 eq(subscriber), anyLong() /* startTime */, anyLong() /* endTime */); in hasEthernet_shouldQueryEthernetSummaryForUser()
82 "src/subscriber/IncidentdReporter.cpp",83 "src/subscriber/SubscriberReporter.cpp",316 "tests/subscriber/SubscriberReporter_test.cpp",
5 based on the subscriber's network. It replaced many XML resource overlays in frameworks/base and
73 // Name of the script function that's invoked when this subscriber is triggered.
16 package android.cts.statsd.subscriber;
1dictionary=main:en_gb,locale=en_GB,description=English (UK),date ...
1dictionary=main:en,locale=en,description=English,date=1414726273, ...