Home
last modified time | relevance | path

Searched defs:eventTimeNs (Results 1 – 25 of 28) sorted by relevance

12

/packages/modules/StatsD/statsd/tests/metrics/
DNumericValueMetricProducer_test.cpp418 const int64_t eventTimeNs, in TEST_P()
419 vector<std::shared_ptr<LogEvent>>* data) { in TEST_P()
638 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
645 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
646 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
772 vector<std::shared_ptr<LogEvent>>* data) { in TEST_P()
854 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST_P()
855 vector<std::shared_ptr<LogEvent>>* data) { in TEST_P()
1113 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
1114 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
[all …]
DGaugeMetricProducer_test.cpp136 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
319 vector<std::shared_ptr<LogEvent>>* data) { in TEST_P()
443 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
531 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
672 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
673 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
730 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
794 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
801 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
802 vector<std::shared_ptr<LogEvent>>* data) { in TEST()
[all …]
DCountMetricProducer_test.cpp257 int64_t eventTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST_P() local
329 int64_t eventTimeNs = bucketStartTimeNs + 65 * NS_PER_SEC; in TEST_P() local
389 int64_t eventTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST() local
/packages/modules/StatsD/statsd/src/state/
DStateTracker.cpp32 const int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onLogEvent() local
88 void StateTracker::handleReset(const int64_t eventTimeNs, const FieldValue& newState) { in handleReset()
97 void StateTracker::clearStateForPrimaryKey(const int64_t eventTimeNs, in clearStateForPrimaryKey()
113 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/
DValueMetricProducer.cpp156 const int64_t& eventTimeNs) { in onStatsdInitCompleted()
167 const int64_t eventTimeNs) { in notifyAppUpgradeInternalLocked()
225 int64_t eventTimeNs, int32_t atomId, const HashableDimensionKey& primaryKey, in onStateChanged()
474 const int64_t eventTimeNs, const bool isActive) { in onActiveStateChangedLocked()
509 const bool condition, const int64_t eventTimeNs) { in onConditionChangedLocked()
572 bool newCondition, int64_t eventTimeNs) { in updateCurrentSlicedBucketConditionTimers()
658 const int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local
720 const int64_t& eventTimeNs) { in flushIfNeededLocked()
745 const int64_t& eventTimeNs, const int64_t& nextBucketStartTimeNs) { in flushCurrentBucketLocked()
772 const int64_t eventTimeNs, const int64_t nextBucketStartTimeNs) { in closeCurrentBucket()
DMetricProducer.h208 void notifyAppUpgrade(const int64_t& eventTimeNs) { in notifyAppUpgrade()
218 void notifyAppRemoved(const int64_t& eventTimeNs) { in notifyAppRemoved()
226 virtual void onStatsdInitCompleted(const int64_t& eventTimeNs) { in onStatsdInitCompleted()
251 void onStateChanged(const int64_t eventTimeNs, const int32_t atomId, in onStateChanged()
424 virtual void flushCurrentBucketLocked(const int64_t& eventTimeNs, in flushCurrentBucketLocked()
430 void flushLocked(const int64_t& eventTimeNs) { in flushLocked()
435 virtual void notifyAppUpgradeInternalLocked(const int64_t eventTimeNs) { in notifyAppUpgradeInternalLocked()
481 virtual void onActiveStateChangedLocked(const int64_t eventTimeNs, const bool isActive) { in onActiveStateChangedLocked()
DGaugeMetricProducer.cpp413 void GaugeMetricProducer::onActiveStateChangedLocked(const int64_t eventTimeNs, in onActiveStateChangedLocked()
427 const int64_t eventTimeNs) { in onConditionChangedLocked()
443 const int64_t eventTimeNs) { in onSlicedConditionMayChangeLocked()
533 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local
611 void GaugeMetricProducer::flushIfNeededLocked(const int64_t& eventTimeNs) { in flushIfNeededLocked()
630 void GaugeMetricProducer::flushCurrentBucketLocked(const int64_t& eventTimeNs, in flushCurrentBucketLocked()
DCountMetricProducer.cpp179 void CountMetricProducer::onStateChanged(const int64_t eventTimeNs, const int32_t atomId, in onStateChanged()
355 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local
391 void CountMetricProducer::flushIfNeededLocked(const int64_t& eventTimeNs) { in flushIfNeededLocked()
427 void CountMetricProducer::flushCurrentBucketLocked(const int64_t& eventTimeNs, in flushCurrentBucketLocked()
499 void CountMetricProducer::onActiveStateChangedLocked(const int64_t eventTimeNs, in onActiveStateChangedLocked()
DDurationMetricProducer.cpp314 void DurationMetricProducer::onStateChanged(const int64_t eventTimeNs, const int32_t atomId, in onStateChanged()
420 void DurationMetricProducer::onSlicedConditionMayChangeInternalLocked(const int64_t eventTimeNs) { in onSlicedConditionMayChangeInternalLocked()
450 void DurationMetricProducer::onActiveStateChangedLocked(const int64_t eventTimeNs, in onActiveStateChangedLocked()
601 void DurationMetricProducer::flushIfNeededLocked(const int64_t& eventTimeNs) { in flushIfNeededLocked()
615 void DurationMetricProducer::flushCurrentBucketLocked(const int64_t& eventTimeNs, in flushCurrentBucketLocked()
677 const int64_t eventTimeNs, in handleStartEvent()
718 const int64_t eventTimeNs) { in handleMatchedLogEventValuesLocked()
DGaugeMetricProducer.h89 void notifyAppUpgradeInternalLocked(const int64_t eventTimeNs) override { in notifyAppUpgradeInternalLocked()
97 void onStatsdInitCompleted(const int64_t& eventTimeNs) override { in onStatsdInitCompleted()
DNumericValueMetricProducer.cpp139 void NumericValueMetricProducer::onActiveStateChangedInternalLocked(const int64_t eventTimeNs, in onActiveStateChangedInternalLocked()
151 const int64_t eventTimeNs) { in onConditionChangedInternalLocked()
392 bool NumericValueMetricProducer::aggregateFields(const int64_t eventTimeNs, in aggregateFields()
546 void NumericValueMetricProducer::closeCurrentBucket(const int64_t eventTimeNs, in closeCurrentBucket()
DMetricsManager.cpp343 void MetricsManager::notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid, in notifyAppUpgrade()
364 void MetricsManager::notifyAppRemoved(const int64_t& eventTimeNs, const string& apk, in notifyAppRemoved()
385 void MetricsManager::onUidMapReceived(const int64_t& eventTimeNs) { in onUidMapReceived()
397 void MetricsManager::onStatsdInitCompleted(const int64_t& eventTimeNs) { in onStatsdInitCompleted()
576 const int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onLogEvent() local
DKllMetricProducer.h77 const MetricDimensionKey& eventKey, bool condition, int64_t eventTimeNs, in canSkipLogEventLocked()
DValueMetricProducer.h176 virtual void onActiveStateChangedInternalLocked(const int64_t eventTimeNs, in onActiveStateChangedInternalLocked()
186 const int64_t eventTimeNs) { in onConditionChangedInternalLocked()
361 inline bool isEventLateLocked(const int64_t eventTimeNs) const { in isEventLateLocked()
DNumericValueMetricProducer.h121 const MetricDimensionKey& eventKey, const bool condition, const int64_t eventTimeNs, in canSkipLogEventLocked()
DKllMetricProducer.cpp112 bool KllMetricProducer::aggregateFields(const int64_t eventTimeNs, in aggregateFields()
/packages/modules/StatsD/statsd/tests/external/
DStatsPuller_test.cpp63 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/src/external/
DStatsPullerManager.cpp55 bool StatsPullerManager::Pull(int tagId, const ConfigKey& configKey, const int64_t eventTimeNs, in Pull()
61 bool StatsPullerManager::Pull(int tagId, const vector<int32_t>& uids, const int64_t eventTimeNs, in Pull()
68 const int64_t eventTimeNs, vector<shared_ptr<LogEvent>>* data) { in PullLocked()
89 const int64_t eventTimeNs, vector<shared_ptr<LogEvent>>* data) { in PullLocked()
DStatsPuller.cpp45 PullErrorCode StatsPuller::Pull(const int64_t eventTimeNs, in Pull()
/packages/modules/StatsD/statsd/src/condition/
DConditionTimer.h73 ConditionDurationInfo newBucketStart(int64_t eventTimeNs, int64_t nextBucketStartNs) { in newBucketStart()
/packages/modules/StatsD/statsd/tests/
Dstatsd_test_util.cpp737 void CreateTwoValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, int32_t value1, in CreateTwoValueLogEvent()
749 shared_ptr<LogEvent> CreateTwoValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value1, in CreateTwoValueLogEvent()
756 void CreateThreeValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, int32_t value1, in CreateThreeValueLogEvent()
769 shared_ptr<LogEvent> CreateThreeValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value1, in CreateThreeValueLogEvent()
776 void CreateRepeatedValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, in CreateRepeatedValueLogEvent()
788 shared_ptr<LogEvent> CreateRepeatedValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value) { in CreateRepeatedValueLogEvent()
794 void CreateNoValuesLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs) { in CreateNoValuesLogEvent()
802 shared_ptr<LogEvent> CreateNoValuesLogEvent(int atomId, int64_t eventTimeNs) { in CreateNoValuesLogEvent()
808 AStatsEvent* makeUidStatsEvent(int atomId, int64_t eventTimeNs, int uid, int data1, int data2) { in makeUidStatsEvent()
821 AStatsEvent* makeUidStatsEvent(int atomId, int64_t eventTimeNs, int uid, int data1, in makeUidStatsEvent()
[all …]
DStatsLogProcessor_test.cpp1888 uint64_t eventTimeNs = 12355; in TEST() local
1913 uint64_t eventTimeNs = 12355; in TEST() local
1943 uint64_t eventTimeNs = 12355; in TEST() local
1971 uint64_t eventTimeNs = 12355; in TEST() local
2000 uint64_t eventTimeNs = 12355; in TEST() local
2039 uint64_t eventTimeNs = 12355; in TEST() local
/packages/modules/StatsD/statsd/src/metrics/duration_helper/
DMaxDurationTracker.cpp168 const int64_t& eventTimeNs, const optional<UploadThreshold>& uploadThreshold, in flushCurrentBucket()
226 int64_t eventTimeNs, const optional<UploadThreshold>& uploadThreshold, in flushIfNeeded()
DOringDurationTracker.cpp138 const int64_t& eventTimeNs, const optional<UploadThreshold>& uploadThreshold, in flushCurrentBucket()
234 int64_t eventTimeNs, const optional<UploadThreshold>& uploadThreshold, in flushIfNeeded()
/packages/modules/StatsD/statsd/src/
DStatsLogProcessor.cpp823 void StatsLogProcessor::resetIfConfigTtlExpiredLocked(const int64_t eventTimeNs) { in resetIfConfigTtlExpiredLocked()
1405 void StatsLogProcessor::notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, in notifyAppUpgrade()
1415 void StatsLogProcessor::notifyAppRemoved(const int64_t& eventTimeNs, const string& apk, in notifyAppRemoved()
1425 void StatsLogProcessor::onUidMapReceived(const int64_t& eventTimeNs) { in onUidMapReceived()

12