Searched refs:ShellSubscriberClient (Results 1 – 6 of 6) sorted by relevance
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::ShellSubscriberClient104 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()[all …]
43 class ShellSubscriberClient {56 static std::unique_ptr<ShellSubscriberClient> create(int in, int out, int64_t timeoutSec,61 static std::unique_ptr<ShellSubscriberClient> create(67 explicit ShellSubscriberClient(int out,
81 return ShellSubscriberClient::getMaxSizeKb(); in getMaxSizeKb()89 bool startNewSubscriptionLocked(unique_ptr<ShellSubscriberClient> client);105 std::set<unique_ptr<ShellSubscriberClient>> mClientSet;
55 return startNewSubscriptionLocked(ShellSubscriberClient::create( in startNewSubscription()70 return startNewSubscriptionLocked(ShellSubscriberClient::create( in startNewSubscription()74 bool ShellSubscriber::startNewSubscriptionLocked(unique_ptr<ShellSubscriberClient> client) { in startNewSubscriptionLocked()
287 shellSubscriberClient = std::move(ShellSubscriberClient::create( in SetUp()291 unique_ptr<ShellSubscriberClient> shellSubscriberClient;618 EXPECT_THAT(sleepTimeMs, Eq(ShellSubscriberClient::kMinCallbackSleepIntervalMs)); in TEST_F()
79 "src/shell/ShellSubscriberClient.cpp",