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()
150                 VLOG("Pulled %zu atoms with id %d", data.size(), pullInfo.mPullerMatcher.atom_id());  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()
182     for (const string& pkg : pullInfo.mPullPackages) {  in getUidsForPullAtom()