Lines Matching refs:ShellSubscriberClient
43 vector<ShellSubscriberClient::PullInfo> pullInfo;
61 vector<ShellSubscriberClient::PullInfo> pullInfo; in readConfig()
85 ShellSubscriberClient::PullInfo::PullInfo(const SimpleAtomMatcher& matcher, int64_t startTimeMs, in PullInfo()
96 ShellSubscriberClient::ShellSubscriberClient( in ShellSubscriberClient() function in android::os::statsd::ShellSubscriberClient
113 unique_ptr<ShellSubscriberClient> ShellSubscriberClient::create( in create()
143 auto result = unique_ptr<ShellSubscriberClient>(new ShellSubscriberClient( in create()
152 unique_ptr<ShellSubscriberClient> ShellSubscriberClient::create( in create()
170 ShellSubscriberClient::kMinCallbackPullIntervalMs); in create()
179 auto result = unique_ptr<ShellSubscriberClient>(new ShellSubscriberClient( in create()
188 bool ShellSubscriberClient::writeEventToProtoIfMatched(const LogEvent& event, in writeEventToProtoIfMatched()
222 void ShellSubscriberClient::onLogEvent(const LogEvent& event) { in onLogEvent()
231 void ShellSubscriberClient::flushProtoIfNeeded() { in flushProtoIfNeeded()
240 int64_t ShellSubscriberClient::pullIfNeeded(int64_t nowSecs, int64_t nowMillis, int64_t nowNanos) { in pullIfNeeded()
272 int64_t ShellSubscriberClient::pullAndSendHeartbeatsIfNeeded(int64_t nowSecs, int64_t nowMillis, in pullAndSendHeartbeatsIfNeeded()
315 void ShellSubscriberClient::writePulledAtomsLocked(const vector<shared_ptr<LogEvent>>& data, in writePulledAtomsLocked()
332 void ShellSubscriberClient::attemptWriteToPipeLocked() { in attemptWriteToPipeLocked()
347 void ShellSubscriberClient::getUidsForPullAtom(vector<int32_t>* uids, const PullInfo& pullInfo) { in getUidsForPullAtom()
357 void ShellSubscriberClient::clearCache() { in clearCache()
362 void ShellSubscriberClient::triggerFdFlush() { in triggerFdFlush()
367 void ShellSubscriberClient::triggerCallback(StatsSubscriptionCallbackReason reason) { in triggerCallback()
383 void ShellSubscriberClient::flush() { in flush()
387 void ShellSubscriberClient::onUnsubscribe() { in onUnsubscribe()
394 void ShellSubscriberClient::addAllAtomIds(LogEventFilter::AtomIdSet& allAtomIds) const { in addAllAtomIds()