Searched refs:mClientSet (Results 1 – 2 of 2) sorted by relevance
38 mClientSet.clear(); in ~ShellSubscriber()50 if (mClientSet.size() >= kMaxSubscriptions) { in startNewSubscription()53 mClientSet.size(), kMaxSubscriptions); in startNewSubscription()65 if (mClientSet.size() >= kMaxSubscriptions) { in startNewSubscription()68 mClientSet.size(), kMaxSubscriptions); in startNewSubscription()80 mClientSet.insert(std::move(client)); in startNewSubscriptionLocked()106 for (auto clientIt = mClientSet.begin(); clientIt != mClientSet.end();) { in pullAndSendHeartbeats()115 clientIt = mClientSet.erase(clientIt); in pullAndSendHeartbeats()119 if (mClientSet.empty()) { in pullAndSendHeartbeats()125 mThreadSleepCV.wait_for(lock, sleepTimeMs * 1ms, [this] { return mClientSet.empty(); }); in pullAndSendHeartbeats()[all …]
105 std::set<unique_ptr<ShellSubscriberClient>> mClientSet; variable