/frameworks/base/cmds/statsd/src/metrics/ |
H A D | MetricProducer.cpp | 28 int64_t eventTimeNs = event.GetElapsedTimestampNs(); local 30 if (eventTimeNs < mTimeBaseNs) {
|
H A D | GaugeMetricProducer.h | 69 void notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid, 73 if (eventTimeNs > getCurrentBucketEndTimeNs()) { 75 flushIfNeededLocked(eventTimeNs); variable 77 flushCurrentBucketLocked(eventTimeNs); variable 78 mCurrentBucketStartTimeNs = eventTimeNs; 80 pullLocked(eventTimeNs); variable 120 void flushCurrentBucketLocked(const int64_t& eventTimeNs) override;
|
H A D | ValueMetricProducer.h | 50 void notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid, 56 mStatsPullerManager->Pull(mPullTagId, eventTimeNs, &allData); 64 data->setElapsedTimestampNs(eventTimeNs - 1); 68 flushCurrentBucketLocked(eventTimeNs); variable 69 mCurrentBucketStartTimeNs = eventTimeNs; 73 data->setElapsedTimestampNs(eventTimeNs); 79 flushCurrentBucketLocked(eventTimeNs); variable 80 mCurrentBucketStartTimeNs = eventTimeNs; 111 void flushCurrentBucketLocked(const int64_t& eventTimeNs) override;
|
H A D | MetricsManager.cpp | 147 void MetricsManager::notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid, argument 158 void MetricsManager::notifyAppRemoved(const int64_t& eventTimeNs, const string& apk, argument 169 void MetricsManager::onUidMapReceived(const int64_t& eventTimeNs) { argument
|
H A D | CountMetricProducer.cpp | 268 int64_t eventTimeNs = event.GetElapsedTimestampNs(); local 269 flushIfNeededLocked(eventTimeNs); 294 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, eventKey, 304 void CountMetricProducer::flushIfNeededLocked(const int64_t& eventTimeNs) { argument 306 if (eventTimeNs < currentBucketEndTimeNs) { 310 flushCurrentBucketLocked(eventTimeNs); 312 int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; 319 void CountMetricProducer::flushCurrentBucketLocked(const int64_t& eventTimeNs) { argument 323 if (eventTimeNs < fullBucketEndTimeNs) { 324 info.mBucketEndNs = eventTimeNs; [all...] |
H A D | MetricProducer.h | 68 void notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid, 72 if (eventTimeNs > getCurrentBucketEndTimeNs()) { 74 flushIfNeededLocked(eventTimeNs); variable 77 flushCurrentBucketLocked(eventTimeNs); variable 78 mCurrentBucketStartTimeNs = eventTimeNs; 83 void notifyAppRemoved(const int64_t& eventTimeNs, const string& apk, const int uid) override{ 85 notifyAppUpgrade(eventTimeNs, apk, uid, 0); 88 void onUidMapReceived(const int64_t& eventTimeNs) override{ 209 * start new bucket). If this function is called when eventTimeNs is greater than the current 216 virtual void flushCurrentBucketLocked(const int64_t& eventTimeNs){}; argument [all...] |
H A D | DurationMetricProducer.cpp | 549 void DurationMetricProducer::flushIfNeededLocked(const int64_t& eventTimeNs) { argument 552 if (currentBucketEndTimeNs > eventTimeNs) { 559 if (it->second->flushIfNeeded(eventTimeNs, &mPastBuckets)) { 574 int numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; 579 void DurationMetricProducer::flushCurrentBucketLocked(const int64_t& eventTimeNs) { argument 583 if (it->second->flushCurrentBucket(eventTimeNs, &mPastBuckets)) { 701 int64_t eventTimeNs = event.GetElapsedTimestampNs(); local 702 if (eventTimeNs < mTimeBaseNs) {
|
H A D | GaugeMetricProducer.cpp | 350 const int64_t eventTimeNs) { 352 flushIfNeededLocked(eventTimeNs); 356 pullLocked(eventTimeNs); 361 const int64_t eventTimeNs) { 364 flushIfNeededLocked(eventTimeNs); 369 pullLocked(eventTimeNs); 419 int64_t eventTimeNs = event.GetElapsedTimestampNs(); local 421 if (eventTimeNs < mCurrentBucketStartTimeNs) { 422 VLOG("Gauge Skip event due to late arrival: %lld vs %lld", (long long)eventTimeNs, 426 flushIfNeededLocked(eventTimeNs); 349 onConditionChangedLocked(const bool conditionMet, const int64_t eventTimeNs) argument 360 onSlicedConditionMayChangeLocked(bool overallCondition, const int64_t eventTimeNs) argument 440 GaugeAtom gaugeAtom(getGaugeFields(event), eventTimeNs, getWallClockNs()); local 487 flushIfNeededLocked(const int64_t& eventTimeNs) argument 506 flushCurrentBucketLocked(const int64_t& eventTimeNs) argument [all...] |
H A D | ValueMetricProducer.cpp | 273 const int64_t eventTimeNs) { 276 if (eventTimeNs < mCurrentBucketStartTimeNs) { 277 VLOG("Skip event due to late arrival: %lld vs %lld", (long long)eventTimeNs, 282 flushIfNeededLocked(eventTimeNs); 286 if (mStatsPullerManager->Pull(mPullTagId, eventTimeNs, &allData)) { 366 int64_t eventTimeNs = event.GetElapsedTimestampNs(); local 367 if (eventTimeNs < mCurrentBucketStartTimeNs) { 368 VLOG("Skip event due to late arrival: %lld vs %lld", (long long)eventTimeNs, 373 flushIfNeededLocked(eventTimeNs); 430 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNu 272 onConditionChangedLocked(const bool condition, const int64_t eventTimeNs) argument 434 flushIfNeededLocked(const int64_t& eventTimeNs) argument 456 flushCurrentBucketLocked(const int64_t& eventTimeNs) argument [all...] |
/frameworks/base/cmds/statsd/src/metrics/duration_helper/ |
H A D | MaxDurationTracker.cpp | 189 const int64_t& eventTimeNs, 197 if (eventTimeNs >= fullBucketEnd) { 198 numBucketsForward = 1 + (eventTimeNs - fullBucketEnd) / mBucketSizeNs; 202 currentBucketEndTimeNs = eventTimeNs; 232 mCurrentBucketStartTimeNs = eventTimeNs; 241 int64_t eventTimeNs, unordered_map<MetricDimensionKey, vector<DurationBucket>>* output) { 242 if (eventTimeNs < getCurrentBucketEndTimeNs()) { 245 return flushCurrentBucket(eventTimeNs, output); 188 flushCurrentBucket( const int64_t& eventTimeNs, std::unordered_map<MetricDimensionKey, std::vector<DurationBucket>>* output) argument 240 flushIfNeeded( int64_t eventTimeNs, unordered_map<MetricDimensionKey, vector<DurationBucket>>* output) argument
|
H A D | OringDurationTracker.cpp | 139 const int64_t& eventTimeNs, 150 if (eventTimeNs >= fullBucketEnd) { 151 numBucketsForward = 1 + (eventTimeNs - fullBucketEnd) / mBucketSizeNs; 155 currentBucketEndTimeNs = eventTimeNs; 171 if (eventTimeNs > fullBucketEnd) { 201 mCurrentBucketStartTimeNs = eventTimeNs; 210 int64_t eventTimeNs, unordered_map<MetricDimensionKey, vector<DurationBucket>>* output) { 211 if (eventTimeNs < getCurrentBucketEndTimeNs()) { 214 return flushCurrentBucket(eventTimeNs, output); 138 flushCurrentBucket( const int64_t& eventTimeNs, std::unordered_map<MetricDimensionKey, std::vector<DurationBucket>>* output) argument 209 flushIfNeeded( int64_t eventTimeNs, unordered_map<MetricDimensionKey, vector<DurationBucket>>* output) argument
|