Home
last modified time | relevance | path

Searched refs:eventTimeNs (Results 1 – 22 of 22) sorted by relevance

/frameworks/base/cmds/statsd/src/metrics/
DGaugeMetricProducer.cpp360 void GaugeMetricProducer::onActiveStateChangedLocked(const int64_t& eventTimeNs) { in onActiveStateChangedLocked() argument
361 MetricProducer::onActiveStateChangedLocked(eventTimeNs); in onActiveStateChangedLocked()
366 pullAndMatchEventsLocked(eventTimeNs); in onActiveStateChangedLocked()
372 const int64_t eventTimeNs) { in onConditionChangedLocked() argument
380 flushIfNeededLocked(eventTimeNs); in onConditionChangedLocked()
382 pullAndMatchEventsLocked(eventTimeNs); in onConditionChangedLocked()
387 const int64_t eventTimeNs) { in onSlicedConditionMayChangeLocked() argument
395 flushIfNeededLocked(eventTimeNs); in onSlicedConditionMayChangeLocked()
399 pullAndMatchEventsLocked(eventTimeNs); in onSlicedConditionMayChangeLocked()
466 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local
[all …]
DMetricProducer.h106 virtual void notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid, in notifyAppUpgrade() argument
110 if (eventTimeNs > getCurrentBucketEndTimeNs()) { in notifyAppUpgrade()
112 flushIfNeededLocked(eventTimeNs); in notifyAppUpgrade()
115 flushCurrentBucketLocked(eventTimeNs, eventTimeNs); in notifyAppUpgrade()
120 void notifyAppRemoved(const int64_t& eventTimeNs, const string& apk, const int uid) { in notifyAppRemoved() argument
122 notifyAppUpgrade(eventTimeNs, apk, uid, 0); in notifyAppRemoved()
282 virtual void flushLocked(const int64_t& eventTimeNs) { in flushLocked() argument
283 flushIfNeededLocked(eventTimeNs); in flushLocked()
284 flushCurrentBucketLocked(eventTimeNs, eventTimeNs); in flushLocked()
297 virtual void flushCurrentBucketLocked(const int64_t& eventTimeNs, in flushCurrentBucketLocked() argument
[all …]
DValueMetricProducer.cpp370 void ValueMetricProducer::onActiveStateChangedLocked(const int64_t& eventTimeNs) { in onActiveStateChangedLocked() argument
371 bool isEventTooLate = eventTimeNs < mCurrentBucketStartTimeNs; in onActiveStateChangedLocked()
378 MetricProducer::onActiveStateChangedLocked(eventTimeNs); in onActiveStateChangedLocked()
387 pullAndMatchEventsLocked(eventTimeNs, mCondition); in onActiveStateChangedLocked()
396 flushIfNeededLocked(eventTimeNs); in onActiveStateChangedLocked()
399 mConditionTimer.onConditionChanged(mIsActive, eventTimeNs); in onActiveStateChangedLocked()
403 const int64_t eventTimeNs) { in onConditionChangedLocked() argument
405 bool isEventTooLate = eventTimeNs < mCurrentBucketStartTimeNs; in onConditionChangedLocked()
409 VLOG("Skip event due to late arrival: %lld vs %lld", (long long)eventTimeNs, in onConditionChangedLocked()
436 pullAndMatchEventsLocked(eventTimeNs, newCondition); in onConditionChangedLocked()
[all …]
DGaugeMetricProducer.h74 void notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid, in notifyAppUpgrade() argument
81 if (eventTimeNs > getCurrentBucketEndTimeNs()) { in notifyAppUpgrade()
83 flushIfNeededLocked(eventTimeNs); in notifyAppUpgrade()
85 flushCurrentBucketLocked(eventTimeNs, eventTimeNs); in notifyAppUpgrade()
87 pullAndMatchEventsLocked(eventTimeNs); in notifyAppUpgrade()
110 void onActiveStateChangedLocked(const int64_t& eventTimeNs) override;
125 void flushCurrentBucketLocked(const int64_t& eventTimeNs,
DDurationMetricProducer.cpp342 const int64_t eventTimeNs) { in onSlicedConditionMayChangeInternalLocked() argument
346 onSlicedConditionMayChangeLocked_opt1(overallCondition, eventTimeNs); in onSlicedConditionMayChangeInternalLocked()
352 onSlicedConditionMayChangeLocked_opt2(overallCondition, eventTimeNs); in onSlicedConditionMayChangeInternalLocked()
359 pair.second->onSlicedConditionMayChange(overallCondition, eventTimeNs); in onSlicedConditionMayChangeInternalLocked()
385 whatIt.second.begin()->second->clone(eventTimeNs); in onSlicedConditionMayChangeInternalLocked()
388 newTracker->onSlicedConditionMayChange(overallCondition, eventTimeNs); in onSlicedConditionMayChangeInternalLocked()
414 auto newTracker = whatIt.second.begin()->second->clone(eventTimeNs); in onSlicedConditionMayChangeInternalLocked()
417 newTracker->onSlicedConditionMayChange(overallCondition, eventTimeNs); in onSlicedConditionMayChangeInternalLocked()
443 void DurationMetricProducer::onActiveStateChangedLocked(const int64_t& eventTimeNs) { in onActiveStateChangedLocked() argument
444 MetricProducer::onActiveStateChangedLocked(eventTimeNs); in onActiveStateChangedLocked()
[all …]
DCountMetricProducer.cpp280 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local
281 flushIfNeededLocked(eventTimeNs); in onMatchedLogEventInternalLocked()
306 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, mMetricId, eventKey, in onMatchedLogEventInternalLocked()
316 void CountMetricProducer::flushIfNeededLocked(const int64_t& eventTimeNs) { in flushIfNeededLocked() argument
318 if (eventTimeNs < currentBucketEndTimeNs) { in flushIfNeededLocked()
323 int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked()
325 flushCurrentBucketLocked(eventTimeNs, nextBucketNs); in flushIfNeededLocked()
332 void CountMetricProducer::flushCurrentBucketLocked(const int64_t& eventTimeNs, in flushCurrentBucketLocked() argument
337 if (eventTimeNs < fullBucketEndTimeNs) { in flushCurrentBucketLocked()
338 info.mBucketEndNs = eventTimeNs; in flushCurrentBucketLocked()
[all …]
DValueMetricProducer.h67 void notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid, in notifyAppUpgrade() argument
74 pullAndMatchEventsLocked(eventTimeNs, mCondition); in notifyAppUpgrade()
76 flushCurrentBucketLocked(eventTimeNs, eventTimeNs); in notifyAppUpgrade()
95 void onActiveStateChangedLocked(const int64_t& eventTimeNs) override;
114 void flushCurrentBucketLocked(const int64_t& eventTimeNs,
125 int64_t calcBucketsForwardCount(const int64_t& eventTimeNs) const;
195 void appendToFullBucket(int64_t eventTimeNs, int64_t fullBucketEndTimeNs);
DMetricsManager.cpp175 void MetricsManager::notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid, in notifyAppUpgrade() argument
179 it->notifyAppUpgrade(eventTimeNs, apk, uid, version); in notifyAppUpgrade()
190 void MetricsManager::notifyAppRemoved(const int64_t& eventTimeNs, const string& apk, in notifyAppRemoved() argument
194 it->notifyAppRemoved(eventTimeNs, apk, uid); in notifyAppRemoved()
205 void MetricsManager::onUidMapReceived(const int64_t& eventTimeNs) { in onUidMapReceived() argument
362 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onLogEvent() local
372 metric->flushIfExpire(eventTimeNs); in onLogEvent()
410 metric->flushIfExpire(eventTimeNs); in onLogEvent()
423 mAllMetricProducers[metricIndex]->activate(it.first, eventTimeNs); in onLogEvent()
468 eventTimeNs); in onLogEvent()
[all …]
DDurationMetricProducer.h77 void onActiveStateChangedLocked(const int64_t& eventTimeNs) override;
83 const int64_t eventTimeNs);
98 void flushCurrentBucketLocked(const int64_t& eventTimeNs,
DMetricsManager.h65 void notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid,
68 void notifyAppRemoved(const int64_t& eventTimeNs, const string& apk, const int uid);
70 void onUidMapReceived(const int64_t& eventTimeNs);
DMetricProducer.cpp46 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventLocked() local
48 if (eventTimeNs < mTimeBaseNs) { in onMatchedLogEventLocked()
DCountMetricProducer.h82 void flushCurrentBucketLocked(const int64_t& eventTimeNs,
/frameworks/base/cmds/statsd/src/packages/
DPackageInfoListener.h30 virtual void notifyAppUpgrade(const int64_t& eventTimeNs, const std::string& apk,
34 virtual void notifyAppRemoved(const int64_t& eventTimeNs, const std::string& apk,
38 virtual void onUidMapReceived(const int64_t& eventTimeNs) = 0;
/frameworks/base/cmds/statsd/src/metrics/duration_helper/
DMaxDurationTracker.cpp189 const int64_t& eventTimeNs, in flushCurrentBucket() argument
197 if (eventTimeNs >= fullBucketEnd) { in flushCurrentBucket()
198 numBucketsForward = 1 + (eventTimeNs - fullBucketEnd) / mBucketSizeNs; in flushCurrentBucket()
202 currentBucketEndTimeNs = eventTimeNs; in flushCurrentBucket()
232 mCurrentBucketStartTimeNs = eventTimeNs; in flushCurrentBucket()
241 int64_t eventTimeNs, unordered_map<MetricDimensionKey, vector<DurationBucket>>* output) { in flushIfNeeded() argument
242 if (eventTimeNs < getCurrentBucketEndTimeNs()) { in flushIfNeeded()
245 return flushCurrentBucket(eventTimeNs, output); in flushIfNeeded()
DOringDurationTracker.cpp139 const int64_t& eventTimeNs, in flushCurrentBucket() argument
150 if (eventTimeNs >= fullBucketEnd) { in flushCurrentBucket()
151 numBucketsForward = 1 + (eventTimeNs - fullBucketEnd) / mBucketSizeNs; in flushCurrentBucket()
155 currentBucketEndTimeNs = eventTimeNs; in flushCurrentBucket()
171 if (eventTimeNs > fullBucketEnd) { in flushCurrentBucket()
201 mCurrentBucketStartTimeNs = eventTimeNs; in flushCurrentBucket()
210 int64_t eventTimeNs, unordered_map<MetricDimensionKey, vector<DurationBucket>>* output) { in flushIfNeeded() argument
211 if (eventTimeNs < getCurrentBucketEndTimeNs()) { in flushIfNeeded()
214 return flushCurrentBucket(eventTimeNs, output); in flushIfNeeded()
DMaxDurationTracker.h53 const int64_t& eventTimeNs,
DOringDurationTracker.h51 const int64_t& eventTimeNs,
DDurationTracker.h106 const int64_t& eventTimeNs,
/frameworks/base/cmds/statsd/src/
DStatsLogProcessor.h95 void notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid,
99 void notifyAppRemoved(const int64_t& eventTimeNs, const string& apk, const int uid) override;
102 void onUidMapReceived(const int64_t& eventTimeNs) override;
DStatsLogProcessor.cpp736 void StatsLogProcessor::notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, in notifyAppUpgrade() argument
741 it.second->notifyAppUpgrade(eventTimeNs, apk, uid, version); in notifyAppUpgrade()
745 void StatsLogProcessor::notifyAppRemoved(const int64_t& eventTimeNs, const string& apk, in notifyAppRemoved() argument
750 it.second->notifyAppRemoved(eventTimeNs, apk, uid); in notifyAppRemoved()
754 void StatsLogProcessor::onUidMapReceived(const int64_t& eventTimeNs) { in onUidMapReceived() argument
758 it.second->onUidMapReceived(eventTimeNs); in onUidMapReceived()
/frameworks/base/cmds/statsd/tests/external/
DStatsPuller_test.cpp59 shared_ptr<LogEvent> createSimpleEvent(int64_t eventTimeNs, int64_t value) { in createSimpleEvent() argument
60 shared_ptr<LogEvent> event = make_shared<LogEvent>(pullTagId, eventTimeNs); in createSimpleEvent()
/frameworks/base/cmds/statsd/tests/metrics/
DValueMetricProducer_test.cpp83 static shared_ptr<LogEvent> createEvent(int64_t eventTimeNs, int64_t value) { in createEvent() argument
84 shared_ptr<LogEvent> event = make_shared<LogEvent>(tagId, eventTimeNs); in createEvent()