OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:eventTimeNs
(Results
1 - 18
of
18
) sorted by null
/frameworks/base/cmds/statsd/src/packages/
PackageInfoListener.h
31
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/
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
);
69
mCurrentBucketStartTimeNs =
eventTimeNs
;
73
data->setElapsedTimestampNs(
eventTimeNs
);
79
flushCurrentBucketLocked(
eventTimeNs
);
80
mCurrentBucketStartTimeNs =
eventTimeNs
;
111
void flushCurrentBucketLocked(const int64_t&
eventTimeNs
) override;
GaugeMetricProducer.h
69
void notifyAppUpgrade(const int64_t&
eventTimeNs
, const string& apk, const int uid,
73
if (
eventTimeNs
> getCurrentBucketEndTimeNs()) {
75
flushIfNeededLocked(
eventTimeNs
);
77
flushCurrentBucketLocked(
eventTimeNs
);
78
mCurrentBucketStartTimeNs =
eventTimeNs
;
80
pullLocked(
eventTimeNs
);
120
void flushCurrentBucketLocked(const int64_t&
eventTimeNs
) override;
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();
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
, mCurrentBucketNum, eventKey, wholeBucketVal)
[
all
...]
MetricProducer.h
68
void notifyAppUpgrade(const int64_t&
eventTimeNs
, const string& apk, const int uid,
72
if (
eventTimeNs
> getCurrentBucketEndTimeNs()) {
74
flushIfNeededLocked(
eventTimeNs
);
77
flushCurrentBucketLocked(
eventTimeNs
);
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
){};
[
all
...]
CountMetricProducer.cpp
268
int64_t
eventTimeNs
= event.GetElapsedTimestampNs();
269
flushIfNeededLocked(
eventTimeNs
);
294
tracker->detectAndDeclareAnomaly(
eventTimeNs
, mCurrentBucketNum, eventKey,
304
void CountMetricProducer::flushIfNeededLocked(const int64_t&
eventTimeNs
) {
306
if (
eventTimeNs
< currentBucketEndTimeNs) {
310
flushCurrentBucketLocked(
eventTimeNs
);
312
int64_t numBucketsForward = 1 + (
eventTimeNs
- currentBucketEndTimeNs) / mBucketSizeNs;
319
void CountMetricProducer::flushCurrentBucketLocked(const int64_t&
eventTimeNs
) {
323
if (
eventTimeNs
< fullBucketEndTimeNs) {
324
info.mBucketEndNs =
eventTimeNs
;
[
all
...]
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();
421
if (
eventTimeNs
< mCurrentBucketStartTimeNs) {
422
VLOG("Gauge Skip event due to late arrival: %lld vs %lld", (long long)
eventTimeNs
,
426
flushIfNeededLocked(
eventTimeNs
);
[
all
...]
MetricProducer.cpp
28
int64_t
eventTimeNs
= event.GetElapsedTimestampNs();
30
if (
eventTimeNs
< mTimeBaseNs) {
MetricsManager.h
59
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;
CountMetricProducer.h
81
void flushCurrentBucketLocked(const int64_t&
eventTimeNs
) override;
MetricsManager.cpp
147
void MetricsManager::notifyAppUpgrade(const int64_t&
eventTimeNs
, const string& apk, const int uid,
158
void MetricsManager::notifyAppRemoved(const int64_t&
eventTimeNs
, const string& apk,
169
void MetricsManager::onUidMapReceived(const int64_t&
eventTimeNs
) {
DurationMetricProducer.h
90
void flushCurrentBucketLocked(const int64_t&
eventTimeNs
) override;
DurationMetricProducer.cpp
549
void DurationMetricProducer::flushIfNeededLocked(const int64_t&
eventTimeNs
) {
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
) {
583
if (it->second->flushCurrentBucket(
eventTimeNs
, &mPastBuckets)) {
701
int64_t
eventTimeNs
= event.GetElapsedTimestampNs();
702
if (
eventTimeNs
< mTimeBaseNs) {
[
all
...]
/frameworks/base/cmds/statsd/src/metrics/duration_helper/
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);
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);
MaxDurationTracker.h
53
const int64_t&
eventTimeNs
,
OringDurationTracker.h
52
const int64_t&
eventTimeNs
,
DurationTracker.h
107
const int64_t&
eventTimeNs
,
Completed in 120 milliseconds