Searched refs:watchers_ (Results 1 – 8 of 8) sorted by relevance
38 const auto watcher_it = watchers_.find(watcher_ptr); in SetKeyMaterials()39 GPR_ASSERT(watcher_it != watchers_.end()); in SetKeyMaterials()63 const auto watcher_it = watchers_.find(watcher_ptr); in SetKeyMaterials()64 GPR_ASSERT(watcher_it != watchers_.end()); in SetKeyMaterials()111 const auto watcher_it = watchers_.find(watcher_ptr); in SetErrorForCert()112 GPR_ASSERT(watcher_it != watchers_.end()); in SetErrorForCert()132 const auto watcher_it = watchers_.find(watcher_ptr); in SetErrorForCert()133 GPR_ASSERT(watcher_it != watchers_.end()); in SetErrorForCert()157 for (const auto& watcher : watchers_) { in SetError()189 const auto watcher_it = watchers_.find(watcher_ptr); in WatchTlsCertificates()[all …]
204 std::map<TlsCertificatesWatcherInterface*, WatcherInfo> watchers_; member
106 for (const auto& p : watchers_) { in ~ConnectivityStateTracker()137 watchers_.insert(std::make_pair(watcher.get(), std::move(watcher))); in AddWatcher()147 watchers_.erase(watcher); in RemoveWatcher()162 for (const auto& p : watchers_) { in SetState()173 if (state == GRPC_CHANNEL_SHUTDOWN) watchers_.clear(); in SetState()
140 watchers_; variable
55 auto& watcher_state = watchers_[watcher_ptr]; in StartWatch()63 auto it = watchers_.find(watcher); in CancelWatch()64 if (it != watchers_.end()) { in CancelWatch()69 watchers_.erase(it); in CancelWatch()247 watchers_; member in grpc_core::__anonc82c1b380111::XdsServerConfigFetcher
164 std::map<std::string, WatcherState> watchers_; member in grpc_core::__anona4cab1b20111::CdsLb293 for (auto& watcher : watchers_) { in ShutdownLocked()301 watchers_.clear(); in ShutdownLocked()339 for (auto& watcher : watchers_) { in UpdateLocked()347 watchers_.clear(); in UpdateLocked()350 watchers_[config_->cluster()].watcher = watcher.get(); in UpdateLocked()367 auto& state = watchers_[name]; in GenerateDiscoveryMechanismForCluster()433 auto it = watchers_.find(name); in OnClusterChanged()434 if (it == watchers_.end()) return; in OnClusterChanged()528 for (auto it = watchers_.begin(); it != watchers_.end();) { in OnClusterChanged()[all …]
312 void Clear() { watchers_.clear(); } in Clear()314 bool empty() const { return watchers_.empty(); } in empty()321 watchers_;
402 watchers_.insert(std::make_pair(watcher.get(), std::move(watcher))); in AddWatcherLocked()407 watchers_.erase(watcher); in RemoveWatcherLocked()413 for (const auto& p : watchers_) { in NotifyLocked()