Home
last modified time | relevance | path

Searched refs:mDataBroker (Results 1 – 3 of 3) sorted by relevance

/packages/services/Car/tests/carservice_unit_test/src/com/android/car/telemetry/databroker/
DDataBrokerTest.java122 private DataBrokerImpl mDataBroker; field in DataBrokerTest
163 mDataBroker = new DataBrokerImpl( in setUp()
165 mDataBroker.setDataBrokerListener(mMockDataBrokerListener); in setUp()
167 mDataBroker.getTelemetryHandler().getLooper().getQueue().addIdleHandler(() -> { in setUp()
178 new DataSubscriber(mDataBroker, METRICS_CONFIG_FOO, SUBSCRIBER_FOO), in setUp()
184 new DataSubscriber(mDataBroker, METRICS_CONFIG_BAR, SUBSCRIBER_BAR), in setUp()
200 if (mDataBroker != null) { in tearDown()
202 mDataBroker.getTelemetryHandler().removeMessages(DataBrokerImpl.MSG_HANDLE_TASK); in tearDown()
203 mDataBroker.getTelemetryHandler().removeMessages( in tearDown()
205 mDataBroker.getTelemetryHandler().removeMessages( in tearDown()
[all …]
/packages/services/Car/service/src/com/android/car/telemetry/
DCarTelemetryService.java126 mDataBroker.scheduleNextTask();
163 mDataBroker.scheduleNextTask();
171 private DataBroker mDataBroker; field in CarTelemetryService
222 mDataBroker = dataBroker; in CarTelemetryService()
247 if (mDataBroker == null) { in init()
248 mDataBroker = new DataBrokerImpl(mContext, mPublisherFactory, mResultStore, in init()
251 mDataBroker.setDataBrokerListener(mDataBrokerListener); in init()
388 mDataBroker.removeMetricsConfig(metricsConfigName); in addMetricsConfigInternal()
393 mDataBroker.addMetricsConfig(metricsConfigName, metricsConfig); in addMetricsConfigInternal()
420 mDataBroker.removeMetricsConfig(metricsConfigName); in removeMetricsConfig()
[all …]
/packages/services/Car/service/src/com/android/car/telemetry/databroker/
DDataSubscriber.java39 private final DataBroker mDataBroker; field in DataSubscriber
47 mDataBroker = dataBroker; in DataSubscriber()
87 return mDataBroker.addTaskToQueue(task); in push()
101 return mDataBroker.addTaskToQueue(task); in push()