Home
last modified time | relevance | path

Searched refs:assigned_stores_ (Results 1 – 2 of 2) sorted by relevance

/third_party/grpc/src/cpp/server/load_reporter/
Dload_data_store.cc189 if (assigned_stores_.size() == 1) { in ReportStreamCreated()
214 UnorderedMapOfSetExtract(assigned_stores_, lb_id); in ReportStreamClosed()
223 } else if (!assigned_stores_.empty()) { in ReportStreamClosed()
225 new_receiver = &(RandomElement(assigned_stores_)->first); in ReportStreamClosed()
246 auto it = assigned_stores_.find(lb_id); in GetAssignedStores()
247 if (it == assigned_stores_.end()) return nullptr; in GetAssignedStores()
253 auto it = assigned_stores_.find(new_receiver); in AssignOrphanedStore()
254 GPR_ASSERT(it != assigned_stores_.end()); in AssignOrphanedStore()
268 GPR_ASSERT(assigned_stores_.find(lb_id) == assigned_stores_.end()); in SetUpForNewLbId()
272 assigned_stores_[lb_id] = {per_balancer_store.get()}; in SetUpForNewLbId()
Dload_data_store.h288 std::unordered_map<std::string, std::set<PerBalancerStore*>> assigned_stores_; variable