Searched refs:mClientSet (Results 1 – 2 of 2) sorted by relevance
36 mClientSet.clear(); in ~ShellSubscriber()48 if (mClientSet.size() >= kMaxSubscriptions) { in startNewSubscription()51 mClientSet.size(), kMaxSubscriptions); in startNewSubscription()63 if (mClientSet.size() >= kMaxSubscriptions) { in startNewSubscription()66 mClientSet.size(), kMaxSubscriptions); in startNewSubscription()78 mClientSet.insert(std::move(client)); in startNewSubscriptionLocked()103 for (auto clientIt = mClientSet.begin(); clientIt != mClientSet.end();) { in pullAndSendHeartbeats()111 clientIt = mClientSet.erase(clientIt); in pullAndSendHeartbeats()115 if (mClientSet.empty()) { in pullAndSendHeartbeats()121 mThreadSleepCV.wait_for(lock, sleepTimeMs * 1ms, [this] { return mClientSet.empty(); }); in pullAndSendHeartbeats()[all …]
105 std::set<unique_ptr<ShellSubscriberClient>> mClientSet; variable