Home
last modified time | relevance | path

Searched refs:dataSubscriber (Results 1 – 4 of 4) sorted by relevance

/packages/services/Car/tests/carservice_unit_test/src/com/android/car/telemetry/publisher/
DMemoryPublisherTest.java197 DataSubscriber dataSubscriber = mock(DataSubscriber.class); in testAddDataSubscriber_whenMatchingPackageName_pullsDeviceAndProcessMeminfo() local
198 when(dataSubscriber.getSubscriber()).thenReturn( in testAddDataSubscriber_whenMatchingPackageName_pullsDeviceAndProcessMeminfo()
201 when(dataSubscriber.getPublisherParam()).thenReturn( in testAddDataSubscriber_whenMatchingPackageName_pullsDeviceAndProcessMeminfo()
204 mPublisher.addDataSubscriber(dataSubscriber); in testAddDataSubscriber_whenMatchingPackageName_pullsDeviceAndProcessMeminfo()
206 assertThat(mPublisher.hasDataSubscriber(dataSubscriber)).isTrue(); in testAddDataSubscriber_whenMatchingPackageName_pullsDeviceAndProcessMeminfo()
207 verify(dataSubscriber).push(mBundleCaptor.capture(), anyBoolean()); in testAddDataSubscriber_whenMatchingPackageName_pullsDeviceAndProcessMeminfo()
243 DataSubscriber dataSubscriber = mock(DataSubscriber.class); in testAddDataSubscriber_multipleMatchingPackageName_pullsDeviceAndProcessMeminfo() local
244 when(dataSubscriber.getSubscriber()).thenReturn( in testAddDataSubscriber_multipleMatchingPackageName_pullsDeviceAndProcessMeminfo()
247 when(dataSubscriber.getPublisherParam()).thenReturn( in testAddDataSubscriber_multipleMatchingPackageName_pullsDeviceAndProcessMeminfo()
250 mPublisher.addDataSubscriber(dataSubscriber); in testAddDataSubscriber_multipleMatchingPackageName_pullsDeviceAndProcessMeminfo()
[all …]
/packages/services/Car/service/src/com/android/car/telemetry/publisher/
DMemoryPublisher.java364 DataSubscriber dataSubscriber, int numSnapshotsLeft, boolean collectIndefinitely) {
365 mDataSubscriber = dataSubscriber;
368 mMetricsConfig = dataSubscriber.getMetricsConfig();
369 mPublisherProto = dataSubscriber.getPublisherParam().getMemory();
/packages/services/Car/tests/carservice_unit_test/src/com/android/car/telemetry/databroker/
DDataSubscriberTest.java62 DataSubscriber dataSubscriber = new DataSubscriber(mMockDataBroker, METRICS_CONFIG_FOO, in testPush_shouldAddTaskToQueue() local
68 int numPendingTasks = dataSubscriber.push(publishedData); in testPush_shouldAddTaskToQueue()
/packages/services/Car/service/src/com/android/car/telemetry/databroker/
DDataBrokerImpl.java324 DataSubscriber dataSubscriber = new DataSubscriber( in addMetricsConfig() local
328 dataSubscribers.add(dataSubscriber); in addMetricsConfig()
330 publisher.addDataSubscriber(dataSubscriber); in addMetricsConfig()