179     sp<KllMetricProducer> kllProducer =  in TEST_P()  local
184     kllProducer->onMatchedLogEvent(1 /*log matcher index*/, event1);  in TEST_P()
185     ASSERT_EQ(1UL, kllProducer->mCurrentSlicedBucket.size());  in TEST_P()
190             kllProducer->notifyAppUpgrade(partialBucketSplitTimeNs);  in TEST_P()
193             kllProducer->onStatsdInitCompleted(partialBucketSplitTimeNs);  in TEST_P()
196     TRACE_CALL(assertPastBucketsSingleKey, kllProducer->mPastBuckets, {1},  in TEST_P()
199     EXPECT_EQ(partialBucketSplitTimeNs, kllProducer->mCurrentBucketStartTimeNs);  in TEST_P()
200     EXPECT_EQ(0, kllProducer->getCurrentBucketNum());  in TEST_P()
205     kllProducer->onMatchedLogEvent(1 /*log matcher index*/, event2);  in TEST_P()
207     TRACE_CALL(assertPastBucketsSingleKey, kllProducer->mPastBuckets, {1},  in TEST_P()
210     EXPECT_EQ(partialBucketSplitTimeNs, kllProducer->mCurrentBucketStartTimeNs);  in TEST_P()
211     EXPECT_EQ(0, kllProducer->getCurrentBucketNum());  in TEST_P()
216     kllProducer->onMatchedLogEvent(1 /*log matcher index*/, event3);  in TEST_P()
217     TRACE_CALL(assertPastBucketsSingleKey, kllProducer->mPastBuckets, {1, 1},  in TEST_P()
222     EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, kllProducer->mCurrentBucketStartTimeNs);  in TEST_P()
223     EXPECT_EQ(1, kllProducer->getCurrentBucketNum());  in TEST_P()
228     sp<KllMetricProducer> kllProducer =  in TEST()  local
237     kllProducer->onMatchedLogEvent(1 /*log matcher index*/, event1);  in TEST()
239     ASSERT_EQ(1UL, kllProducer->mCurrentSlicedBucket.size());  in TEST()
241             kllProducer->mCurrentSlicedBucket.begin()->second.intervals[0];  in TEST()
245     kllProducer->onMatchedLogEvent(1 /*log matcher index*/, event2);  in TEST()
248     ASSERT_EQ(1UL, kllProducer->mCurrentSlicedBucket.size());  in TEST()
251     kllProducer->flushIfNeededLocked(bucket2StartTimeNs);  in TEST()
252     TRACE_CALL(assertPastBucketsSingleKey, kllProducer->mPastBuckets, {2}, {bucketSizeNs},  in TEST()
258     sp<KllMetricProducer> kllProducer = KllMetricProducerTestHelper::createKllProducerWithCondition(  in TEST()  local
263     kllProducer->onMatchedLogEvent(1 /*log matcher index*/, event1);  in TEST()
265     ASSERT_EQ(0UL, kllProducer->mCurrentSlicedBucket.size());  in TEST()
267     kllProducer->onConditionChangedLocked(true, bucketStartTimeNs + 15);  in TEST()
271     kllProducer->onMatchedLogEvent(1 /*log matcher index*/, event2);  in TEST()
274     ASSERT_EQ(1UL, kllProducer->mCurrentSlicedBucket.size());  in TEST()
276             kllProducer->mCurrentSlicedBucket.begin()->second.intervals[0];  in TEST()
281     kllProducer->onMatchedLogEvent(1 /*log matcher index*/, event3);  in TEST()
284     ASSERT_EQ(1UL, kllProducer->mCurrentSlicedBucket.size());  in TEST()
287     kllProducer->onConditionChangedLocked(false, bucketStartTimeNs + 35);  in TEST()
291     kllProducer->onMatchedLogEvent(1 /*log matcher index*/, event4);  in TEST()
294     ASSERT_EQ(1UL, kllProducer->mCurrentSlicedBucket.size());  in TEST()
297     kllProducer->flushIfNeededLocked(bucket2StartTimeNs);  in TEST()
298     TRACE_CALL(assertPastBucketsSingleKey, kllProducer->mPastBuckets, {2}, {20},  in TEST()
308     sp<KllMetricProducer> kllProducer = KllMetricProducerTestHelper::createKllProducerWithCondition(  in TEST()  local
312     kllProducer->onConditionChanged(true, bucketStartTimeNs + 50);  in TEST()
318     kllProducer->onDumpReport(dumpReportTimeNs, true /* include recent buckets */, true,  in TEST()
345     sp<KllMetricProducer> kllProducer =  in TEST()  local
350     kllProducer->onMatchedLogEvent(1 /*log matcher index*/, event1);  in TEST()
356     kllProducer->onDumpReport(dumpReportTimeNs, true /* include recent buckets */, true,  in TEST()
381     sp<KllMetricProducer> kllProducer = KllMetricProducerTestHelper::createKllProducerWithCondition(  in TEST()  local
388     kllProducer->onDumpReport(dumpReportTimeNs, true /* include current bucket */, true,  in TEST()
413     sp<KllMetricProducer> kllProducer = KllMetricProducerTestHelper::createKllProducerWithCondition(  in TEST()  local
418     kllProducer->notifyAppUpgrade(appUpdateTimeNs);  in TEST()
424     kllProducer->onDumpReport(dumpReportTimeNs, false /* include current buckets */, true,  in TEST()
445     sp<KllMetricProducer> kllProducer =  in TEST()  local
454     kllProducer->onMatchedLogEvent(1 /*log matcher index*/, event1);  in TEST()
455     kllProducer->onMatchedLogEvent(1 /*log matcher index*/, event2);  in TEST()
456     kllProducer->flushIfNeededLocked(bucket2StartTimeNs);  in TEST()
458     const size_t expectedSize = kllProducer->kBucketSize + 4 /* one int aggIndex entry */ +  in TEST()
461     EXPECT_EQ(expectedSize, kllProducer->byteSize());  in TEST()