Home
last modified time | relevance | path

Searched refs:lb_id (Results 1 – 6 of 6) sorted by relevance

/external/grpc-grpc/src/cpp/server/load_reporter/
Dload_data_store.cc180 void PerHostStore::ReportStreamCreated(const grpc::string& lb_id, in ReportStreamCreated() argument
182 GPR_ASSERT(lb_id != kInvalidLbId); in ReportStreamCreated()
183 SetUpForNewLbId(lb_id, load_key); in ReportStreamCreated()
193 if (other_lb_id != lb_id) { in ReportStreamCreated()
195 AssignOrphanedStore(orphaned_store.get(), lb_id); in ReportStreamCreated()
206 void PerHostStore::ReportStreamClosed(const grpc::string& lb_id) { in ReportStreamClosed() argument
207 auto it_store_for_gone_lb = per_balancer_stores_.find(lb_id); in ReportStreamClosed()
212 lb_id)); in ReportStreamClosed()
214 UnorderedMapOfSetExtract(assigned_stores_, lb_id); in ReportStreamClosed()
238 const grpc::string& lb_id) const { in FindPerBalancerStore()
[all …]
Dload_data_store.h70 LoadRecordKey(grpc::string lb_id, grpc::string lb_tag, grpc::string user_id, in LoadRecordKey() argument
72 : lb_id_(std::move(lb_id)), in LoadRecordKey()
95 const grpc::string& lb_id() const { return lb_id_; } in lb_id() function
200 PerBalancerStore(grpc::string lb_id, grpc::string load_key) in PerBalancerStore() argument
201 : lb_id_(std::move(lb_id)), load_key_(std::move(load_key)) {} in PerBalancerStore()
228 const grpc::string& lb_id() const { return lb_id_; } in lb_id() function
249 void ReportStreamCreated(const grpc::string& lb_id,
257 void ReportStreamClosed(const grpc::string& lb_id);
260 PerBalancerStore* FindPerBalancerStore(const grpc::string& lb_id) const;
265 const grpc::string& lb_id) const;
[all …]
Dload_reporter.cc224 int64_t lb_id = next_lb_id_++; in GenerateLbId() local
226 GPR_ASSERT(lb_id >= 0); in GenerateLbId()
229 snprintf(buf, sizeof(buf), "%08lx", lb_id); in GenerateLbId()
292 const grpc::string& lb_id) { in GenerateLoads() argument
294 auto assigned_stores = load_data_store_.GetAssignedStores(hostname, lb_id); in GenerateLoads()
330 if (per_balancer_store->lb_id() != lb_id) { in GenerateLoads()
342 if (per_balancer_store->lb_id() != lb_id) { in GenerateLoads()
354 if (per_balancer_store.lb_id() == kInvalidLbId) { in AttachOrphanLoadId()
362 per_balancer_store.lb_id()); in AttachOrphanLoadId()
380 const grpc::string& lb_id, in ReportStreamCreated() argument
[all …]
Dload_reporter.h142 const grpc::string& hostname, const grpc::string& lb_id);
152 const grpc::string& lb_id,
158 const grpc::string& lb_id);
/external/grpc-grpc/test/cpp/server/load_reporter/
Dload_data_store_test.cc53 const grpc::string& hostname, const grpc::string& lb_id, in PerBalancerStoresContains() argument
56 load_data_store.FindPerBalancerStore(hostname, lb_id); in PerBalancerStoresContains()
58 EXPECT_EQ(original_per_balancer_store->lb_id(), lb_id); in PerBalancerStoresContains()
158 for (const auto& lb_id : active_lb_ids) { in TEST_F() local
161 load_data_store.GetAssignedStores(kHostname1, lb_id), kHostname1, in TEST_F()
163 assigned_lb_id = lb_id; in TEST_F()
172 for (const auto& lb_id : active_lb_ids) { in TEST_F() local
173 if (lb_id != assigned_lb_id) { in TEST_F()
174 lb_id_to_close = lb_id; in TEST_F()
190 for (const auto& lb_id : active_lb_ids) { in TEST_F() local
[all …]
/external/grpc-grpc/test/cpp/end2end/
Dserver_load_reporting_end2end_test.cc93 void ClientMakeEchoCalls(const grpc::string& lb_id, in ClientMakeEchoCalls() argument
98 grpc::string lb_token = lb_id + lb_tag; in ClientMakeEchoCalls()
142 const grpc::string& lb_id = response.initial_response().load_balancer_id(); in TEST_F() local
143 gpr_log(GPR_INFO, "Initial response received (lb_id: %s).", lb_id.c_str()); in TEST_F()
144 ClientMakeEchoCalls(lb_id, "LB_TAG", kOkMessage, 1); in TEST_F()