Home
last modified time | relevance | path

Searched refs:PerBalancerStore (Results 1 – 5 of 5) sorted by relevance

/external/grpc-grpc/src/cpp/server/load_reporter/
Dload_data_store.cc141 void PerBalancerStore::MergeRow(const LoadRecordKey& key, in MergeRow()
163 void PerBalancerStore::Suspend() { in Suspend()
169 void PerBalancerStore::Resume() { in Resume()
174 uint64_t PerBalancerStore::GetNumCallsInProgressForReport() { in GetNumCallsInProgressForReport()
192 const std::unique_ptr<PerBalancerStore>& orphaned_store = p.second; in ReportStreamCreated()
213 std::set<PerBalancerStore*> orphaned_stores = in ReportStreamClosed()
217 for (PerBalancerStore* orphaned_store : orphaned_stores) { in ReportStreamClosed()
237 PerBalancerStore* PerHostStore::FindPerBalancerStore( in FindPerBalancerStore()
244 const std::set<PerBalancerStore*>* PerHostStore::GetAssignedStores( in GetAssignedStores()
251 void PerHostStore::AssignOrphanedStore(PerBalancerStore* orphaned_store, in AssignOrphanedStore()
[all …]
Dload_data_store.h195 class PerBalancerStore {
200 PerBalancerStore(grpc::string lb_id, grpc::string load_key) in PerBalancerStore() function
260 PerBalancerStore* FindPerBalancerStore(const grpc::string& lb_id) const;
264 const std::set<PerBalancerStore*>* GetAssignedStores(
272 void AssignOrphanedStore(PerBalancerStore* orphaned_store,
281 std::unordered_map<grpc::string, std::unique_ptr<PerBalancerStore>>
289 std::unordered_map<grpc::string, std::set<PerBalancerStore*>>
305 PerBalancerStore* FindPerBalancerStore(const grpc::string& hostname,
310 const std::set<PerBalancerStore*>* GetAssignedStores(const string& hostname,
Dload_reporter.h211 const PerBalancerStore& per_balancer_store);
Dload_reporter.cc298 for (PerBalancerStore* per_balancer_store : *assigned_stores) { in GenerateLoads()
353 ::grpc::lb::v1::Load* load, const PerBalancerStore& per_balancer_store) { in AttachOrphanLoadId()
/external/grpc-grpc/test/cpp/server/load_reporter/
Dload_data_store_test.cc39 using ::grpc::load_reporter::PerBalancerStore;
52 const std::set<PerBalancerStore*>* per_balancer_stores, in PerBalancerStoresContains()
352 PerBalancerStore per_balancer_store(kLbId1, kLoadKey1); in TEST_F()
394 PerBalancerStore per_balancer_store(kLbId1, kLoadKey1); in TEST_F()