Searched refs:nextPullTimeNs (Results 1 – 4 of 4) sorted by relevance
93 int64_t& nextPullTimeNs = in TEST() local102 processor->informPullAlarmFired(nextPullTimeNs + 1); in TEST()113 processor->informPullAlarmFired(nextPullTimeNs + 1); in TEST()116 processor->informPullAlarmFired(nextPullTimeNs + 1); in TEST()123 processor->informPullAlarmFired(nextPullTimeNs + 3); in TEST()130 processor->informPullAlarmFired(nextPullTimeNs + 2); in TEST()133 processor->informPullAlarmFired(nextPullTimeNs + 2); in TEST()329 int64_t& nextPullTimeNs = in TEST() local438 int64_t& nextPullTimeNs = in TEST() local554 int64_t& nextPullTimeNs = in TEST() local[all …]
228 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST()332 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST()445 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST()
182 wp<PullDataReceiver> receiver, int64_t nextPullTimeNs, in RegisterReceiver() argument205 receiverInfo.nextPullTimeNs = nextPullTimeNs; in RegisterReceiver()209 if (nextPullTimeNs < mNextPullTimeNs) { in RegisterReceiver()211 mNextPullTimeNs = nextPullTimeNs; in RegisterReceiver()261 if (receiverInfo.nextPullTimeNs <= elapsedTimeNs) { in OnAlarmFired()264 if (receiverInfo.nextPullTimeNs < minNextPullTimeNs) { in OnAlarmFired()265 minNextPullTimeNs = receiverInfo.nextPullTimeNs; in OnAlarmFired()300 (elapsedTimeNs - receiverInfo->nextPullTimeNs) / receiverInfo->intervalNs; in OnAlarmFired()301 receiverInfo->nextPullTimeNs += (numBucketsAhead + 1) * receiverInfo->intervalNs; in OnAlarmFired()302 if (receiverInfo->nextPullTimeNs < minNextPullTimeNs) { in OnAlarmFired()[all …]
73 wp<PullDataReceiver> receiver, int64_t nextPullTimeNs,143 int64_t nextPullTimeNs; member