Searched refs:eventTimeNs (Results 1 - 18 of 18) sorted by relevance

/frameworks/base/cmds/statsd/src/packages/
H A DPackageInfoListener.h31 virtual void notifyAppUpgrade(const int64_t& eventTimeNs, const std::string& apk,
35 virtual void notifyAppRemoved(const int64_t& eventTimeNs, const std::string& apk,
39 virtual void onUidMapReceived(const int64_t& eventTimeNs) = 0;
/frameworks/base/cmds/statsd/src/metrics/
H A DValueMetricProducer.h50 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 DGaugeMetricProducer.h69 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 DValueMetricProducer.cpp273 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...]
H A DMetricProducer.h68 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 DCountMetricProducer.cpp268 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 DGaugeMetricProducer.cpp350 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 DMetricProducer.cpp28 int64_t eventTimeNs = event.GetElapsedTimestampNs(); local
30 if (eventTimeNs < mTimeBaseNs) {
H A DMetricsManager.h59 void notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid,
62 void notifyAppRemoved(const int64_t& eventTimeNs, const string& apk, const int uid) override;
64 void onUidMapReceived(const int64_t& eventTimeNs) override;
H A DCountMetricProducer.h81 void flushCurrentBucketLocked(const int64_t& eventTimeNs) override;
H A DMetricsManager.cpp147 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 DDurationMetricProducer.h90 void flushCurrentBucketLocked(const int64_t& eventTimeNs) override;
H A DDurationMetricProducer.cpp549 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) {
/frameworks/base/cmds/statsd/src/metrics/duration_helper/
H A DMaxDurationTracker.cpp189 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 DOringDurationTracker.cpp139 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
H A DMaxDurationTracker.h53 const int64_t& eventTimeNs,
H A DOringDurationTracker.h52 const int64_t& eventTimeNs,
H A DDurationTracker.h107 const int64_t& eventTimeNs,

Completed in 286 milliseconds