Searched refs:ShellSubscriberClient (Results 1 – 6 of 6) sorted by relevance
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::ShellSubscriberClient113 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()[all …]
81 return ShellSubscriberClient::getMaxSizeKb(); in getMaxSizeKb()89 bool startNewSubscriptionLocked(unique_ptr<ShellSubscriberClient> client);105 std::set<unique_ptr<ShellSubscriberClient>> mClientSet;
43 class ShellSubscriberClient {56 static std::unique_ptr<ShellSubscriberClient> create(int in, int out, int64_t timeoutSec,61 static std::unique_ptr<ShellSubscriberClient> create(
57 return startNewSubscriptionLocked(ShellSubscriberClient::create( in startNewSubscription()72 return startNewSubscriptionLocked(ShellSubscriberClient::create( in startNewSubscription()76 bool ShellSubscriber::startNewSubscriptionLocked(unique_ptr<ShellSubscriberClient> client) { in startNewSubscriptionLocked()
318 shellSubscriberClient = ShellSubscriberClient::create( in SetUp()322 unique_ptr<ShellSubscriberClient> shellSubscriberClient;722 EXPECT_THAT(sleepTimeMs, Eq(ShellSubscriberClient::kMinCallbackSleepIntervalMs)); in TEST_F()
113 "src/shell/ShellSubscriberClient.cpp",