Home
last modified time | relevance | path

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

12

/packages/modules/StatsD/statsd/src/metrics/
DValueMetricProducer.cpp235 void ValueMetricProducer::onStateChanged(int64_t eventTimeNs, int32_t atomId, in onStateChanged() argument
239 (long long)mMetricId, (long long)eventTimeNs, atomId, primaryKey.toString().c_str(), in onStateChanged()
258 bool isEventLate = eventTimeNs < mCurrentBucketStartTimeNs; in onStateChanged()
260 VLOG("Skip event due to late arrival: %lld vs %lld", (long long)eventTimeNs, in onStateChanged()
262 invalidateCurrentBucket(eventTimeNs, BucketDropReason::EVENT_IN_WRONG_BUCKET); in onStateChanged()
268 pullAndMatchEventsLocked(eventTimeNs); in onStateChanged()
272 flushIfNeededLocked(eventTimeNs); in onStateChanged()
476 void ValueMetricProducer::onActiveStateChangedLocked(const int64_t& eventTimeNs) { in onActiveStateChangedLocked() argument
477 bool isEventTooLate = eventTimeNs < mCurrentBucketStartTimeNs; in onActiveStateChangedLocked()
481 invalidateCurrentBucket(eventTimeNs, BucketDropReason::EVENT_IN_WRONG_BUCKET); in onActiveStateChangedLocked()
[all …]
DDurationMetricProducer.cpp299 void DurationMetricProducer::onStateChanged(const int64_t eventTimeNs, const int32_t atomId, in onStateChanged() argument
308 flushIfNeededLocked(eventTimeNs); in onStateChanged()
324 whatIt.second->onStateChanged(eventTimeNs, atomId, newStateCopy); in onStateChanged()
407 const int64_t eventTimeNs) { in onSlicedConditionMayChangeInternalLocked() argument
410 onSlicedConditionMayChangeLocked_opt1(overallCondition, eventTimeNs); in onSlicedConditionMayChangeInternalLocked()
416 whatIt.second->onSlicedConditionMayChange(overallCondition, eventTimeNs); in onSlicedConditionMayChangeInternalLocked()
437 void DurationMetricProducer::onActiveStateChangedLocked(const int64_t& eventTimeNs) { in onActiveStateChangedLocked() argument
438 MetricProducer::onActiveStateChangedLocked(eventTimeNs); in onActiveStateChangedLocked()
446 flushIfNeededLocked(eventTimeNs); in onActiveStateChangedLocked()
450 whatIt.second->onConditionChanged(mIsActive, eventTimeNs); in onActiveStateChangedLocked()
[all …]
DGaugeMetricProducer.cpp407 void GaugeMetricProducer::onActiveStateChangedLocked(const int64_t& eventTimeNs) { in onActiveStateChangedLocked() argument
408 MetricProducer::onActiveStateChangedLocked(eventTimeNs); in onActiveStateChangedLocked()
413 pullAndMatchEventsLocked(eventTimeNs); in onActiveStateChangedLocked()
419 const int64_t eventTimeNs) { in onConditionChangedLocked() argument
427 flushIfNeededLocked(eventTimeNs); in onConditionChangedLocked()
429 pullAndMatchEventsLocked(eventTimeNs); in onConditionChangedLocked()
434 const int64_t eventTimeNs) { in onSlicedConditionMayChangeLocked() argument
442 flushIfNeededLocked(eventTimeNs); in onSlicedConditionMayChangeLocked()
446 pullAndMatchEventsLocked(eventTimeNs); in onSlicedConditionMayChangeLocked()
521 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local
[all …]
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 …]
DCountMetricProducer.cpp171 void CountMetricProducer::onStateChanged(const int64_t eventTimeNs, const int32_t atomId, in onStateChanged() argument
175 (long long)mMetricId, (long long)eventTimeNs, atomId, primaryKey.toString().c_str(), in onStateChanged()
329 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local
330 flushIfNeededLocked(eventTimeNs); in onMatchedLogEventInternalLocked()
355 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, mMetricId, eventKey, 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
[all …]
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()
224 void onStateChanged(const int64_t eventTimeNs, const int32_t atomId, in onStateChanged() argument
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()
[all …]
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,
DMetricsManager.cpp309 void MetricsManager::notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid, in notifyAppUpgrade() argument
313 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()
[all …]
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,
/packages/modules/StatsD/statsd/src/state/
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()
63 updateStateForPrimaryKey(eventTimeNs, primaryKey, newState, nested, stateValueInfo); in onLogEvent()
87 void StateTracker::handleReset(const int64_t eventTimeNs, const FieldValue& newState) { in handleReset() argument
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
[all …]
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,
/packages/modules/StatsD/statsd/tests/metrics/
DValueMetricProducer_test.cpp358 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST_P()
360 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST_P()
367 const int64_t eventTimeNs, in TEST_P() argument
369 EXPECT_EQ(eventTimeNs, partialBucketSplitTimeNs); in TEST_P()
610 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
612 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); // First condition change. in TEST()
617 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
619 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 1); // Second condition change. in TEST()
624 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
626 EXPECT_EQ(eventTimeNs, bucket3StartTimeNs + 1); // Third condition change. in TEST()
[all …]
DGaugeMetricProducer_test.cpp135 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
137 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
139 data->push_back(makeLogEvent(tagId, eventTimeNs + 10, 3, "some value", 11)); in TEST()
304 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST_P()
306 EXPECT_EQ(eventTimeNs, partialBucketSplitTimeNs); in TEST_P()
308 data->push_back(CreateRepeatedValueLogEvent(tagId, eventTimeNs, 2)); in TEST_P()
427 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
430 data->push_back(CreateRepeatedValueLogEvent(tagId, eventTimeNs + 10, 100)); in TEST()
510 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
513 data->push_back(CreateTwoValueLogEvent(tagId, eventTimeNs + 10, 1000, 100)); in TEST()
[all …]
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 …]
/packages/modules/StatsD/statsd/tests/external/
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 …]
/packages/modules/StatsD/statsd/src/metrics/duration_helper/
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()
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()
/packages/modules/StatsD/statsd/src/external/
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()
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,
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()
/packages/modules/StatsD/statsd/tests/e2e/
DConfigUpdate_e2e_test.cpp2198 int64_t eventTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST_F() local
2200 CreateAcquireWakelockEvent(eventTimeNs, attributionUids1, attributionTags1, "wl1") in TEST_F()
2202 eventTimeNs); in TEST_F()
2206 eventTimeNs = bucketStartTimeNs + 20 * NS_PER_SEC; in TEST_F()
2208 eventTimeNs, android::view::DisplayStateEnum::DISPLAY_STATE_ON) in TEST_F()
2210 eventTimeNs); in TEST_F()
2215 eventTimeNs = bucketStartTimeNs + 30 * NS_PER_SEC; in TEST_F()
2217 CreateReleaseWakelockEvent(eventTimeNs, attributionUids1, attributionTags1, "wl1") in TEST_F()
2219 eventTimeNs); in TEST_F()
2225 eventTimeNs = bucketStartTimeNs + 40 * NS_PER_SEC; in TEST_F()
[all …]
/packages/modules/StatsD/statsd/tests/
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,
Dstatsd_test_util.cpp638 void CreateTwoValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, int32_t value1, in CreateTwoValueLogEvent() argument
642 AStatsEvent_overwriteTimestamp(statsEvent, eventTimeNs); in CreateTwoValueLogEvent()
650 shared_ptr<LogEvent> CreateTwoValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value1, in CreateTwoValueLogEvent() argument
653 CreateTwoValueLogEvent(logEvent.get(), atomId, eventTimeNs, value1, value2); in CreateTwoValueLogEvent()
657 void CreateThreeValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, int32_t value1, in CreateThreeValueLogEvent() argument
661 AStatsEvent_overwriteTimestamp(statsEvent, eventTimeNs); in CreateThreeValueLogEvent()
670 shared_ptr<LogEvent> CreateThreeValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value1, in CreateThreeValueLogEvent() argument
673 CreateThreeValueLogEvent(logEvent.get(), atomId, eventTimeNs, value1, value2, value3); in CreateThreeValueLogEvent()
677 void CreateRepeatedValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, in CreateRepeatedValueLogEvent() argument
681 AStatsEvent_overwriteTimestamp(statsEvent, eventTimeNs); in CreateRepeatedValueLogEvent()
[all …]
/packages/modules/StatsD/statsd/src/packages/
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;
/packages/modules/StatsD/statsd/src/
DStatsLogProcessor.h109 void notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid,
113 void notifyAppRemoved(const int64_t& eventTimeNs, const string& apk, const int uid) override;
116 void onUidMapReceived(const int64_t& eventTimeNs) override;
188 void resetIfConfigTtlExpiredLocked(const int64_t eventTimeNs);

12