Searched refs:nextPullTimeNs (Results 1 – 4 of 4) sorted by relevance
87 int64_t& nextPullTimeNs = in TEST() local88 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST()89 EXPECT_EQ(baseTimeNs + startBucketNum * bucketSizeNs + bucketSizeNs, nextPullTimeNs); in TEST()96 processor->informPullAlarmFired(nextPullTimeNs + 1); in TEST()97 EXPECT_EQ(baseTimeNs + startBucketNum * bucketSizeNs + 2 * bucketSizeNs, nextPullTimeNs); in TEST()107 processor->informPullAlarmFired(nextPullTimeNs + 1); in TEST()109 nextPullTimeNs); in TEST()111 processor->informPullAlarmFired(nextPullTimeNs + 1); in TEST()112 EXPECT_EQ(baseTimeNs + startBucketNum * bucketSizeNs + 4 * bucketSizeNs, nextPullTimeNs); in TEST()118 processor->informPullAlarmFired(nextPullTimeNs + 3); in TEST()[all …]
88 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST()192 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST()305 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST()
324 int64_t nextPullTimeNs, int64_t intervalNs) { in RegisterReceiver() argument346 receiverInfo.nextPullTimeNs = nextPullTimeNs; in RegisterReceiver()350 if (nextPullTimeNs < mNextPullTimeNs) { in RegisterReceiver()352 mNextPullTimeNs = nextPullTimeNs; in RegisterReceiver()386 if (receiverInfo.nextPullTimeNs <= elapsedTimeNs) { in OnAlarmFired()389 if (receiverInfo.nextPullTimeNs < minNextPullTimeNs) { in OnAlarmFired()390 minNextPullTimeNs = receiverInfo.nextPullTimeNs; in OnAlarmFired()428 (elapsedTimeNs - receiverInfo->nextPullTimeNs) / receiverInfo->intervalNs; in OnAlarmFired()429 receiverInfo->nextPullTimeNs += (numBucketsAhead + 1) * receiverInfo->intervalNs; in OnAlarmFired()430 if (receiverInfo->nextPullTimeNs < minNextPullTimeNs) { in OnAlarmFired()[all …]
65 virtual void RegisterReceiver(int tagId, wp<PullDataReceiver> receiver, int64_t nextPullTimeNs,106 int64_t nextPullTimeNs; member