| /external/grpc-grpc/src/cpp/server/load_reporter/ |
| load_data_store.h | 72 : lb_id_(std::move(lb_id)),
81 return "[lb_id_=" + lb_id_ + ", lb_tag_=" + lb_tag_ +
87 return lb_id_ == other.lb_id_ && lb_tag_ == other.lb_tag_ &&
95 const grpc::string& lb_id() const { return lb_id_; }
108 hash_combine(&h, k.lb_id_);
117 grpc::string lb_id_; member in class:grpc::load_reporter::LoadRecordKey
201 : lb_id_(std::move(lb_id)), load_key_(std::move(load_key)) {}
221 return "[PerBalancerStore lb_id_=" + lb_id_ + " load_key_=" + load_key_
233 grpc::string lb_id_; member in class:grpc::load_reporter::PerBalancerStore
[all...] |
| load_reporter_async_service_impl.cc | 180 lb_id_ = load_reporter_->GenerateLbId();
182 "[LRS %p] Call request delivered (lb_id_: %s, handler: %p). "
184 service_, lb_id_.c_str(), this);
194 "(lb_id_: %s, handler: %p, done_notified: %d, is_cancelled: %d).",
195 service_, lb_id_.c_str(), this, static_cast<int>(done_notified_),
210 load_reporter_->ReportStreamCreated(load_balanced_hostname_, lb_id_,
219 "balanced host: %s, interval: %lu ms, lb_id_: %s, handler: %p)...",
221 lb_id_.c_str(), this);
241 "[LRS %p] Another request received (lb_id_: %s, handler: %p).",
242 service_, lb_id_.c_str(), this)
[all...] |
| load_reporter_async_service_impl.h | 137 grpc::string lb_id_; member in class:grpc::load_reporter::LoadReporterAsyncServiceImpl::ReportLoadHandler
|
| load_data_store.cc | 93 lb_id_ = kInvalidLbId;
96 lb_id_ = client_ip_and_token.substr(cur_pos, kLbIdLength);
304 "[LoadDataStore %p] Start tracking unknown balancer (lb_id_: %s).",
311 "[LoadDataStore %p] Stop tracking unknown balancer (lb_id_: %s).",
|
