Home
last modified time | relevance | path

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

12

/packages/modules/StatsD/statsd/src/metrics/
DValueMetricProducer.cpp158 const int64_t& eventTimeNs) { in onStatsdInitCompleted() argument
164 pullAndMatchEventsLocked(eventTimeNs); in onStatsdInitCompleted()
166 flushCurrentBucketLocked(eventTimeNs, eventTimeNs); in onStatsdInitCompleted()
171 const int64_t eventTimeNs) { in notifyAppUpgradeInternalLocked() argument
174 pullAndMatchEventsLocked(eventTimeNs); in notifyAppUpgradeInternalLocked()
176 flushCurrentBucketLocked(eventTimeNs, eventTimeNs); in notifyAppUpgradeInternalLocked()
227 int64_t eventTimeNs, int32_t atomId, const HashableDimensionKey& primaryKey, in onStateChanged() argument
231 (long long)mMetricId, (long long)eventTimeNs, atomId, primaryKey.toString().c_str(), in onStateChanged()
251 if (isEventLateLocked(eventTimeNs)) { in onStateChanged()
252 VLOG("Skip event due to late arrival: %lld vs %lld", (long long)eventTimeNs, in onStateChanged()
[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 …]
DValueMetricProducer.h126 void onStatsdInitCompleted(const int64_t& eventTimeNs) override;
128 void onStateChanged(int64_t eventTimeNs, int32_t atomId, const HashableDimensionKey& primaryKey,
146 const MetricDimensionKey& eventKey, bool condition, int64_t eventTimeNs,
149 void notifyAppUpgradeInternalLocked(const int64_t eventTimeNs) override;
170 void onActiveStateChangedLocked(const int64_t eventTimeNs) override;
172 virtual void onActiveStateChangedInternalLocked(const int64_t eventTimeNs) { in onActiveStateChangedInternalLocked() argument
176 void onConditionChangedLocked(const bool condition, const int64_t eventTimeNs) override;
181 const int64_t eventTimeNs) { in onConditionChangedInternalLocked() argument
197 void flushCurrentBucketLocked(const int64_t& eventTimeNs,
203 int64_t calcBucketsForwardCount(const int64_t eventTimeNs) const;
[all …]
DGaugeMetricProducer.cpp409 void GaugeMetricProducer::onActiveStateChangedLocked(const int64_t eventTimeNs) { in onActiveStateChangedLocked() argument
410 MetricProducer::onActiveStateChangedLocked(eventTimeNs); in onActiveStateChangedLocked()
415 pullAndMatchEventsLocked(eventTimeNs); in onActiveStateChangedLocked()
420 const int64_t eventTimeNs) { in onConditionChangedLocked() argument
428 flushIfNeededLocked(eventTimeNs); in onConditionChangedLocked()
430 pullAndMatchEventsLocked(eventTimeNs); in onConditionChangedLocked()
435 const int64_t eventTimeNs) { in onSlicedConditionMayChangeLocked() argument
443 flushIfNeededLocked(eventTimeNs); in onSlicedConditionMayChangeLocked()
447 pullAndMatchEventsLocked(eventTimeNs); in onSlicedConditionMayChangeLocked()
522 int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local
[all …]
DMetricProducer.h196 void notifyAppUpgrade(const int64_t& eventTimeNs) { in notifyAppUpgrade() argument
203 notifyAppUpgradeInternalLocked(eventTimeNs); in notifyAppUpgrade()
206 void notifyAppRemoved(const int64_t& eventTimeNs) { in notifyAppRemoved() argument
208 notifyAppUpgrade(eventTimeNs); in notifyAppRemoved()
214 virtual void onStatsdInitCompleted(const int64_t& eventTimeNs) { in onStatsdInitCompleted() argument
216 flushLocked(eventTimeNs); in onStatsdInitCompleted()
239 void onStateChanged(const int64_t eventTimeNs, const int32_t atomId, in onStateChanged() argument
391 virtual void flushCurrentBucketLocked(const int64_t& eventTimeNs, in flushCurrentBucketLocked() argument
397 virtual void flushLocked(const int64_t& eventTimeNs) { in flushLocked() argument
398 flushIfNeededLocked(eventTimeNs); in flushLocked()
[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 …]
DGaugeMetricProducer.h83 void notifyAppUpgradeInternalLocked(const int64_t eventTimeNs) override { in notifyAppUpgradeInternalLocked() argument
84 flushLocked(eventTimeNs); in notifyAppUpgradeInternalLocked()
86 pullAndMatchEventsLocked(eventTimeNs); in notifyAppUpgradeInternalLocked()
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,
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,
DMetricsManager.cpp312 void MetricsManager::notifyAppUpgrade(const int64_t& eventTimeNs, const string& apk, const int uid, in notifyAppUpgrade() argument
316 it->notifyAppUpgrade(eventTimeNs); in notifyAppUpgrade()
333 void MetricsManager::notifyAppRemoved(const int64_t& eventTimeNs, const string& apk, in notifyAppRemoved() argument
337 it->notifyAppRemoved(eventTimeNs); in notifyAppRemoved()
354 void MetricsManager::onUidMapReceived(const int64_t& eventTimeNs) { in onUidMapReceived() argument
366 void MetricsManager::onStatsdInitCompleted(const int64_t& eventTimeNs) { in onStatsdInitCompleted() argument
369 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 …]
DNumericValueMetricProducer.cpp131 void NumericValueMetricProducer::onActiveStateChangedInternalLocked(const int64_t eventTimeNs) { in onActiveStateChangedInternalLocked() argument
142 const int64_t eventTimeNs) { in onConditionChangedInternalLocked() argument
381 bool NumericValueMetricProducer::aggregateFields(const int64_t eventTimeNs, in aggregateFields() argument
491 if (useAnomalyDetection && !multipleBucketsSkipped(calcBucketsForwardCount(eventTimeNs))) { in aggregateFields()
499 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, mMetricId, eventKey, in aggregateFields()
532 void NumericValueMetricProducer::closeCurrentBucket(const int64_t eventTimeNs, in closeCurrentBucket() argument
534 ValueMetricProducer::closeCurrentBucket(eventTimeNs, nextBucketStartTimeNs); in closeCurrentBucket()
536 appendToFullBucket(eventTimeNs > getCurrentBucketEndTimeNs()); in closeCurrentBucket()
DNumericValueMetricProducer.h69 void onActiveStateChangedInternalLocked(const int64_t eventTimeNs) override;
74 const int64_t eventTimeNs) override;
97 void closeCurrentBucket(const int64_t eventTimeNs,
114 const MetricDimensionKey& eventKey, const bool condition, const int64_t eventTimeNs, in canSkipLogEventLocked() argument
123 bool aggregateFields(const int64_t eventTimeNs, const MetricDimensionKey& eventKey,
/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()
88 void StateTracker::handleReset(const int64_t eventTimeNs, const FieldValue& newState) { in handleReset() argument
91 updateStateForPrimaryKey(eventTimeNs, primaryKey, newState, in handleReset()
97 void StateTracker::clearStateForPrimaryKey(const int64_t eventTimeNs, in clearStateForPrimaryKey() argument
107 updateStateForPrimaryKey(eventTimeNs, primaryKey, state, in clearStateForPrimaryKey()
113 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/
DNumericValueMetricProducer_test.cpp402 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST_P()
404 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST_P()
411 const int64_t eventTimeNs, in TEST_P() argument
413 EXPECT_EQ(eventTimeNs, partialBucketSplitTimeNs); in TEST_P()
624 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
626 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); // First condition change. in TEST()
631 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
633 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 1); // Second condition change. in TEST()
638 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
640 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()
318 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST_P()
320 EXPECT_EQ(eventTimeNs, partialBucketSplitTimeNs); in TEST_P()
322 data->push_back(CreateRepeatedValueLogEvent(tagId, eventTimeNs, 2)); in TEST_P()
441 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
444 data->push_back(CreateRepeatedValueLogEvent(tagId, eventTimeNs + 10, 100)); in TEST()
529 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
532 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
287 countProducer.notifyAppUpgrade(eventTimeNs); in TEST_P()
290 countProducer.onStatsdInitCompleted(eventTimeNs); in TEST_P()
296 EXPECT_EQ(eventTimeNs, in TEST_P()
299 EXPECT_EQ(eventTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST_P()
309 EXPECT_EQ(eventTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST_P()
326 int64_t eventTimeNs = bucketStartTimeNs + 65 * NS_PER_SEC; in TEST_P() local
352 countProducer.notifyAppUpgrade(eventTimeNs); in TEST_P()
355 countProducer.onStatsdInitCompleted(eventTimeNs); in TEST_P()
363 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_EQ(puller.Pull(eventTimeNs, &dataHolder), PULL_SUCCESS); in TEST_F()
256 EXPECT_EQ(puller.Pull(eventTimeNs, &dataHolder), PULL_SUCCESS); in TEST_F()
268 int64_t eventTimeNs = getElapsedRealtimeNs(); in TEST_F() local
273 EXPECT_EQ(puller.Pull(eventTimeNs, &dataHolder), PULL_FAIL); in TEST_F()
285 EXPECT_EQ(puller.Pull(eventTimeNs, &dataHolder), PULL_FAIL); in TEST_F()
293 int64_t eventTimeNs = getElapsedRealtimeNs(); in TEST_F() local
296 EXPECT_EQ(puller.Pull(eventTimeNs, &dataHolder), PULL_FAIL); in TEST_F()
[all …]
/packages/modules/StatsD/statsd/tests/
Dstatsd_test_util.h300 shared_ptr<LogEvent> CreateTwoValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value1,
303 void CreateTwoValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, int32_t value1,
306 shared_ptr<LogEvent> CreateThreeValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value1,
309 void CreateThreeValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, int32_t value1,
315 std::shared_ptr<LogEvent> CreateRepeatedValueLogEvent(int atomId, int64_t eventTimeNs,
318 void CreateRepeatedValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs,
321 std::shared_ptr<LogEvent> CreateNoValuesLogEvent(int atomId, int64_t eventTimeNs);
323 void CreateNoValuesLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs);
325 AStatsEvent* makeUidStatsEvent(int atomId, int64_t eventTimeNs, int uid, int data1, int data2);
327 AStatsEvent* makeUidStatsEvent(int atomId, int64_t eventTimeNs, int uid, int data1,
[all …]
Dstatsd_test_util.cpp716 void CreateTwoValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, int32_t value1, in CreateTwoValueLogEvent() argument
720 AStatsEvent_overwriteTimestamp(statsEvent, eventTimeNs); in CreateTwoValueLogEvent()
728 shared_ptr<LogEvent> CreateTwoValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value1, in CreateTwoValueLogEvent() argument
731 CreateTwoValueLogEvent(logEvent.get(), atomId, eventTimeNs, value1, value2); in CreateTwoValueLogEvent()
735 void CreateThreeValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, int32_t value1, in CreateThreeValueLogEvent() argument
739 AStatsEvent_overwriteTimestamp(statsEvent, eventTimeNs); in CreateThreeValueLogEvent()
748 shared_ptr<LogEvent> CreateThreeValueLogEvent(int atomId, int64_t eventTimeNs, int32_t value1, in CreateThreeValueLogEvent() argument
751 CreateThreeValueLogEvent(logEvent.get(), atomId, eventTimeNs, value1, value2, value3); in CreateThreeValueLogEvent()
755 void CreateRepeatedValueLogEvent(LogEvent* logEvent, int atomId, int64_t eventTimeNs, in CreateRepeatedValueLogEvent() argument
759 AStatsEvent_overwriteTimestamp(statsEvent, eventTimeNs); in CreateRepeatedValueLogEvent()
[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.cpp55 bool StatsPullerManager::Pull(int tagId, const ConfigKey& configKey, const int64_t eventTimeNs, in Pull() argument
58 return PullLocked(tagId, configKey, eventTimeNs, data); in Pull()
61 bool StatsPullerManager::Pull(int tagId, const vector<int32_t>& uids, const int64_t eventTimeNs, in Pull() argument
64 return PullLocked(tagId, uids, eventTimeNs, data); in Pull()
68 const int64_t eventTimeNs, vector<shared_ptr<LogEvent>>* data) { in PullLocked() argument
85 return PullLocked(tagId, uids, eventTimeNs, data); in PullLocked()
89 const int64_t eventTimeNs, vector<shared_ptr<LogEvent>>* data) { in PullLocked() argument
95 PullErrorCode status = 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,
/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/tests/e2e/
DConfigUpdate_e2e_test.cpp2394 int64_t eventTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST_F() local
2396 CreateAcquireWakelockEvent(eventTimeNs, attributionUids1, attributionTags1, "wl1") in TEST_F()
2398 eventTimeNs); in TEST_F()
2402 eventTimeNs = bucketStartTimeNs + 20 * NS_PER_SEC; in TEST_F()
2404 eventTimeNs, android::view::DisplayStateEnum::DISPLAY_STATE_ON) in TEST_F()
2406 eventTimeNs); in TEST_F()
2411 eventTimeNs = bucketStartTimeNs + 30 * NS_PER_SEC; in TEST_F()
2413 CreateReleaseWakelockEvent(eventTimeNs, attributionUids1, attributionTags1, "wl1") in TEST_F()
2415 eventTimeNs); in TEST_F()
2421 eventTimeNs = bucketStartTimeNs + 40 * NS_PER_SEC; in TEST_F()
[all …]

12