OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:nextPullTimeNs
(Results
1 - 5
of
5
) sorted by null
/frameworks/base/cmds/statsd/src/external/
StatsPullerManager.h
29
virtual void RegisterReceiver(int tagId, wp<PullDataReceiver> receiver, int64_t
nextPullTimeNs
,
31
mPullerManager.RegisterReceiver(tagId, receiver,
nextPullTimeNs
, intervalNs);
StatsPullerManagerImpl.cpp
231
int64_t
nextPullTimeNs
, int64_t intervalNs) {
253
receiverInfo.
nextPullTimeNs
=
nextPullTimeNs
;
257
if (
nextPullTimeNs
< mNextPullTimeNs) {
259
mNextPullTimeNs =
nextPullTimeNs
;
292
if (receiverInfo.
nextPullTimeNs
<= currentTimeNs) {
295
if (receiverInfo.
nextPullTimeNs
< minNextPullTimeNs) {
296
minNextPullTimeNs = receiverInfo.
nextPullTimeNs
;
314
receiverInfo->
nextPullTimeNs
=
315
(currentTimeNs - receiverInfo->
nextPullTimeNs
) /
[
all
...]
StatsPullerManagerImpl.h
53
void RegisterReceiver(int tagId, wp<PullDataReceiver> receiver, int64_t
nextPullTimeNs
,
79
int64_t
nextPullTimeNs
;
/frameworks/base/cmds/statsd/tests/e2e/
GaugeMetric_e2e_pull_test.cpp
81
int64_t&
nextPullTimeNs
= StatsPullerManagerImpl::GetInstance().mReceivers.begin()->
82
second.front().
nextPullTimeNs
;
83
EXPECT_EQ(baseTimeNs + startBucketNum * bucketSizeNs + bucketSizeNs,
nextPullTimeNs
);
90
processor->informPullAlarmFired(
nextPullTimeNs
+ 1);
91
EXPECT_EQ(baseTimeNs + startBucketNum * bucketSizeNs + 2 * bucketSizeNs,
nextPullTimeNs
);
101
processor->informPullAlarmFired(
nextPullTimeNs
+ 1);
103
nextPullTimeNs
);
105
processor->informPullAlarmFired(
nextPullTimeNs
+ 1);
106
EXPECT_EQ(baseTimeNs + startBucketNum * bucketSizeNs + 4 * bucketSizeNs,
nextPullTimeNs
);
112
processor->informPullAlarmFired(
nextPullTimeNs
+ 3)
[
all
...]
ValueMetric_pull_e2e_test.cpp
82
second.front().
nextPullTimeNs
;
189
second.front().
nextPullTimeNs
;
Completed in 132 milliseconds