Searched refs:per_balancer_store (Results 1 – 4 of 4) sorted by relevance
60 for (auto per_balancer_store : *per_balancer_stores) { in PerBalancerStoresContains()61 if (per_balancer_store == original_per_balancer_store) { in PerBalancerStoresContains()352 PerBalancerStore per_balancer_store(kLbId1, kLoadKey1); in TEST_F() local353 EXPECT_FALSE(per_balancer_store.IsSuspended()); in TEST_F()355 per_balancer_store.Suspend(); in TEST_F()356 EXPECT_TRUE(per_balancer_store.IsSuspended()); in TEST_F()357 EXPECT_EQ(0U, per_balancer_store.load_record_map().size()); in TEST_F()360 per_balancer_store.MergeRow(kKey1, v1); in TEST_F()361 EXPECT_EQ(0U, per_balancer_store.load_record_map().size()); in TEST_F()363 per_balancer_store.Resume(); in TEST_F()[all …]
298 for (PerBalancerStore* per_balancer_store : *assigned_stores) { in GenerateLoads()299 GPR_ASSERT(!per_balancer_store->IsSuspended()); in GenerateLoads()300 if (!per_balancer_store->load_record_map().empty()) { in GenerateLoads()301 for (const auto& p : per_balancer_store->load_record_map()) { in GenerateLoads()330 if (per_balancer_store->lb_id() != lb_id) { in GenerateLoads()333 AttachOrphanLoadId(load, *per_balancer_store); in GenerateLoads()336 per_balancer_store->ClearLoadRecordMap(); in GenerateLoads()338 if (per_balancer_store->IsNumCallsInProgressChangedSinceLastReport()) { in GenerateLoads()341 per_balancer_store->GetNumCallsInProgressForReport()); in GenerateLoads()342 if (per_balancer_store->lb_id() != lb_id) { in GenerateLoads()[all …]
270 std::unique_ptr<PerBalancerStore> per_balancer_store( in SetUpForNewLbId() local272 assigned_stores_[lb_id] = {per_balancer_store.get()}; in SetUpForNewLbId()273 per_balancer_stores_[lb_id] = std::move(per_balancer_store); in SetUpForNewLbId()290 PerBalancerStore* per_balancer_store = in MergeRow() local292 if (per_balancer_store != nullptr) { in MergeRow()293 per_balancer_store->MergeRow(key, value); in MergeRow()
211 const PerBalancerStore& per_balancer_store);