diff options
author | Sree Kuchibhotla <sreek@google.com> | 2015-11-03 15:55:43 -0800 |
---|---|---|
committer | Sree Kuchibhotla <sreek@google.com> | 2015-11-03 15:55:43 -0800 |
commit | 4d0f2f9dab16162d41970e80c48d851f34b831bb (patch) | |
tree | 53b605b7f609eb641b30993995142134e93750b5 /test/cpp/util | |
parent | b5e98c5c69fe6ce9c069a7192385cd530c35f7a8 (diff) |
Fix typo in my previous commit. %s/guage/gauge/g
Diffstat (limited to 'test/cpp/util')
-rw-r--r-- | test/cpp/util/metrics_server.cc | 40 | ||||
-rw-r--r-- | test/cpp/util/metrics_server.h | 28 |
2 files changed, 34 insertions, 34 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; } diff --git a/test/cpp/util/metrics_server.h b/test/cpp/util/metrics_server.h index c33d40e370..19c3a0c32e 100644 --- a/test/cpp/util/metrics_server.h +++ b/test/cpp/util/metrics_server.h @@ -43,16 +43,16 @@ /* * This implements a Metrics server defined in test/proto/metrics.proto. Any - * test service can use this to export Metrics (TODO (sreek): Only Guages for + * test service can use this to export Metrics (TODO (sreek): Only Gauges for * now). * * Example: * MetricsServiceImpl metricsImpl; * .. - * // Create Guage(s). Note: Guages can be created even after calling + * // Create Gauge(s). Note: Gauges can be created even after calling * // 'StartServer'. - * Guage guage1 = metricsImpl.CreateGuage("foo",is_present); - * // guage1 can now be used anywhere in the program to set values. + * Gauge gauge1 = metricsImpl.CreateGauge("foo",is_present); + * // gauge1 can now be used anywhere in the program to set values. * ... * // Create the metrics server * std::unique_ptr<grpc::Server> server = metricsImpl.StartServer(port); @@ -64,9 +64,9 @@ namespace testing { using std::map; using std::vector; -class Guage { +class Gauge { public: - Guage(long initial_val); + Gauge(long initial_val); void Set(long new_val); long Get(); @@ -76,22 +76,22 @@ class Guage { class MetricsServiceImpl GRPC_FINAL : public MetricsService::Service { public: - grpc::Status GetAllGuages(ServerContext* context, const EmptyMessage* request, - ServerWriter<GuageResponse>* writer) GRPC_OVERRIDE; + grpc::Status GetAllGauges(ServerContext* context, const EmptyMessage* request, + ServerWriter<GaugeResponse>* writer) GRPC_OVERRIDE; - grpc::Status GetGuage(ServerContext* context, const GuageRequest* request, - GuageResponse* response) GRPC_OVERRIDE; + grpc::Status GetGauge(ServerContext* context, const GaugeRequest* request, + GaugeResponse* response) GRPC_OVERRIDE; - // Create a Guage with name 'name'. is_present is set to true if the Guage + // Create a Gauge with name 'name'. is_present is set to true if the Gauge // is already present in the map. - // NOTE: CreateGuage can be called anytime (i.e before or after calling + // NOTE: CreateGauge can be called anytime (i.e before or after calling // StartServer). - std::shared_ptr<Guage> CreateGuage(string name, bool& is_present); + std::shared_ptr<Gauge> CreateGauge(string name, bool& is_present); std::unique_ptr<grpc::Server> StartServer(int port); private: - std::map<string, std::shared_ptr<Guage>> guages_; + std::map<string, std::shared_ptr<Gauge>> gauges_; std::mutex mu_; }; |