/aosp_15_r20/packages/modules/StatsD/statsd/tests/metrics/ |
D | NumericValueMetricProducer_test.cpp | 386 const int64_t eventTimeNs, in TEST_P() 387 vector<std::shared_ptr<LogEvent>>* data) { in TEST_P() 606 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() 613 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() 614 vector<std::shared_ptr<LogEvent>>* data) { in TEST() 740 vector<std::shared_ptr<LogEvent>>* data) { in TEST_P() 822 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST_P() 823 vector<std::shared_ptr<LogEvent>>* data) { in TEST_P() 1075 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() 1076 vector<std::shared_ptr<LogEvent>>* data) { in TEST() [all …]
|
D | GaugeMetricProducer_test.cpp | 147 vector<std::shared_ptr<LogEvent>>* data) { in TEST() 336 vector<std::shared_ptr<LogEvent>>* data) { in TEST_P() 462 vector<std::shared_ptr<LogEvent>>* data) { in TEST() 552 vector<std::shared_ptr<LogEvent>>* data) { in TEST() 697 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() 698 vector<std::shared_ptr<LogEvent>>* data) { in TEST() 757 vector<std::shared_ptr<LogEvent>>* data) { in TEST() 823 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() 830 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() 831 vector<std::shared_ptr<LogEvent>>* data) { in TEST() [all …]
|
D | CountMetricProducer_test.cpp | 269 int64_t eventTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST_P() local 341 int64_t eventTimeNs = bucketStartTimeNs + 65 * NS_PER_SEC; in TEST_P() local 401 int64_t eventTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST() local
|
/aosp_15_r20/packages/modules/StatsD/statsd/src/metrics/ |
D | ValueMetricProducer.cpp | 162 const int64_t eventTimeNs) { in onStatsdInitCompleted() 174 const int64_t eventTimeNs) { in notifyAppUpgradeInternalLocked() 257 int64_t eventTimeNs, int32_t atomId, const HashableDimensionKey& primaryKey, in onStateChanged() 529 const int64_t eventTimeNs, const bool isActive) { in onActiveStateChangedLocked() 564 const bool condition, const int64_t eventTimeNs) { in onConditionChangedLocked() 623 bool newCondition, int64_t eventTimeNs) { in updateCurrentSlicedBucketConditionTimers() 709 const int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local 771 const int64_t eventTimeNs) { in flushIfNeededLocked() 796 const int64_t eventTimeNs, const int64_t nextBucketStartTimeNs) { in flushCurrentBucketLocked() 823 const int64_t eventTimeNs, const int64_t nextBucketStartTimeNs) { in closeCurrentBucket()
|
D | MetricProducer.h | 183 void notifyAppUpgrade(int64_t eventTimeNs) { in notifyAppUpgrade() 193 void notifyAppRemoved(int64_t eventTimeNs) { in notifyAppRemoved() 201 virtual void onStatsdInitCompleted(int64_t eventTimeNs) { in onStatsdInitCompleted() 239 void onStateChanged(const int64_t eventTimeNs, const int32_t atomId, in onStateChanged() 416 virtual void flushCurrentBucketLocked(int64_t eventTimeNs, int64_t nextBucketStartTimeNs){}; in flushCurrentBucketLocked() 421 void flushLocked(int64_t eventTimeNs) { in flushLocked() 426 virtual void notifyAppUpgradeInternalLocked(const int64_t eventTimeNs) { in notifyAppUpgradeInternalLocked() 482 virtual void onActiveStateChangedLocked(const int64_t eventTimeNs, const bool isActive) { in onActiveStateChangedLocked()
|
D | DurationMetricProducer.cpp | 320 void DurationMetricProducer::onStateChanged(const int64_t eventTimeNs, const int32_t atomId, in onStateChanged() 427 void DurationMetricProducer::onSlicedConditionMayChangeInternalLocked(const int64_t eventTimeNs) { in onSlicedConditionMayChangeInternalLocked() 457 void DurationMetricProducer::onActiveStateChangedLocked(const int64_t eventTimeNs, in onActiveStateChangedLocked() 627 void DurationMetricProducer::flushIfNeededLocked(const int64_t eventTimeNs) { in flushIfNeededLocked() 641 void DurationMetricProducer::flushCurrentBucketLocked(const int64_t eventTimeNs, in flushCurrentBucketLocked() 703 const int64_t eventTimeNs, in handleStartEvent() 746 const int64_t eventTimeNs) { in handleMatchedLogEventValuesLocked()
|
D | GaugeMetricProducer.cpp | 444 void GaugeMetricProducer::onActiveStateChangedLocked(const int64_t eventTimeNs, in onActiveStateChangedLocked() 458 const int64_t eventTimeNs) { in onConditionChangedLocked() 474 const int64_t eventTimeNs) { in onSlicedConditionMayChangeLocked() 573 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local 653 void GaugeMetricProducer::flushIfNeededLocked(const int64_t eventTimeNs) { in flushIfNeededLocked() 672 void GaugeMetricProducer::flushCurrentBucketLocked(const int64_t eventTimeNs, in flushCurrentBucketLocked()
|
D | CountMetricProducer.cpp | 187 void CountMetricProducer::onStateChanged(const int64_t eventTimeNs, const int32_t atomId, in onStateChanged() 388 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local 424 void CountMetricProducer::flushIfNeededLocked(const int64_t eventTimeNs) { in flushIfNeededLocked() 460 void CountMetricProducer::flushCurrentBucketLocked(const int64_t eventTimeNs, in flushCurrentBucketLocked() 558 void CountMetricProducer::onActiveStateChangedLocked(const int64_t eventTimeNs, in onActiveStateChangedLocked()
|
D | MetricsManager.cpp | 385 void MetricsManager::notifyAppUpgrade(const int64_t eventTimeNs, const string& apk, const int uid, in notifyAppUpgrade() 406 void MetricsManager::notifyAppRemoved(const int64_t eventTimeNs, const string& apk, const int uid) { in notifyAppRemoved() 426 void MetricsManager::onUidMapReceived(const int64_t eventTimeNs) { in onUidMapReceived() 438 void MetricsManager::onStatsdInitCompleted(const int64_t eventTimeNs) { in onStatsdInitCompleted() 577 const int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onLogEvent() local
|
D | NumericValueMetricProducer.cpp | 162 void NumericValueMetricProducer::onActiveStateChangedInternalLocked(const int64_t eventTimeNs, in onActiveStateChangedInternalLocked() 174 const int64_t eventTimeNs) { in onConditionChangedInternalLocked() 440 bool NumericValueMetricProducer::aggregateFields(const int64_t eventTimeNs, in aggregateFields() 653 void NumericValueMetricProducer::closeCurrentBucket(const int64_t eventTimeNs, in closeCurrentBucket()
|
D | ValueMetricProducer.h | 179 virtual void onActiveStateChangedInternalLocked(const int64_t eventTimeNs, in onActiveStateChangedInternalLocked() 189 const int64_t eventTimeNs) { in onConditionChangedInternalLocked() 369 inline bool isEventLateLocked(const int64_t eventTimeNs) const { in isEventLateLocked()
|
D | GaugeMetricProducer.h | 90 void notifyAppUpgradeInternalLocked(int64_t eventTimeNs) override { in notifyAppUpgradeInternalLocked() 98 void onStatsdInitCompleted(int64_t eventTimeNs) override { in onStatsdInitCompleted()
|
D | KllMetricProducer.h | 78 const MetricDimensionKey& eventKey, bool condition, int64_t eventTimeNs, in canSkipLogEventLocked()
|
D | NumericValueMetricProducer.h | 123 const MetricDimensionKey& eventKey, const bool condition, int64_t eventTimeNs, in canSkipLogEventLocked()
|
/aosp_15_r20/packages/modules/StatsD/statsd/src/state/ |
D | StateTracker.cpp | 32 const int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onLogEvent() local 100 void StateTracker::handleReset(const int64_t eventTimeNs, const FieldValue& newState) { in handleReset() 109 void StateTracker::clearStateForPrimaryKey(const int64_t eventTimeNs, in clearStateForPrimaryKey() 125 void StateTracker::updateStateForPrimaryKey(const int64_t eventTimeNs, in updateStateForPrimaryKey() 178 void StateTracker::notifyListeners(const int64_t eventTimeNs, in notifyListeners()
|
/aosp_15_r20/packages/modules/StatsD/statsd/tests/external/ |
D | StatsPuller_test.cpp | 63 std::unique_ptr<LogEvent> createSimpleEvent(int64_t eventTimeNs, int64_t value) { in createSimpleEvent() 238 int64_t eventTimeNs = getElapsedRealtimeNs(); in TEST_F() local 268 int64_t eventTimeNs = getElapsedRealtimeNs(); in TEST_F() local 293 int64_t eventTimeNs = getElapsedRealtimeNs(); in TEST_F() local
|
/aosp_15_r20/packages/modules/StatsD/statsd/tests/ |
D | statsd_test_util.cpp | 771 AStatsEvent* makeTwoValueStatsEvent(int atomId, int64_t eventTimeNs, int32_t value1, in makeTwoValueStatsEvent() 783 void CreateTwoValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, int32_t value1, in CreateTwoValueLogEvent() 789 shared_ptr<LogEvent> CreateTwoValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value1, in CreateTwoValueLogEvent() 796 void CreateThreeValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, int32_t value1, in CreateThreeValueLogEvent() 809 shared_ptr<LogEvent> CreateThreeValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value1, in CreateThreeValueLogEvent() 816 void CreateRepeatedValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, in CreateRepeatedValueLogEvent() 828 shared_ptr<LogEvent> CreateRepeatedValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value) { in CreateRepeatedValueLogEvent() 834 void CreateNoValuesLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs) { in CreateNoValuesLogEvent() 842 shared_ptr<LogEvent> CreateNoValuesLogEvent(int atomId, int64_t eventTimeNs) { in CreateNoValuesLogEvent() 848 AStatsEvent* makeUidStatsEvent(int atomId, int64_t eventTimeNs, int uid, int data1, int data2) { in makeUidStatsEvent() [all …]
|
D | StatsLogProcessor_test.cpp | 1883 uint64_t eventTimeNs = 12355; in TEST() local 1908 uint64_t eventTimeNs = 12355; in TEST() local 1938 uint64_t eventTimeNs = 12355; in TEST() local 1966 uint64_t eventTimeNs = 12355; in TEST() local 1995 uint64_t eventTimeNs = 12355; in TEST() local 2035 uint64_t eventTimeNs = 12355; in TEST_GUARDED() local
|
/aosp_15_r20/packages/modules/StatsD/statsd/src/external/ |
D | StatsPullerManager.cpp | 55 bool StatsPullerManager::Pull(int tagId, const ConfigKey& configKey, const int64_t eventTimeNs, in Pull() 62 bool StatsPullerManager::Pull(int tagId, const vector<int32_t>& uids, const int64_t eventTimeNs, in Pull() 70 const int64_t eventTimeNs, vector<shared_ptr<LogEvent>>* data) { in PullLocked() 91 const int64_t eventTimeNs, vector<shared_ptr<LogEvent>>* data) { in PullLocked()
|
D | StatsPuller.cpp | 47 PullErrorCode StatsPuller::Pull(const int64_t eventTimeNs, in Pull()
|
/aosp_15_r20/packages/modules/StatsD/statsd/tests/log_event/ |
D | LogEventQueue_test.cpp | 59 int64_t eventTimeNs = 100; in TEST() local 84 int64_t eventTimeNs = 100; in TEST() local 125 int64_t eventTimeNs = 100; in TEST() local
|
/aosp_15_r20/packages/modules/StatsD/statsd/src/metrics/duration_helper/ |
D | MaxDurationTracker.cpp | 179 const int64_t eventTimeNs, const optional<UploadThreshold>& uploadThreshold, in flushCurrentBucket() 237 int64_t eventTimeNs, const optional<UploadThreshold>& uploadThreshold, in flushIfNeeded()
|
D | OringDurationTracker.cpp | 144 const int64_t eventTimeNs, const optional<UploadThreshold>& uploadThreshold, in flushCurrentBucket() 243 int64_t eventTimeNs, const optional<UploadThreshold>& uploadThreshold, in flushIfNeeded()
|
/aosp_15_r20/packages/modules/StatsD/statsd/src/ |
D | StatsLogProcessor.cpp | 866 void StatsLogProcessor::resetIfConfigTtlExpiredLocked(const int64_t eventTimeNs) { in resetIfConfigTtlExpiredLocked() 1454 void StatsLogProcessor::notifyAppUpgrade(const int64_t eventTimeNs, const string& apk, in notifyAppUpgrade() 1464 void StatsLogProcessor::notifyAppRemoved(const int64_t eventTimeNs, const string& apk, in notifyAppRemoved() 1474 void StatsLogProcessor::onUidMapReceived(const int64_t eventTimeNs) { in onUidMapReceived()
|
/aosp_15_r20/packages/modules/StatsD/statsd/src/condition/ |
D | ConditionTimer.h | 73 ConditionDurationInfo newBucketStart(int64_t eventTimeNs, int64_t nextBucketStartNs) { in newBucketStart()
|