Searched refs:nextPullTimeNs (Results 1 – 4 of 4) sorted by relevance
154 int64_t nextPullTimeNs, int64_t intervalNs) { in RegisterReceiver() argument176 receiverInfo.nextPullTimeNs = nextPullTimeNs; in RegisterReceiver()180 if (nextPullTimeNs < mNextPullTimeNs) { in RegisterReceiver()182 mNextPullTimeNs = nextPullTimeNs; in RegisterReceiver()237 if (receiverInfo.nextPullTimeNs <= elapsedTimeNs && receiverPtr != nullptr && in OnAlarmFired()241 if (receiverInfo.nextPullTimeNs <= elapsedTimeNs) { in OnAlarmFired()243 int numBucketsAhead = (elapsedTimeNs - receiverInfo.nextPullTimeNs) / in OnAlarmFired()245 receiverInfo.nextPullTimeNs += in OnAlarmFired()248 minNextPullTimeNs = min(receiverInfo.nextPullTimeNs, minNextPullTimeNs); in OnAlarmFired()284 (elapsedTimeNs - receiverInfo->nextPullTimeNs) / receiverInfo->intervalNs; in OnAlarmFired()[all …]
73 const wp<PullDataReceiver>& receiver, int64_t nextPullTimeNs,144 int64_t nextPullTimeNs; member
94 int64_t& nextPullTimeNs = in TEST() local95 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST()96 EXPECT_EQ(baseTimeNs + startBucketNum * bucketSizeNs + bucketSizeNs, nextPullTimeNs); in TEST()103 processor->informPullAlarmFired(nextPullTimeNs + 1); in TEST()104 EXPECT_EQ(baseTimeNs + startBucketNum * bucketSizeNs + 2 * bucketSizeNs, nextPullTimeNs); in TEST()114 processor->informPullAlarmFired(nextPullTimeNs + 1); in TEST()115 EXPECT_EQ(baseTimeNs + startBucketNum * bucketSizeNs + 3 * bucketSizeNs, nextPullTimeNs); in TEST()117 processor->informPullAlarmFired(nextPullTimeNs + 1); in TEST()118 EXPECT_EQ(baseTimeNs + startBucketNum * bucketSizeNs + 4 * bucketSizeNs, nextPullTimeNs); in TEST()124 processor->informPullAlarmFired(nextPullTimeNs + 3); in TEST()[all …]
228 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST()350 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST()489 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST()