Searched refs:pullInfo (Results 1 – 3 of 3) sorted by relevance
| /aosp12/packages/modules/StatsD/statsd/src/shell/ |
| H A D | ShellSubscriber.cpp | 140 for (PullInfo& pullInfo : mSubscriptionInfo->mPulledInfo) { in pullAndSendHeartbeats()
141 if (pullInfo.mPrevPullElapsedRealtimeMs + pullInfo.mInterval >= nowMillis) { in pullAndSendHeartbeats()
146 getUidsForPullAtom(&uids, pullInfo); in pullAndSendHeartbeats()
149 mPullerMgr->Pull(pullInfo.mPullerMatcher.atom_id(), uids, nowNanos, &data); in pullAndSendHeartbeats()
151 writePulledAtomsLocked(data, pullInfo.mPullerMatcher); in pullAndSendHeartbeats()
153 pullInfo.mPrevPullElapsedRealtimeMs = nowMillis; in pullAndSendHeartbeats()
164 for (PullInfo& pullInfo : mSubscriptionInfo->mPulledInfo) { in pullAndSendHeartbeats()
165 int64_t nextPullTime = pullInfo.mPrevPullElapsedRealtimeMs + pullInfo.mInterval; in pullAndSendHeartbeats()
179 void ShellSubscriber::getUidsForPullAtom(vector<int32_t>* uids, const PullInfo& pullInfo) { in getUidsForPullAtom() argument
180 uids->insert(uids->end(), pullInfo.mPullUids.begin(), pullInfo.mPullUids.end()); in getUidsForPullAtom()
[all …]
|
| H A D | ShellSubscriber.h | 118 void getUidsForPullAtom(vector<int32_t>* uids, const PullInfo& pullInfo);
|
| /aosp12/packages/modules/StatsD/statsd/src/external/ |
| H A D | StatsPullerManager.cpp | 274 for (const auto& pullInfo : needToPull) { in OnAlarmFired() local
276 bool pullSuccess = PullLocked(pullInfo.first->atomTag, pullInfo.first->configKey, in OnAlarmFired()
294 for (const auto& receiverInfo : pullInfo.second) { in OnAlarmFired()
|