Lines Matching refs:receiverInfo
192 ReceiverInfo receiverInfo; in RegisterReceiver() local
193 receiverInfo.receiver = receiver; in RegisterReceiver()
204 receiverInfo.intervalNs = roundedIntervalNs; in RegisterReceiver()
205 receiverInfo.nextPullTimeNs = nextPullTimeNs; in RegisterReceiver()
206 receivers.push_back(receiverInfo); in RegisterReceiver()
260 for (ReceiverInfo& receiverInfo : pair.second) { in OnAlarmFired()
261 if (receiverInfo.nextPullTimeNs <= elapsedTimeNs) { in OnAlarmFired()
262 receivers.push_back(&receiverInfo); in OnAlarmFired()
264 if (receiverInfo.nextPullTimeNs < minNextPullTimeNs) { in OnAlarmFired()
265 minNextPullTimeNs = receiverInfo.nextPullTimeNs; in OnAlarmFired()
294 for (const auto& receiverInfo : pullInfo.second) { in OnAlarmFired() local
295 sp<PullDataReceiver> receiverPtr = receiverInfo->receiver.promote(); 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()
303 minNextPullTimeNs = receiverInfo->nextPullTimeNs; in OnAlarmFired()