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()
327 int64_t nextPullTimeNs, int64_t intervalNs) { in RegisterReceiver() argument349 receiverInfo.nextPullTimeNs = nextPullTimeNs; in RegisterReceiver()353 if (nextPullTimeNs < mNextPullTimeNs) { in RegisterReceiver()355 mNextPullTimeNs = nextPullTimeNs; in RegisterReceiver()389 if (receiverInfo.nextPullTimeNs <= elapsedTimeNs) { in OnAlarmFired()392 if (receiverInfo.nextPullTimeNs < minNextPullTimeNs) { in OnAlarmFired()393 minNextPullTimeNs = receiverInfo.nextPullTimeNs; in OnAlarmFired()431 (elapsedTimeNs - receiverInfo->nextPullTimeNs) / receiverInfo->intervalNs; in OnAlarmFired()432 receiverInfo->nextPullTimeNs += (numBucketsAhead + 1) * receiverInfo->intervalNs; in OnAlarmFired()433 if (receiverInfo->nextPullTimeNs < minNextPullTimeNs) { in OnAlarmFired()[all …]
63 virtual void RegisterReceiver(int tagId, wp<PullDataReceiver> receiver, int64_t nextPullTimeNs,104 int64_t nextPullTimeNs; member