| /packages/modules/StatsD/statsd/tests/metrics/ |
| D | NumericValueMetricProducer_test.cpp | 376 const int64_t eventTimeNs, in TEST_P()
377 vector<std::shared_ptr<LogEvent>>* data) { in TEST_P()
596 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
603 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
604 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
730 vector<std::shared_ptr<LogEvent>>* data) { in TEST_P()
812 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST_P()
813 vector<std::shared_ptr<LogEvent>>* data) { in TEST_P()
1071 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
1072 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
[all …]
|
| D | GaugeMetricProducer_test.cpp | 137 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
326 vector<std::shared_ptr<LogEvent>>* data) { in TEST_P()
452 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
542 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
687 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
688 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
747 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
813 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
820 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
821 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
[all …]
|
| D | CountMetricProducer_test.cpp | 262 int64_t eventTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST_P() local
334 int64_t eventTimeNs = bucketStartTimeNs + 65 * NS_PER_SEC; in TEST_P() local
394 int64_t eventTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST() local
|
| /packages/modules/StatsD/statsd/src/state/ |
| D | StateTracker.cpp | 32 const int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onLogEvent() local
89 void StateTracker::handleReset(const int64_t eventTimeNs, const FieldValue& newState) { in handleReset()
98 void StateTracker::clearStateForPrimaryKey(const int64_t eventTimeNs, in clearStateForPrimaryKey()
114 void StateTracker::updateStateForPrimaryKey(const int64_t eventTimeNs, in updateStateForPrimaryKey()
167 void StateTracker::notifyListeners(const int64_t eventTimeNs, in notifyListeners()
|
| /packages/modules/StatsD/statsd/src/metrics/ |
| D | ValueMetricProducer.cpp | 160 const int64_t eventTimeNs) { in onStatsdInitCompleted()
172 const int64_t eventTimeNs) { in notifyAppUpgradeInternalLocked()
255 int64_t eventTimeNs, int32_t atomId, const HashableDimensionKey& primaryKey, in onStateChanged()
512 const int64_t eventTimeNs, const bool isActive) { in onActiveStateChangedLocked()
547 const bool condition, const int64_t eventTimeNs) { in onConditionChangedLocked()
606 bool newCondition, int64_t eventTimeNs) { in updateCurrentSlicedBucketConditionTimers()
692 const int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local
754 const int64_t eventTimeNs) { in flushIfNeededLocked()
779 const int64_t eventTimeNs, const int64_t nextBucketStartTimeNs) { in flushCurrentBucketLocked()
806 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()
238 void onStateChanged(const int64_t eventTimeNs, const int32_t atomId, in onStateChanged()
403 virtual void flushCurrentBucketLocked(int64_t eventTimeNs, int64_t nextBucketStartTimeNs){}; in flushCurrentBucketLocked()
408 void flushLocked(int64_t eventTimeNs) { in flushLocked()
413 virtual void notifyAppUpgradeInternalLocked(const int64_t eventTimeNs) { in notifyAppUpgradeInternalLocked()
469 virtual void onActiveStateChangedLocked(const int64_t eventTimeNs, const bool isActive) { in onActiveStateChangedLocked()
|
| D | GaugeMetricProducer.cpp | 432 void GaugeMetricProducer::onActiveStateChangedLocked(const int64_t eventTimeNs, in onActiveStateChangedLocked()
446 const int64_t eventTimeNs) { in onConditionChangedLocked()
462 const int64_t eventTimeNs) { in onSlicedConditionMayChangeLocked()
561 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local
640 void GaugeMetricProducer::flushIfNeededLocked(const int64_t eventTimeNs) { in flushIfNeededLocked()
659 void GaugeMetricProducer::flushCurrentBucketLocked(const int64_t eventTimeNs, in flushCurrentBucketLocked()
|
| D | CountMetricProducer.cpp | 186 void CountMetricProducer::onStateChanged(const int64_t eventTimeNs, const int32_t atomId, in onStateChanged()
374 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local
410 void CountMetricProducer::flushIfNeededLocked(const int64_t eventTimeNs) { in flushIfNeededLocked()
446 void CountMetricProducer::flushCurrentBucketLocked(const int64_t eventTimeNs, in flushCurrentBucketLocked()
544 void CountMetricProducer::onActiveStateChangedLocked(const int64_t eventTimeNs, in onActiveStateChangedLocked()
|
| D | GaugeMetricProducer.h | 90 void notifyAppUpgradeInternalLocked(int64_t eventTimeNs) override { in notifyAppUpgradeInternalLocked()
98 void onStatsdInitCompleted(int64_t eventTimeNs) override { in onStatsdInitCompleted()
|
| D | DurationMetricProducer.cpp | 319 void DurationMetricProducer::onStateChanged(const int64_t eventTimeNs, const int32_t atomId, in onStateChanged()
426 void DurationMetricProducer::onSlicedConditionMayChangeInternalLocked(const int64_t eventTimeNs) { in onSlicedConditionMayChangeInternalLocked()
456 void DurationMetricProducer::onActiveStateChangedLocked(const int64_t eventTimeNs, in onActiveStateChangedLocked()
612 void DurationMetricProducer::flushIfNeededLocked(const int64_t eventTimeNs) { in flushIfNeededLocked()
626 void DurationMetricProducer::flushCurrentBucketLocked(const int64_t eventTimeNs, in flushCurrentBucketLocked()
688 const int64_t eventTimeNs, in handleStartEvent()
731 const int64_t eventTimeNs) { in handleMatchedLogEventValuesLocked()
|
| D | NumericValueMetricProducer.cpp | 142 void NumericValueMetricProducer::onActiveStateChangedInternalLocked(const int64_t eventTimeNs, in onActiveStateChangedInternalLocked()
154 const int64_t eventTimeNs) { in onConditionChangedInternalLocked()
398 bool NumericValueMetricProducer::aggregateFields(const int64_t eventTimeNs, in aggregateFields()
552 void NumericValueMetricProducer::closeCurrentBucket(const int64_t eventTimeNs, in closeCurrentBucket()
|
| D | KllMetricProducer.h | 78 const MetricDimensionKey& eventKey, bool condition, int64_t eventTimeNs, in canSkipLogEventLocked()
|
| D | MetricsManager.cpp | 377 void MetricsManager::notifyAppUpgrade(const int64_t eventTimeNs, const string& apk, const int uid, in notifyAppUpgrade()
398 void MetricsManager::notifyAppRemoved(const int64_t eventTimeNs, const string& apk, const int uid) { in notifyAppRemoved()
418 void MetricsManager::onUidMapReceived(const int64_t eventTimeNs) { in onUidMapReceived()
430 void MetricsManager::onStatsdInitCompleted(const int64_t eventTimeNs) { in onStatsdInitCompleted()
571 const int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onLogEvent() local
|
| D | ValueMetricProducer.h | 178 virtual void onActiveStateChangedInternalLocked(const int64_t eventTimeNs, in onActiveStateChangedInternalLocked()
188 const int64_t eventTimeNs) { in onConditionChangedInternalLocked()
368 inline bool isEventLateLocked(const int64_t eventTimeNs) const { in isEventLateLocked()
|
| D | NumericValueMetricProducer.h | 122 const MetricDimensionKey& eventKey, const bool condition, int64_t eventTimeNs, in canSkipLogEventLocked()
|
| D | KllMetricProducer.cpp | 111 bool KllMetricProducer::aggregateFields(const int64_t eventTimeNs, in aggregateFields()
|
| /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
|
| /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
|
| /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()
|
| /packages/modules/StatsD/statsd/src/condition/ |
| D | ConditionTimer.h | 73 ConditionDurationInfo newBucketStart(int64_t eventTimeNs, int64_t nextBucketStartNs) { in newBucketStart()
|
| /packages/modules/StatsD/statsd/src/metrics/duration_helper/ |
| D | MaxDurationTracker.cpp | 178 const int64_t eventTimeNs, const optional<UploadThreshold>& uploadThreshold, in flushCurrentBucket()
236 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()
|
| /packages/modules/StatsD/statsd/tests/ |
| D | statsd_test_util.cpp | 739 void CreateTwoValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, int32_t value1, in CreateTwoValueLogEvent()
751 shared_ptr<LogEvent> CreateTwoValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value1, in CreateTwoValueLogEvent()
758 void CreateThreeValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, int32_t value1, in CreateThreeValueLogEvent()
771 shared_ptr<LogEvent> CreateThreeValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value1, in CreateThreeValueLogEvent()
778 void CreateRepeatedValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, in CreateRepeatedValueLogEvent()
790 shared_ptr<LogEvent> CreateRepeatedValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value) { in CreateRepeatedValueLogEvent()
796 void CreateNoValuesLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs) { in CreateNoValuesLogEvent()
804 shared_ptr<LogEvent> CreateNoValuesLogEvent(int atomId, int64_t eventTimeNs) { in CreateNoValuesLogEvent()
810 AStatsEvent* makeUidStatsEvent(int atomId, int64_t eventTimeNs, int uid, int data1, int data2) { in makeUidStatsEvent()
823 AStatsEvent* makeUidStatsEvent(int atomId, int64_t eventTimeNs, int uid, int data1, 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
2034 uint64_t eventTimeNs = 12355; in TEST() local
|