Lines Matching refs:ShellSubscriberClient
38 vector<ShellSubscriberClient::PullInfo> pullInfo;
55 vector<ShellSubscriberClient::PullInfo> pullInfo; in readConfig()
77 ShellSubscriberClient::PullInfo::PullInfo(const SimpleAtomMatcher& matcher, int64_t startTimeMs, in PullInfo()
88 ShellSubscriberClient::ShellSubscriberClient( in ShellSubscriberClient() function in android::os::statsd::ShellSubscriberClient
104 unique_ptr<ShellSubscriberClient> ShellSubscriberClient::create( in create()
134 return make_unique<ShellSubscriberClient>( in create()
139 unique_ptr<ShellSubscriberClient> ShellSubscriberClient::create( in create()
157 ShellSubscriberClient::kMinCallbackPullIntervalMs); in create()
162 return make_unique<ShellSubscriberClient>( in create()
167 bool ShellSubscriberClient::writeEventToProtoIfMatched(const LogEvent& event, in writeEventToProtoIfMatched()
192 void ShellSubscriberClient::onLogEvent(const LogEvent& event) { in onLogEvent()
201 void ShellSubscriberClient::flushProtoIfNeeded() { in flushProtoIfNeeded()
210 int64_t ShellSubscriberClient::pullIfNeeded(int64_t nowSecs, int64_t nowMillis, int64_t nowNanos) { in pullIfNeeded()
238 int64_t ShellSubscriberClient::pullAndSendHeartbeatsIfNeeded(int64_t nowSecs, int64_t nowMillis, in pullAndSendHeartbeatsIfNeeded()
281 void ShellSubscriberClient::writePulledAtomsLocked(const vector<shared_ptr<LogEvent>>& data, in writePulledAtomsLocked()
298 void ShellSubscriberClient::attemptWriteToPipeLocked() { in attemptWriteToPipeLocked()
313 void ShellSubscriberClient::getUidsForPullAtom(vector<int32_t>* uids, const PullInfo& pullInfo) { in getUidsForPullAtom()
323 void ShellSubscriberClient::clearCache() { in clearCache()
328 void ShellSubscriberClient::triggerFdFlush() { in triggerFdFlush()
333 void ShellSubscriberClient::triggerCallback(StatsSubscriptionCallbackReason reason) { in triggerCallback()
348 void ShellSubscriberClient::flush() { in flush()
352 void ShellSubscriberClient::onUnsubscribe() { in onUnsubscribe()
356 void ShellSubscriberClient::addAllAtomIds(LogEventFilter::AtomIdSet& allAtomIds) const { in addAllAtomIds()