diff options
author | 2015-11-03 15:55:43 -0800 | |
---|---|---|
committer | 2015-11-03 15:55:43 -0800 | |
commit | 4d0f2f9dab16162d41970e80c48d851f34b831bb (patch) | |
tree | 53b605b7f609eb641b30993995142134e93750b5 /test/cpp/util/metrics_server.cc | |
parent | b5e98c5c69fe6ce9c069a7192385cd530c35f7a8 (diff) |
Fix typo in my previous commit. %s/guage/gauge/g
Diffstat (limited to 'test/cpp/util/metrics_server.cc')
-rw-r--r-- | test/cpp/util/metrics_server.cc | 40 |
1 files changed, 20 insertions, 20 deletions
diff --git a/test/cpp/util/metrics_server.cc b/test/cpp/util/metrics_server.cc index 42a8911609..eac29f3093 100644 --- a/test/cpp/util/metrics_server.cc +++ b/test/cpp/util/metrics_server.cc @@ -45,37 +45,37 @@ namespace testing { using std::vector; -Guage::Guage(long initial_val) : val_(initial_val) {} +Gauge::Gauge(long initial_val) : val_(initial_val) {} -void Guage::Set(long new_val) { +void Gauge::Set(long new_val) { val_.store(new_val, std::memory_order_relaxed); } -long Guage::Get() { return val_.load(std::memory_order_relaxed); } +long Gauge::Get() { return val_.load(std::memory_order_relaxed); } -grpc::Status MetricsServiceImpl::GetAllGuages( +grpc::Status MetricsServiceImpl::GetAllGauges( ServerContext* context, const EmptyMessage* request, - ServerWriter<GuageResponse>* writer) { - gpr_log(GPR_INFO, "GetAllGuages called"); + ServerWriter<GaugeResponse>* writer) { + gpr_log(GPR_INFO, "GetAllGauges called"); std::lock_guard<std::mutex> lock(mu_); - for (auto it = guages_.begin(); it != guages_.end(); it++) { - GuageResponse resp; - resp.set_name(it->first); // Guage name - resp.set_value(it->second->Get()); // Guage value + for (auto it = gauges_.begin(); it != gauges_.end(); it++) { + GaugeResponse resp; + resp.set_name(it->first); // Gauge name + resp.set_value(it->second->Get()); // Gauge value writer->Write(resp); } return Status::OK; } -grpc::Status MetricsServiceImpl::GetGuage(ServerContext* context, - const GuageRequest* request, - GuageResponse* response) { +grpc::Status MetricsServiceImpl::GetGauge(ServerContext* context, + const GaugeRequest* request, + GaugeResponse* response) { std::lock_guard<std::mutex> lock(mu_); - auto it = guages_.find(request->name()); - if (it != guages_.end()) { + auto it = gauges_.find(request->name()); + if (it != gauges_.end()) { response->set_name(it->first); response->set_value(it->second->Get()); } @@ -83,15 +83,15 @@ grpc::Status MetricsServiceImpl::GetGuage(ServerContext* context, return Status::OK; } -std::shared_ptr<Guage> MetricsServiceImpl::CreateGuage(string name, +std::shared_ptr<Gauge> MetricsServiceImpl::CreateGauge(string name, bool& already_present) { std::lock_guard<std::mutex> lock(mu_); - std::shared_ptr<Guage> guage(new Guage(0)); - auto p = guages_.emplace(name, guage); + std::shared_ptr<Gauge> gauge(new Gauge(0)); + auto p = gauges_.emplace(name, gauge); - // p.first is an iterator pointing to <name, shared_ptr<Guage>> pair. p.second - // is a boolean indicating if the Guage is already present in the map + // p.first is an iterator pointing to <name, shared_ptr<Gauge>> pair. p.second + // is a boolean indicating if the Gauge is already present in the map already_present = !p.second; return p.first->second; } |