Searched refs:pullInfo (Results 1 – 2 of 2) sorted by relevance
/packages/modules/StatsD/statsd/src/shell/ |
D | ShellSubscriberClient.cpp | 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() [all …]
|
/packages/modules/StatsD/statsd/src/external/ |
D | StatsPullerManager.cpp | 256 for (const auto& pullInfo : needToPull) { in OnAlarmFired() local 259 PullLocked(pullInfo.first->atomTag, pullInfo.first->configKey, elapsedTimeNs, &data) in OnAlarmFired() 278 for (const auto& receiverInfo : pullInfo.second) { in OnAlarmFired()
|