Home
last modified time | relevance | path

Searched refs:load_key (Results 1 – 7 of 7) sorted by relevance

/external/grpc-grpc/src/cpp/server/load_reporter/
Dload_data_store.cc181 const grpc::string& load_key) { in ReportStreamCreated() argument
183 SetUpForNewLbId(lb_id, load_key); in ReportStreamCreated()
211 load_key_to_receiving_lb_ids_, it_store_for_gone_lb->second->load_key(), in ReportStreamClosed()
219 auto it = load_key_to_receiving_lb_ids_.find(orphaned_store->load_key()); in ReportStreamClosed()
264 const grpc::string& load_key) { in SetUpForNewLbId() argument
269 load_key_to_receiving_lb_ids_[load_key].insert(lb_id); in SetUpForNewLbId()
271 new PerBalancerStore(lb_id, load_key)); in SetUpForNewLbId()
326 const grpc::string& load_key) { in ReportStreamCreated() argument
327 per_host_stores_[hostname].ReportStreamCreated(lb_id, load_key); in ReportStreamCreated()
Dload_data_store.h200 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()
229 const grpc::string& load_key() const { return load_key_; } in load_key() function
250 const grpc::string& load_key);
270 void SetUpForNewLbId(const grpc::string& lb_id, const grpc::string& load_key);
329 const grpc::string& load_key);
Dload_reporter.cc360 per_balancer_store.load_key()); in AttachOrphanLoadId()
381 const grpc::string& load_key) { in ReportStreamCreated() argument
383 load_data_store_.ReportStreamCreated(hostname, lb_id, load_key); in ReportStreamCreated()
386 this, hostname.c_str(), lb_id.c_str(), load_key.c_str()); in ReportStreamCreated()
Dload_reporter.h153 const grpc::string& load_key);
Dload_reporter_async_service_impl.cc209 load_key_ = initial_request.load_key(); in OnReadDone()
/external/grpc-grpc/src/proto/grpc/lb/v1/
Dload_reporter.proto40 // load reporter client has disconnected. load_key is sent in orphaned load
41 // reports; see Load.load_key.
42 bytes load_key = 2; field
149 // Load_key is the load_key from the initial_request from the originating
151 bytes load_key = 12 [deprecated=true]; field
158 // load_key and balancer_id are included in order to identify orphaned load
178 // The load_key from the initial_request from the originating balancer.
179 bytes load_key = 1; field
182 // distinguishes orphaned load with a same load_key.
/external/grpc-grpc/test/cpp/server/load_reporter/
Dload_data_store_test.cc54 const grpc::string& load_key) { in PerBalancerStoresContains() argument
59 EXPECT_EQ(original_per_balancer_store->load_key(), load_key); in PerBalancerStoresContains()