Searched refs:lb_id_ (Results 1 – 4 of 4) sorted by relevance
/external/grpc-grpc/src/cpp/server/load_reporter/ |
D | load_data_store.h | 72 : lb_id_(std::move(lb_id)), in LoadRecordKey() 81 return "[lb_id_=" + lb_id_ + ", lb_tag_=" + lb_tag_ + in ToString() 87 return lb_id_ == other.lb_id_ && lb_tag_ == other.lb_tag_ && 95 const grpc::string& lb_id() const { return lb_id_; } in lb_id() 108 hash_combine(&h, k.lb_id_); in operator() 117 grpc::string lb_id_; 201 : lb_id_(std::move(lb_id)), load_key_(std::move(load_key)) {} in PerBalancerStore() 221 return "[PerBalancerStore lb_id_=" + lb_id_ + " load_key_=" + load_key_ + in ToString() 228 const grpc::string& lb_id() const { return lb_id_; } in lb_id() 233 grpc::string lb_id_;
|
D | load_reporter_async_service_impl.cc | 180 lb_id_ = load_reporter_->GenerateLbId(); in OnRequestDelivered() 184 service_, lb_id_.c_str(), this); in OnRequestDelivered() 195 service_, lb_id_.c_str(), this, static_cast<int>(done_notified_), in OnReadDone() 210 load_reporter_->ReportStreamCreated(load_balanced_hostname_, lb_id_, in OnReadDone() 221 lb_id_.c_str(), this); in OnReadDone() 242 service_, lb_id_.c_str(), this); in OnReadDone() 274 service_, lb_id_.c_str(), this); in ScheduleNextReport() 284 auto loads = load_reporter_->GenerateLoads(load_balanced_hostname_, lb_id_); in SendReport() 290 initial_response->set_load_balancer_id(lb_id_); in SendReport() 311 service_, lb_id_.c_str(), this, response.load().size()); in SendReport() [all …]
|
D | load_data_store.cc | 93 lb_id_ = kInvalidLbId; in LoadRecordKey() 96 lb_id_ = client_ip_and_token.substr(cur_pos, kLbIdLength); in LoadRecordKey()
|
D | load_reporter_async_service_impl.h | 137 grpc::string lb_id_; variable
|