Home
last modified time | relevance | path

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

12

/aosp12/packages/modules/StatsD/statsd/src/state/
H A DStateTracker.cpp32 const int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onLogEvent() local
41 clearStateForPrimaryKey(eventTimeNs, primaryKey); in onLogEvent()
50 clearStateForPrimaryKey(eventTimeNs, primaryKey); in onLogEvent()
57 handleReset(eventTimeNs, resetStateFieldValue); in onLogEvent()
90 updateStateForPrimaryKey(eventTimeNs, primaryKey, newState, in handleReset()
96 void StateTracker::clearStateForPrimaryKey(const int64_t eventTimeNs, in clearStateForPrimaryKey() argument
106 updateStateForPrimaryKey(eventTimeNs, primaryKey, state, in clearStateForPrimaryKey()
112 void StateTracker::updateStateForPrimaryKey(const int64_t eventTimeNs, in updateStateForPrimaryKey() argument
156 notifyListeners(eventTimeNs, primaryKey, oldState, newState); in updateStateForPrimaryKey()
162 notifyListeners(eventTimeNs, primaryKey, oldState, newState); in updateStateForPrimaryKey()
[all …]
H A DStateTracker.h75 void handleReset(const int64_t eventTimeNs, const FieldValue& newState);
78 void clearStateForPrimaryKey(const int64_t eventTimeNs, const HashableDimensionKey& primaryKey);
81 void updateStateForPrimaryKey(const int64_t eventTimeNs, const HashableDimensionKey& primaryKey,
86 void notifyListeners(const int64_t eventTimeNs, const HashableDimensionKey& primaryKey,
/aosp12/packages/modules/StatsD/statsd/src/metrics/
H A DValueMetricProducer.cpp268 pullAndMatchEventsLocked(eventTimeNs); in onStateChanged()
272 flushIfNeededLocked(eventTimeNs); in onStateChanged()
494 pullAndMatchEventsLocked(eventTimeNs); in onActiveStateChangedLocked()
503 flushIfNeededLocked(eventTimeNs); in onActiveStateChangedLocked()
558 pullAndMatchEventsLocked(eventTimeNs); in onConditionChangedLocked()
572 flushIfNeededLocked(eventTimeNs); in onConditionChangedLocked()
843 if (eventTimeNs < mCurrentBucketStartTimeNs) { in onMatchedLogEventInternalLocked()
852 flushIfNeededLocked(eventTimeNs); in onMatchedLogEventInternalLocked()
1038 if (eventTimeNs < currentBucketEndTimeNs) { in flushIfNeededLocked()
1050 if (eventTimeNs < currentBucketEndTimeNs) { in calcBucketsForwardCount()
[all …]
H A DDurationMetricProducer.cpp308 flushIfNeededLocked(eventTimeNs); in onStateChanged()
407 const int64_t eventTimeNs) { in onSlicedConditionMayChangeInternalLocked() argument
438 MetricProducer::onActiveStateChangedLocked(eventTimeNs); in onActiveStateChangedLocked()
446 flushIfNeededLocked(eventTimeNs); in onActiveStateChangedLocked()
453 flushIfNeededLocked(eventTimeNs); in onActiveStateChangedLocked()
578 if (currentBucketEndTimeNs > eventTimeNs) { in flushIfNeededLocked()
584 flushCurrentBucketLocked(eventTimeNs, nextBucketNs); in flushIfNeededLocked()
683 if (eventTimeNs < mTimeBaseNs) { in handleMatchedLogEventValuesLocked()
688 flushIfNeededLocked(eventTimeNs); in handleMatchedLogEventValuesLocked()
694 whatIt.second->noteStopAll(eventTimeNs); in handleMatchedLogEventValuesLocked()
[all …]
H A DGaugeMetricProducer.cpp413 pullAndMatchEventsLocked(eventTimeNs); in onActiveStateChangedLocked()
427 flushIfNeededLocked(eventTimeNs); in onConditionChangedLocked()
429 pullAndMatchEventsLocked(eventTimeNs); in onConditionChangedLocked()
442 flushIfNeededLocked(eventTimeNs); in onSlicedConditionMayChangeLocked()
446 pullAndMatchEventsLocked(eventTimeNs); in onSlicedConditionMayChangeLocked()
522 if (eventTimeNs < mCurrentBucketStartTimeNs) { in onMatchedLogEventInternalLocked()
527 flushIfNeededLocked(eventTimeNs); in onMatchedLogEventInternalLocked()
530 pullAndMatchEventsLocked(eventTimeNs); in onMatchedLogEventInternalLocked()
599 if (eventTimeNs < currentBucketEndTimeNs) { in flushIfNeededLocked()
618 int64_t bucketEndTime = eventTimeNs < fullBucketEndTimeNs ? eventTimeNs : fullBucketEndTimeNs; in flushCurrentBucketLocked()
[all …]
H A DValueMetricProducer.h72 void notifyAppUpgrade(const int64_t& eventTimeNs) override { in notifyAppUpgrade() argument
78 pullAndMatchEventsLocked(eventTimeNs); in notifyAppUpgrade()
80 flushCurrentBucketLocked(eventTimeNs, eventTimeNs); in notifyAppUpgrade()
84 void onStatsdInitCompleted(const int64_t& eventTimeNs) override { in onStatsdInitCompleted() argument
87 pullAndMatchEventsLocked(eventTimeNs); in onStatsdInitCompleted()
89 flushCurrentBucketLocked(eventTimeNs, eventTimeNs); in onStatsdInitCompleted()
92 void onStateChanged(int64_t eventTimeNs, int32_t atomId, const HashableDimensionKey& primaryKey,
115 void onActiveStateChangedLocked(const int64_t& eventTimeNs) override;
134 void flushCurrentBucketLocked(const int64_t& eventTimeNs,
145 int64_t calcBucketsForwardCount(const int64_t& eventTimeNs) const;
[all …]
H A DGaugeMetricProducer.h78 void notifyAppUpgrade(const int64_t& eventTimeNs) override { in notifyAppUpgrade() argument
84 flushLocked(eventTimeNs); in notifyAppUpgrade()
86 pullAndMatchEventsLocked(eventTimeNs); in notifyAppUpgrade()
91 void onStatsdInitCompleted(const int64_t& eventTimeNs) override { in onStatsdInitCompleted() argument
94 flushLocked(eventTimeNs); in onStatsdInitCompleted()
96 pullAndMatchEventsLocked(eventTimeNs); in onStatsdInitCompleted()
123 void onActiveStateChangedLocked(const int64_t& eventTimeNs) override;
138 void flushCurrentBucketLocked(const int64_t& eventTimeNs,
H A DCountMetricProducer.cpp171 void CountMetricProducer::onStateChanged(const int64_t eventTimeNs, const int32_t atomId, in onStateChanged() argument
329 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local
330 flushIfNeededLocked(eventTimeNs); in onMatchedLogEventInternalLocked()
365 void CountMetricProducer::flushIfNeededLocked(const int64_t& eventTimeNs) { in flushIfNeededLocked() argument
367 if (eventTimeNs < currentBucketEndTimeNs) { in flushIfNeededLocked()
372 int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked()
374 flushCurrentBucketLocked(eventTimeNs, nextBucketNs); in flushIfNeededLocked()
401 void CountMetricProducer::flushCurrentBucketLocked(const int64_t& eventTimeNs, in flushCurrentBucketLocked() argument
406 if (eventTimeNs < fullBucketEndTimeNs) { in flushCurrentBucketLocked()
407 info.mBucketEndNs = eventTimeNs; in flushCurrentBucketLocked()
[all …]
H A DMetricProducer.h186 virtual void notifyAppUpgrade(const int64_t& eventTimeNs) { in notifyAppUpgrade() argument
188 flushLocked(eventTimeNs); in notifyAppUpgrade()
191 void notifyAppRemoved(const int64_t& eventTimeNs) { in notifyAppRemoved() argument
193 notifyAppUpgrade(eventTimeNs); in notifyAppRemoved()
199 virtual void onStatsdInitCompleted(const int64_t& eventTimeNs) { in onStatsdInitCompleted() argument
201 flushLocked(eventTimeNs); in onStatsdInitCompleted()
376 virtual void flushCurrentBucketLocked(const int64_t& eventTimeNs, in flushCurrentBucketLocked() argument
382 virtual void flushLocked(const int64_t& eventTimeNs) { in flushLocked() argument
383 flushIfNeededLocked(eventTimeNs); in flushLocked()
384 flushCurrentBucketLocked(eventTimeNs, eventTimeNs); in flushLocked()
[all …]
H A DDurationMetricProducer.h62 void onStateChanged(const int64_t eventTimeNs, const int32_t atomId,
84 const int64_t eventTimeNs);
86 bool condition, const int64_t eventTimeNs,
102 void onActiveStateChangedLocked(const int64_t& eventTimeNs) override;
108 const int64_t eventTimeNs);
123 void flushCurrentBucketLocked(const int64_t& eventTimeNs,
H A DMetricsManager.cpp313 it->notifyAppUpgrade(eventTimeNs); in notifyAppUpgrade()
330 void MetricsManager::notifyAppRemoved(const int64_t& eventTimeNs, const string& apk, in notifyAppRemoved() argument
334 it->notifyAppRemoved(eventTimeNs); in notifyAppRemoved()
351 void MetricsManager::onUidMapReceived(const int64_t& eventTimeNs) { in onUidMapReceived() argument
363 void MetricsManager::onStatsdInitCompleted(const int64_t& eventTimeNs) { in onStatsdInitCompleted() argument
366 it->onStatsdInitCompleted(eventTimeNs); in onStatsdInitCompleted()
539 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onLogEvent() local
549 metric->flushIfExpire(eventTimeNs); in onLogEvent()
588 metric->flushIfExpire(eventTimeNs); in onLogEvent()
601 mAllMetricProducers[metricIndex]->activate(it.first, eventTimeNs); in onLogEvent()
[all …]
/aosp12/packages/modules/StatsD/statsd/tests/external/
H A DStatsPuller_test.cpp63 std::unique_ptr<LogEvent> createSimpleEvent(int64_t eventTimeNs, int64_t value) { in createSimpleEvent() argument
66 AStatsEvent_overwriteTimestamp(statsEvent, eventTimeNs); in createSimpleEvent()
238 int64_t eventTimeNs = getElapsedRealtimeNs(); in TEST_F() local
241 EXPECT_TRUE(puller.Pull(eventTimeNs, &dataHolder)); in TEST_F()
256 EXPECT_TRUE(puller.Pull(eventTimeNs, &dataHolder)); in TEST_F()
268 int64_t eventTimeNs = getElapsedRealtimeNs(); in TEST_F() local
273 EXPECT_FALSE(puller.Pull(eventTimeNs, &dataHolder)); in TEST_F()
285 EXPECT_FALSE(puller.Pull(eventTimeNs, &dataHolder)); in TEST_F()
293 int64_t eventTimeNs = getElapsedRealtimeNs(); in TEST_F() local
296 EXPECT_FALSE(puller.Pull(eventTimeNs, &dataHolder)); in TEST_F()
[all …]
/aosp12/packages/modules/StatsD/statsd/tests/metrics/
H A DGaugeMetricProducer_test.cpp137 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
306 EXPECT_EQ(eventTimeNs, partialBucketSplitTimeNs); in TEST_P()
308 data->push_back(CreateRepeatedValueLogEvent(tagId, eventTimeNs, 2)); in TEST_P()
644 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
651 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20); in TEST()
712 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 3); in TEST()
714 data->push_back(CreateTwoValueLogEvent(tagId, eventTimeNs, 3, 4)); in TEST()
719 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
721 data->push_back(CreateTwoValueLogEvent(tagId, eventTimeNs, 4, 5)); in TEST()
726 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20); in TEST()
[all …]
H A DValueMetricProducer_test.cpp360 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST_P()
841 EXPECT_EQ(eventTimeNs, in TEST_P()
1071 EXPECT_EQ(eventTimeNs, in TEST()
2035 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
2630 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST_P()
2787 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST_P()
3006 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
3971 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
4213 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
4521 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
[all …]
H A DCountMetricProducer_test.cpp254 int64_t eventTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST_P() local
286 countProducer.notifyAppUpgrade(eventTimeNs); in TEST_P()
289 countProducer.onStatsdInitCompleted(eventTimeNs); in TEST_P()
295 EXPECT_EQ(eventTimeNs, in TEST_P()
298 EXPECT_EQ(eventTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST_P()
308 EXPECT_EQ(eventTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST_P()
325 int64_t eventTimeNs = bucketStartTimeNs + 65 * NS_PER_SEC; in TEST_P() local
350 countProducer.notifyAppUpgrade(eventTimeNs); in TEST_P()
353 countProducer.onStatsdInitCompleted(eventTimeNs); in TEST_P()
361 EXPECT_EQ(eventTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST_P()
[all …]
H A Dmetrics_test_helper.h41 MOCK_METHOD4(Pull, bool(const int pullCode, const ConfigKey& key, const int64_t eventTimeNs,
44 const int64_t eventTimeNs, vector<std::shared_ptr<LogEvent>>* data));
/aosp12/packages/modules/StatsD/statsd/src/metrics/duration_helper/
H A DMaxDurationTracker.cpp165 const int64_t& eventTimeNs, const optional<UploadThreshold>& uploadThreshold, in flushCurrentBucket() argument
173 if (eventTimeNs >= fullBucketEnd) { in flushCurrentBucket()
174 numBucketsForward = 1 + (eventTimeNs - fullBucketEnd) / mBucketSizeNs; in flushCurrentBucket()
178 currentBucketEndTimeNs = eventTimeNs; in flushCurrentBucket()
210 mCurrentBucketStartTimeNs = eventTimeNs; in flushCurrentBucket()
219 int64_t eventTimeNs, const optional<UploadThreshold>& uploadThreshold, in flushIfNeeded() argument
221 if (eventTimeNs < getCurrentBucketEndTimeNs()) { in flushIfNeeded()
224 return flushCurrentBucket(eventTimeNs, uploadThreshold, output); in flushIfNeeded()
H A DOringDurationTracker.cpp135 const int64_t& eventTimeNs, const optional<UploadThreshold>& uploadThreshold, in flushCurrentBucket() argument
146 bool isFullBucket = eventTimeNs >= fullBucketEnd; in flushCurrentBucket()
148 numBucketsForward = 1 + (eventTimeNs - fullBucketEnd) / mBucketSizeNs; in flushCurrentBucket()
152 currentBucketEndTimeNs = eventTimeNs; in flushCurrentBucket()
214 mCurrentBucketStartTimeNs = eventTimeNs; in flushCurrentBucket()
227 int64_t eventTimeNs, const optional<UploadThreshold>& uploadThreshold, in flushIfNeeded() argument
229 if (eventTimeNs < getCurrentBucketEndTimeNs()) { in flushIfNeeded()
232 return flushCurrentBucket(eventTimeNs, uploadThreshold, output); in flushIfNeeded()
/aosp12/packages/modules/StatsD/statsd/src/packages/
H A DPackageInfoListener.h32 virtual void notifyAppUpgrade(const int64_t& eventTimeNs, const std::string& apk,
36 virtual void notifyAppRemoved(const int64_t& eventTimeNs, const std::string& apk,
40 virtual void onUidMapReceived(const int64_t& eventTimeNs) = 0;
/aosp12/packages/modules/StatsD/statsd/src/external/
H A DStatsPullerManager.cpp94 bool StatsPullerManager::Pull(int tagId, const ConfigKey& configKey, const int64_t eventTimeNs, in Pull() argument
97 return PullLocked(tagId, configKey, eventTimeNs, data); in Pull()
100 bool StatsPullerManager::Pull(int tagId, const vector<int32_t>& uids, const int64_t eventTimeNs, in Pull() argument
103 return PullLocked(tagId, uids, eventTimeNs, data); in Pull()
107 const int64_t eventTimeNs, vector<shared_ptr<LogEvent>>* data) { in PullLocked() argument
124 return PullLocked(tagId, uids, eventTimeNs, data); in PullLocked()
128 const int64_t eventTimeNs, vector<shared_ptr<LogEvent>>* data) { in PullLocked() argument
134 bool ret = pullerIt->second->Pull(eventTimeNs, data); in PullLocked()
H A DStatsPullerManager.h104 virtual bool Pull(int tagId, const ConfigKey& configKey, const int64_t eventTimeNs,
108 virtual bool Pull(int tagId, const vector<int32_t>& uids, const int64_t eventTimeNs,
154 bool PullLocked(int tagId, const ConfigKey& configKey, const int64_t eventTimeNs,
157 bool PullLocked(int tagId, const vector<int32_t>& uids, const int64_t eventTimeNs,
H A DStatsPuller.cpp45 bool StatsPuller::Pull(const int64_t eventTimeNs, std::vector<std::shared_ptr<LogEvent>>* data) { in Pull() argument
51 (mLastEventTimeNs == eventTimeNs) || (elapsedTimeNs - mLastPullTimeNs < mCoolDownNs); in Pull()
66 mLastEventTimeNs = eventTimeNs; in Pull()
/aosp12/packages/modules/StatsD/statsd/tests/
H A Dstatsd_test_util.h253 shared_ptr<LogEvent> CreateTwoValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value1,
256 void CreateTwoValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, int32_t value1,
259 shared_ptr<LogEvent> CreateThreeValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value1,
262 void CreateThreeValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, int32_t value1,
268 std::shared_ptr<LogEvent> CreateRepeatedValueLogEvent(int atomId, int64_t eventTimeNs,
271 void CreateRepeatedValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs,
274 std::shared_ptr<LogEvent> CreateNoValuesLogEvent(int atomId, int64_t eventTimeNs);
276 void CreateNoValuesLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs);
278 std::shared_ptr<LogEvent> makeUidLogEvent(int atomId, int64_t eventTimeNs, int uid, int data1,
281 std::shared_ptr<LogEvent> makeAttributionLogEvent(int atomId, int64_t eventTimeNs,
H A Dstatsd_test_util.cpp642 AStatsEvent_overwriteTimestamp(statsEvent, eventTimeNs); in CreateTwoValueLogEvent()
653 CreateTwoValueLogEvent(logEvent.get(), atomId, eventTimeNs, value1, value2); in CreateTwoValueLogEvent()
661 AStatsEvent_overwriteTimestamp(statsEvent, eventTimeNs); in CreateThreeValueLogEvent()
681 AStatsEvent_overwriteTimestamp(statsEvent, eventTimeNs); in CreateRepeatedValueLogEvent()
691 CreateRepeatedValueLogEvent(logEvent.get(), atomId, eventTimeNs, value); in CreateRepeatedValueLogEvent()
698 AStatsEvent_overwriteTimestamp(statsEvent, eventTimeNs); in CreateNoValuesLogEvent()
703 shared_ptr<LogEvent> CreateNoValuesLogEvent(int atomId, int64_t eventTimeNs) { in CreateNoValuesLogEvent() argument
705 CreateNoValuesLogEvent(logEvent.get(), atomId, eventTimeNs); in CreateNoValuesLogEvent()
713 AStatsEvent_overwriteTimestamp(statsEvent, eventTimeNs); in makeUidLogEvent()
725 shared_ptr<LogEvent> makeAttributionLogEvent(int atomId, int64_t eventTimeNs, in makeAttributionLogEvent() argument
[all …]
/aosp12/packages/modules/StatsD/statsd/tests/e2e/
H A DConfigUpdate_e2e_test.cpp2202 eventTimeNs); in TEST_F()
2210 eventTimeNs); in TEST_F()
2219 eventTimeNs); in TEST_F()
2237 eventTimeNs); in TEST_F()
2245 eventTimeNs); in TEST_F()
2265 eventTimeNs); in TEST_F()
2287 eventTimeNs); in TEST_F()
2309 eventTimeNs); in TEST_F()
2378 eventTimeNs); in TEST_F()
2399 eventTimeNs); in TEST_F()
[all …]

12