Lines Matching refs:partialBucketSplitTimeNs
364 int64_t partialBucketSplitTimeNs = bucket2StartTimeNs + 2; in TEST_P() local
375 .WillOnce(Invoke([partialBucketSplitTimeNs](int tagId, const ConfigKey&, in TEST_P()
378 EXPECT_EQ(eventTimeNs, partialBucketSplitTimeNs); in TEST_P()
381 CreateRepeatedValueLogEvent(tagId, partialBucketSplitTimeNs + 8, 5)); in TEST_P()
398 valueProducer->notifyAppUpgrade(partialBucketSplitTimeNs); in TEST_P()
401 valueProducer->onStatsdInitCompleted(partialBucketSplitTimeNs); in TEST_P()
404 EXPECT_EQ(partialBucketSplitTimeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P()
408 {bucketSizeNs, partialBucketSplitTimeNs - bucket2StartTimeNs}, in TEST_P()
410 {bucket2StartTimeNs, partialBucketSplitTimeNs}); in TEST_P()
678 int64_t partialBucketSplitTimeNs = bucketStartTimeNs + 150; in TEST_P() local
681 valueProducer->notifyAppUpgrade(partialBucketSplitTimeNs); in TEST_P()
684 valueProducer->onStatsdInitCompleted(partialBucketSplitTimeNs); in TEST_P()
688 {partialBucketSplitTimeNs - bucketStartTimeNs}, {0}, in TEST_P()
689 {bucketStartTimeNs}, {partialBucketSplitTimeNs}); in TEST_P()
690 EXPECT_EQ(partialBucketSplitTimeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P()
699 {partialBucketSplitTimeNs - bucketStartTimeNs}, {0}, in TEST_P()
700 {bucketStartTimeNs}, {partialBucketSplitTimeNs}); in TEST_P()
701 EXPECT_EQ(partialBucketSplitTimeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P()
709 {partialBucketSplitTimeNs - bucketStartTimeNs, in TEST_P()
710 bucket2StartTimeNs - partialBucketSplitTimeNs}, in TEST_P()
712 {bucketStartTimeNs, partialBucketSplitTimeNs}, in TEST_P()
713 {partialBucketSplitTimeNs, bucket2StartTimeNs}); in TEST_P()
725 int64_t partialBucketSplitTimeNs = bucket2StartTimeNs + 150; in TEST_P() local
728 .WillOnce(Invoke([partialBucketSplitTimeNs](int tagId, const ConfigKey&, in TEST_P()
731 EXPECT_EQ(eventTimeNs, partialBucketSplitTimeNs); in TEST_P()
733 data->push_back(CreateRepeatedValueLogEvent(tagId, partialBucketSplitTimeNs, 120)); in TEST_P()
750 valueProducer->notifyAppUpgrade(partialBucketSplitTimeNs); in TEST_P()
753 valueProducer->onStatsdInitCompleted(partialBucketSplitTimeNs); in TEST_P()
756 EXPECT_EQ(partialBucketSplitTimeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P()
759 {bucket2StartTimeNs}, {partialBucketSplitTimeNs}); in TEST_P()
768 {bucket2StartTimeNs, partialBucketSplitTimeNs}, in TEST_P()
769 {partialBucketSplitTimeNs, bucket3StartTimeNs}); in TEST_P()
829 int64_t partialBucketSplitTimeNs = bucket2StartTimeNs - 50; in TEST_P() local
832 valueProducer->notifyAppUpgrade(partialBucketSplitTimeNs); in TEST_P()
835 valueProducer->onStatsdInitCompleted(partialBucketSplitTimeNs); in TEST_P()
839 EXPECT_EQ(partialBucketSplitTimeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P()
843 {bucketStartTimeNs}, {partialBucketSplitTimeNs}); in TEST_P()
2660 int64_t partialBucketSplitTimeNs = bucketStartTimeNs + bucketSizeNs / 2; in TEST_P() local
2671 .WillOnce(Invoke([partialBucketSplitTimeNs](int tagId, const ConfigKey&, in TEST_P()
2674 EXPECT_EQ(eventTimeNs, partialBucketSplitTimeNs); in TEST_P()
2676 data->push_back(CreateRepeatedValueLogEvent(tagId, partialBucketSplitTimeNs, 10)); in TEST_P()
2696 valueProducer->notifyAppUpgrade(partialBucketSplitTimeNs); in TEST_P()
2699 valueProducer->onStatsdInitCompleted(partialBucketSplitTimeNs); in TEST_P()
2702 EXPECT_EQ(partialBucketSplitTimeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P()
2705 {partialBucketSplitTimeNs - bucketStartTimeNs}, {0}, in TEST_P()
2706 {bucketStartTimeNs}, {partialBucketSplitTimeNs}); in TEST_P()
2714 {partialBucketSplitTimeNs - bucketStartTimeNs}, {0}, in TEST_P()
2715 {bucketStartTimeNs}, {partialBucketSplitTimeNs}); in TEST_P()
2720 EXPECT_EQ(partialBucketSplitTimeNs, valueProducer->mSkippedBuckets[0].bucketStartTimeNs); in TEST_P()
2832 int64_t partialBucketSplitTimeNs = bucket2StartTimeNs + 2; in TEST_P() local
2844 .WillOnce(Invoke([partialBucketSplitTimeNs](int tagId, const ConfigKey&, in TEST_P()
2847 EXPECT_EQ(eventTimeNs, partialBucketSplitTimeNs); in TEST_P()
2849 data->push_back(CreateRepeatedValueLogEvent(tagId, partialBucketSplitTimeNs, 10)); in TEST_P()
2859 valueProducer->notifyAppUpgrade(partialBucketSplitTimeNs); in TEST_P()
2862 valueProducer->onStatsdInitCompleted(partialBucketSplitTimeNs); in TEST_P()