OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
defs:eventTimeNs
(Results
1 - 8
of
8
) sorted by null
/frameworks/base/cmds/statsd/src/metrics/
MetricProducer.cpp
28
int64_t
eventTimeNs
= event.GetElapsedTimestampNs();
30
if (
eventTimeNs
< mTimeBaseNs) {
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.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;
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
...]
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
...]
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
...]
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
...]
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
...]
Completed in 92 milliseconds