Searched refs:orphaned_store (Results 1 – 2 of 2) sorted by relevance
192 const std::unique_ptr<PerBalancerStore>& orphaned_store = p.second; in ReportStreamCreated() local194 orphaned_store->Resume(); in ReportStreamCreated()195 AssignOrphanedStore(orphaned_store.get(), lb_id); in ReportStreamCreated()217 for (PerBalancerStore* orphaned_store : orphaned_stores) { in ReportStreamClosed()219 auto it = load_key_to_receiving_lb_ids_.find(orphaned_store->load_key()); in ReportStreamClosed()228 AssignOrphanedStore(orphaned_store, *new_receiver); in ReportStreamClosed()232 orphaned_store->Suspend(); in ReportStreamClosed()251 void PerHostStore::AssignOrphanedStore(PerBalancerStore* orphaned_store, in AssignOrphanedStore() argument255 it->second.insert(orphaned_store); in AssignOrphanedStore()259 this, orphaned_store, orphaned_store->lb_id().c_str(), in AssignOrphanedStore()
272 void AssignOrphanedStore(PerBalancerStore* orphaned_store,