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()
135     for (auto clientIt = mClientSet.begin(); clientIt != mClientSet.end();) {  in onLogEvent()
141             clientIt = mClientSet.erase(clientIt);  in onLogEvent()
152     for (auto clientIt = mClientSet.begin(); clientIt != mClientSet.end(); ++clientIt) {  in flushSubscription()
162                 clientIt = mClientSet.erase(clientIt);  in flushSubscription()
175     for (auto clientIt = mClientSet.begin(); clientIt != mClientSet.end(); ++clientIt) {  in unsubscribe()
185             clientIt = mClientSet.erase(clientIt);  in unsubscribe()
198     for (const auto& client : mClientSet) {  in updateLogEventFilterLocked()