Searched refs:pullInfo (Results 1 – 2 of 2) sorted by relevance
136 for (auto& pullInfo : mPulledInfo) { in startPull() local137 if (pullInfo.mPrevPullElapsedRealtimeMs + pullInfo.mInterval < nowMillis) { in startPull()138 VLOG("pull atom %d now", pullInfo.mPullerMatcher.atom_id()); in startPull()141 mPullerMgr->Pull(pullInfo.mPullerMatcher.atom_id(), &data); in startPull()144 writeToOutputLocked(data, pullInfo.mPullerMatcher); in startPull()146 pullInfo.mPrevPullElapsedRealtimeMs = nowMillis; in startPull()
403 for (const auto& pullInfo : needToPull) { in OnAlarmFired() local405 bool pullSuccess = Pull(pullInfo.first, &data); in OnAlarmFired()408 pullInfo.first, getElapsedRealtimeNs() - elapsedTimeNs); in OnAlarmFired()425 for (const auto& receiverInfo : pullInfo.second) { in OnAlarmFired()