Searched refs:ShellSubscriber (Results 1 – 6 of 6) sorted by relevance
34 void ShellSubscriber::startNewSubscription(int in, int out, int timeoutSec) { in startNewSubscription()55 void ShellSubscriber::spawnHelperThread(int myToken) { in spawnHelperThread()60 void ShellSubscriber::waitForSubscriptionToEndLocked(shared_ptr<SubscriptionInfo> myInfo, in waitForSubscriptionToEndLocked()76 int ShellSubscriber::claimToken() { in claimToken()83 bool ShellSubscriber::readConfig(shared_ptr<SubscriptionInfo> subscriptionInfo) { in readConfig()127 void ShellSubscriber::pullAndSendHeartbeats(int myToken) { in pullAndSendHeartbeats()179 void ShellSubscriber::getUidsForPullAtom(vector<int32_t>* uids, const PullInfo& pullInfo) { in getUidsForPullAtom()189 void ShellSubscriber::writePulledAtomsLocked(const vector<std::shared_ptr<LogEvent>>& data, in writePulledAtomsLocked()206 void ShellSubscriber::onLogEvent(const LogEvent& event) { in onLogEvent()225 void ShellSubscriber::attemptWriteToPipeLocked(size_t dataSize) { in attemptWriteToPipeLocked()
60 class ShellSubscriber : public virtual RefBase {62 ShellSubscriber(sp<UidMap> uidMap, sp<StatsPullerManager> pullerMgr) in ShellSubscriber() function
60 sp<ShellSubscriber> shellClient = new ShellSubscriber(uidMap, pullerManager); in runShellTest()
376 sp<ShellSubscriber> mShellSubscriber;
354 mShellSubscriber = new ShellSubscriber(mUidMap, mPullerManager); in handleShellCommand()
71 "src/shell/ShellSubscriber.cpp",