Lines Matching refs:pullInfo
42 vector<ShellSubscriberClient::PullInfo> pullInfo; member
59 vector<ShellSubscriberClient::PullInfo> pullInfo; in readConfig() local
73 result.pullInfo.emplace_back(pulled.matcher(), startTimeMs, pullIntervalMs, packages, uids); in readConfig()
141 readConfigResult->pullInfo, timeoutSec, startTimeSec, uidMap, pullerMgr); in create()
170 readConfigResult->pullInfo.size()); in create()
172 id, /*out=*/-1, callback, readConfigResult->pushedMatchers, readConfigResult->pullInfo, in create()
223 for (PullInfo& pullInfo : mPulledInfo) { in pullIfNeeded()
224 if (pullInfo.mPrevPullElapsedRealtimeMs + pullInfo.mIntervalMs <= nowMillis) { in pullIfNeeded()
226 getUidsForPullAtom(&uids, pullInfo); in pullIfNeeded()
229 mPullerMgr->Pull(pullInfo.mPullerMatcher.atom_id(), uids, nowNanos, &data); in pullIfNeeded()
231 pullInfo.mPullerMatcher.atom_id()); in pullIfNeeded()
234 pullInfo.mPullerMatcher.atom_id()); in pullIfNeeded()
237 writePulledAtomsLocked(data, pullInfo.mPullerMatcher); in pullIfNeeded()
238 pullInfo.mPrevPullElapsedRealtimeMs = nowMillis; in pullIfNeeded()
242 const int64_t nextPullTimeMs = pullInfo.mPrevPullElapsedRealtimeMs + pullInfo.mIntervalMs; in pullIfNeeded()
328 void ShellSubscriberClient::getUidsForPullAtom(vector<int32_t>* uids, const PullInfo& pullInfo) { in getUidsForPullAtom() argument
329 uids->insert(uids->end(), pullInfo.mPullUids.begin(), pullInfo.mPullUids.end()); in getUidsForPullAtom()
331 for (const string& pkg : pullInfo.mPullPackages) { in getUidsForPullAtom()