Home
last modified time | relevance | path

Searched refs:DataSubscriber (Results 1 – 16 of 16) sorted by relevance

/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()
83 DataSubscriber foo = new DataSubscriber(mMockDataBroker, METRICS_CONFIG_FOO, in testEquals_whenSame_shouldBeEqual()
85 DataSubscriber bar = new DataSubscriber(mMockDataBroker, METRICS_CONFIG_FOO, in testEquals_whenSame_shouldBeEqual()
93 DataSubscriber foo = new DataSubscriber(mMockDataBroker, METRICS_CONFIG_FOO, in testEquals_whenDifferent_shouldNotBeEqual()
95 DataSubscriber bar = new DataSubscriber(mMockDataBroker, METRICS_CONFIG_BAR, in testEquals_whenDifferent_shouldNotBeEqual()
DDataBrokerTest.java178 new DataSubscriber(mDataBroker, METRICS_CONFIG_FOO, SUBSCRIBER_FOO), in setUp()
184 new DataSubscriber(mDataBroker, METRICS_CONFIG_BAR, SUBSCRIBER_BAR), in setUp()
368 new DataSubscriber(mDataBroker, metricConfigForBypass, subscriberWithoutHandler), in testScheduleNextTask_whenScriptExecutorBypassed_shouldStoreFinalResult()
402 new DataSubscriber(mDataBroker, METRICS_CONFIG_FOO, SUBSCRIBER_FOO), in testScheduleNextTask_withLargeDataFlag_shouldPipeData()
419 new DataSubscriber(mDataBroker, METRICS_CONFIG_FOO, SUBSCRIBER_FOO), in testScheduleNextTask_withoutLargeDataFlag_doesNotPipeData()
437 new DataSubscriber(mDataBroker, METRICS_CONFIG_FOO, SUBSCRIBER_FOO), in testScheduleNextTask_largeInputPipeIOException_shouldIgnoreCurrentTask()
443 new DataSubscriber(mDataBroker, METRICS_CONFIG_FOO, SUBSCRIBER_FOO), in testScheduleNextTask_largeInputPipeIOException_shouldIgnoreCurrentTask()
466 new DataSubscriber(mDataBroker, METRICS_CONFIG_FOO, SUBSCRIBER_FOO), in testScheduleNextTask_withBundleList_shouldPassData()
653 new DataSubscriber(mDataBroker, METRICS_CONFIG_FOO, SUBSCRIBER_FOO), in testRemoveMetricsConfiguration_shouldRemoveAllAssociatedTasks()
/packages/services/Car/tests/carservice_unit_test/src/com/android/car/telemetry/publisher/
DVehiclePropertyPublisherTest.java45 import com.android.car.telemetry.databroker.DataSubscriber;
266 private DataSubscriber mMockStringDataSubscriber;
268 private DataSubscriber mMockBoolDataSubscriber;
270 private DataSubscriber mMockIntDataSubscriber;
272 private DataSubscriber mMockIntVecDataSubscriber;
274 private DataSubscriber mMockLongDataSubscriber;
276 private DataSubscriber mMockLongVecDataSubscriber;
278 private DataSubscriber mMockFloatDataSubscriber;
280 private DataSubscriber mMockFloatVecDataSubscriber;
282 private DataSubscriber mMockBytesDataSubscriber;
[all …]
DMemoryPublisherTest.java46 import com.android.car.telemetry.databroker.DataSubscriber;
124 private DataSubscriber mMockDataSubscriber;
197 DataSubscriber dataSubscriber = mock(DataSubscriber.class); in testAddDataSubscriber_whenMatchingPackageName_pullsDeviceAndProcessMeminfo()
243 DataSubscriber dataSubscriber = mock(DataSubscriber.class); in testAddDataSubscriber_multipleMatchingPackageName_pullsDeviceAndProcessMeminfo()
299 DataSubscriber dataSubscriber = mock(DataSubscriber.class); in testAddDataSubscriber_whenPackageNameNotFound_doesNotPullProcessMeminfo()
343 DataSubscriber mockDataSubscriber1 = mock(DataSubscriber.class); in testAddDataSubscriber_whenConfigHasIllegalFields_throwsException()
349 DataSubscriber mockDataSubscriber2 = mock(DataSubscriber.class); in testAddDataSubscriber_whenConfigHasIllegalFields_throwsException()
410 DataSubscriber mockSubscriber = mock(DataSubscriber.class); in testAddDataSubscriber_invalidConfiguration_throwsException()
431 DataSubscriber differentSubscriber = Mockito.mock(DataSubscriber.class); in testRemoveDataSubscriber_ifDoesNotMatch_keepsSubscriber()
DCarTelemetrydPublisherTest.java48 import com.android.car.telemetry.databroker.DataSubscriber;
92 private DataSubscriber mMockDataSubscriber;
145 DataSubscriber invalidDataSubscriber = Mockito.mock(DataSubscriber.class); in testAddDataSubscriber_withInvalidId_fails()
168 DataSubscriber subscriber2 = Mockito.mock(DataSubscriber.class); in testRemoveDataSubscriber_removesOnlySingleSubscriber()
192 DataSubscriber subscriber2 = Mockito.mock(DataSubscriber.class); in testRemoveAllDataSubscribers_succeeds()
261 DataSubscriber subscriber2 = Mockito.mock(DataSubscriber.class); in testPushesPublishedData_multipleSubscribers()
363 new byte[DataSubscriber.SCRIPT_INPUT_SIZE_THRESHOLD_BYTES + 1])}); in testPushesPublishedData_detectsLargeData()
374 .isEqualTo(DataSubscriber.SCRIPT_INPUT_SIZE_THRESHOLD_BYTES + 1); in testPushesPublishedData_detectsLargeData()
DStatsPublisherTest.java68 import com.android.car.telemetry.databroker.DataSubscriber;
255 private static final DataSubscriber DATA_SUBSCRIBER_1 =
256 new DataSubscriber(null, METRICS_CONFIG, SUBSCRIBER_1);
324 DataSubscriber processMemoryStateSubscriber = in testAddDataSubscriber_forProcessMemoryState_generatesStatsdMetrics()
325 new DataSubscriber(null, METRICS_CONFIG, SUBSCRIBER_2); in testAddDataSubscriber_forProcessMemoryState_generatesStatsdMetrics()
337 DataSubscriber activityForegroundStateSubscriber = in testAddDataSubscriber_forActivityForegroundState_generatesStatsdMetrics()
338 new DataSubscriber(null, METRICS_CONFIG, SUBSCRIBER_3); in testAddDataSubscriber_forActivityForegroundState_generatesStatsdMetrics()
440 DataSubscriber subscriber1 = Mockito.mock(DataSubscriber.class); in testPullStatsdReport_correctlyPushesBundlesToSubscribers()
445 DataSubscriber subscriber2 = Mockito.mock(DataSubscriber.class); in testPullStatsdReport_correctlyPushesBundlesToSubscribers()
504 DataSubscriber subscriber = spy(new DataSubscriber(null, METRICS_CONFIG, SUBSCRIBER_1)); in testOnInvalidConfig_notifiesPublisherFailureListener()
DConnectivityPublisherTest.java46 import com.android.car.telemetry.databroker.DataSubscriber;
545 private static class FakeDataSubscriber extends DataSubscriber {
/packages/services/Car/service/src/com/android/car/telemetry/publisher/
DCarTelemetrydPublisher.java35 import com.android.car.telemetry.databroker.DataSubscriber;
59 private final SparseArray<ArrayList<DataSubscriber>> mCarIdSubscriberLookUp =
162 ArrayList<DataSubscriber> subscribers = mCarIdSubscriberLookUp.valueAt(i); in getMetricsConfigs()
200 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber()
216 ArrayList<DataSubscriber> currentSubscribers = mCarIdSubscriberLookUp.get(carDataId); in addDataSubscriber()
247 public void removeDataSubscriber(@NonNull DataSubscriber subscriber) { in removeDataSubscriber()
251 ArrayList<DataSubscriber> currentSubscribers = mCarIdSubscriberLookUp.get(idToRemove); in removeDataSubscriber()
293 public boolean hasDataSubscriber(@NonNull DataSubscriber subscriber) { in hasDataSubscriber()
309 ArrayList<DataSubscriber> currentSubscribers = mCarIdSubscriberLookUp.get(dataItem.id); in processCarData()
322 content.length() > DataSubscriber.SCRIPT_INPUT_SIZE_THRESHOLD_BYTES); in processCarData()
DAbstractPublisher.java23 import com.android.car.telemetry.databroker.DataSubscriber;
82 public abstract void addDataSubscriber(@NonNull DataSubscriber subscriber); in addDataSubscriber()
89 public abstract void removeDataSubscriber(@NonNull DataSubscriber subscriber); in removeDataSubscriber()
99 public abstract boolean hasDataSubscriber(@NonNull DataSubscriber subscriber); in hasDataSubscriber()
DConnectivityPublisher.java41 import com.android.car.telemetry.databroker.DataSubscriber;
75 private final ArrayMap<QueryParam, ArrayList<DataSubscriber>> mSubscribers = new ArrayMap<>();
143 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber()
153 public void removeDataSubscriber(@NonNull DataSubscriber subscriber) { in removeDataSubscriber()
165 public boolean hasDataSubscriber(@NonNull DataSubscriber subscriber) { in hasDataSubscriber()
216 ArrayList<DataSubscriber> subscribers = mSubscribers.get(queryParam); in processPreviousSession()
217 for (DataSubscriber subscriber : subscribers) { in processPreviousSession()
316 static QueryParam forSubscriber(@NonNull DataSubscriber subscriber) { in forSubscriber()
DMemoryPublisher.java35 import com.android.car.telemetry.databroker.DataSubscriber;
145 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber()
180 public void removeDataSubscriber(@NonNull DataSubscriber subscriber) { in removeDataSubscriber()
193 public boolean hasDataSubscriber(@NonNull DataSubscriber subscriber) { in hasDataSubscriber()
353 private final DataSubscriber mDataSubscriber;
364 DataSubscriber dataSubscriber, int numSnapshotsLeft, boolean collectIndefinitely) {
380 data.toString().length() >= DataSubscriber.SCRIPT_INPUT_SIZE_THRESHOLD_BYTES
DStatsPublisher.java52 import com.android.car.telemetry.databroker.DataSubscriber;
184 private final LongSparseArray<DataSubscriber> mConfigKeyToSubscribers = new LongSparseArray<>();
218 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber()
243 DataSubscriber subscriber = mConfigKeyToSubscribers.get(configKey); in processReport()
329 return bytes >= DataSubscriber.SCRIPT_INPUT_SIZE_THRESHOLD_BYTES; in isBundleLargeData()
408 public void removeDataSubscriber(@NonNull DataSubscriber subscriber) { in removeDataSubscriber()
460 public boolean hasDataSubscriber(@NonNull DataSubscriber subscriber) { in hasDataSubscriber()
483 private static String buildBundleConfigKey(@NonNull DataSubscriber subscriber) { in buildBundleConfigKey()
501 private void addStatsConfig(long configKey, @NonNull DataSubscriber subscriber) { in addStatsConfig()
530 private long removeStatsConfig(@NonNull DataSubscriber subscriber) { in removeStatsConfig()
[all …]
DVehiclePropertyPublisher.java43 import com.android.car.telemetry.databroker.DataSubscriber;
101 public void addDataSubscriber(@NonNull DataSubscriber subscriber) { in addDataSubscriber()
144 public void removeDataSubscriber(@NonNull DataSubscriber subscriber) { in removeDataSubscriber()
178 public boolean hasDataSubscriber(@NonNull DataSubscriber subscriber) { in hasDataSubscriber()
223 for (DataSubscriber subscriber : propertyData.subscribers) { in pushPendingDataToSubscribers()
340 public final ArraySet<DataSubscriber> subscribers = new ArraySet<>();
/packages/services/Car/service/src/com/android/car/telemetry/databroker/
DDataSubscriber.java31 public class DataSubscriber { class
43 public DataSubscriber( in DataSubscriber() method in DataSubscriber
135 if (!(o instanceof DataSubscriber)) { in equals()
138 DataSubscriber other = (DataSubscriber) o; in equals()
DScriptExecutionTask.java36 private final DataSubscriber mSubscriber;
43 @NonNull DataSubscriber subscriber, in ScriptExecutionTask()
56 @NonNull DataSubscriber subscriber, in ScriptExecutionTask()
DDataBrokerImpl.java114 private final ArrayMap<String, List<DataSubscriber>> mSubscriptionMap = new ArrayMap<>();
314 List<DataSubscriber> dataSubscribers = new ArrayList<>( in addMetricsConfig()
324 DataSubscriber dataSubscriber = new DataSubscriber( in addMetricsConfig()
342 List<DataSubscriber> dataSubscribers = mSubscriptionMap.remove(metricsConfigName); in removeMetricsConfig()
344 for (DataSubscriber subscriber : dataSubscribers) { in removeMetricsConfig()
431 ArrayMap<String, List<DataSubscriber>> getSubscriptionMap() { in getSubscriptionMap()