Home
last modified time | relevance | path

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

/packages/services/Car/tests/carservice_unit_test/src/com/android/car/telemetry/publisher/
DMemoryPublisherTest.java362 Message message = mFakeHandlerWrapper.getQueuedMessages().get(0); in testAddDataSubscriber_schedulesNextPullBasedOnReadRate()
371 assertThat(mFakeHandlerWrapper.getQueuedMessages()).hasSize(1); in testAddDataSubscriber_maxSnapshotsReached_removesDataSubscriber()
376 assertThat(mFakeHandlerWrapper.getQueuedMessages()).hasSize(0); in testAddDataSubscriber_maxSnapshotsReached_removesDataSubscriber()
425 assertThat(mFakeHandlerWrapper.getQueuedMessages()).hasSize(0); in testRemoveDataSubscriber_removesSubscriberAndStopsPullingMeminfo()
436 assertThat(mFakeHandlerWrapper.getQueuedMessages()).hasSize(1); in testRemoveDataSubscriber_ifDoesNotMatch_keepsSubscriber()
446 assertThat(mFakeHandlerWrapper.getQueuedMessages()).hasSize(0); in testRemoveAllDataSubscriber_removesSubscriberAndStopsPullingMeminfo()
457 assertThat(mFakeHandlerWrapper.getQueuedMessages()).hasSize(1); in testReadMeminfo_shouldThrottlePublisher()
458 Message message = mFakeHandlerWrapper.getQueuedMessages().get(0); in testReadMeminfo_shouldThrottlePublisher()
475 assertThat(mFakeHandlerWrapper.getQueuedMessages()).hasSize(0); in testReadMeminfo_whenPreviousStateExists_shouldContinueFromPrevious()
DStatsPublisherTest.java388 assertThat(mFakeHandlerWrapper.getQueuedMessages()).hasSize(1); in testAddDataSubscriber_queuesPeriodicTaskInTheHandler()
389 Message msg = mFakeHandlerWrapper.getQueuedMessages().get(0); in testAddDataSubscriber_queuesPeriodicTaskInTheHandler()
411 assertThat(mFakeHandlerWrapper.getQueuedMessages()).isEmpty(); in testRemoveDataSubscriber_removesPeriodicStatsdReportPull()
420 assertThat(mFakeHandlerWrapper.getQueuedMessages()).isEmpty(); in testRemoveAllDataSubscriber_removesPeriodicStatsdReportPull()
426 Message firstMessage = mFakeHandlerWrapper.getQueuedMessages().get(0); in testAfterDispatchItSchedulesANewPullReportTask()
431 assertThat(mFakeHandlerWrapper.getQueuedMessages()).hasSize(1); in testAfterDispatchItSchedulesANewPullReportTask()
432 Message newMessage = mFakeHandlerWrapper.getQueuedMessages().get(0); in testAfterDispatchItSchedulesANewPullReportTask()
/packages/services/Car/tests/common_utils/src/com/android/car/test/
DFakeHandlerWrapper.java89 public ArrayList<Message> getQueuedMessages() { in getQueuedMessages() method in FakeHandlerWrapper