From 2ed337aab35e227d329e435ec97d48660d6f1458 Mon Sep 17 00:00:00 2001 From: Vijay Pai <vpai@google.com> Date: Tue, 2 Feb 2016 09:43:35 -0800 Subject: [PATCH] clang-format --- test/cpp/qps/driver.cc | 2 +- test/cpp/qps/qps_worker.cc | 10 +++++----- test/cpp/qps/qps_worker.h | 1 + 3 files changed, 7 insertions(+), 6 deletions(-) diff --git a/test/cpp/qps/driver.cc b/test/cpp/qps/driver.cc index 370a3a834a..5fd0f21d1c 100644 --- a/test/cpp/qps/driver.cc +++ b/test/cpp/qps/driver.cc @@ -289,7 +289,7 @@ void RunQuit() { auto workers = get_hosts("QPS_WORKERS"); for (size_t i = 0; i < workers.size(); i++) { auto stub = WorkerService::NewStub( - CreateChannel(workers[i], InsecureChannelCredentials())); + CreateChannel(workers[i], InsecureChannelCredentials())); Void dummy; grpc::ClientContext ctx; GPR_ASSERT(stub->QuitWorker(&ctx, dummy, &dummy).ok()); diff --git a/test/cpp/qps/qps_worker.cc b/test/cpp/qps/qps_worker.cc index f33b13b5b2..47b51fe3dd 100644 --- a/test/cpp/qps/qps_worker.cc +++ b/test/cpp/qps/qps_worker.cc @@ -107,8 +107,8 @@ static std::unique_ptr<Server> CreateServer(const ServerConfig& config) { class WorkerServiceImpl GRPC_FINAL : public WorkerService::Service { public: - WorkerServiceImpl(int server_port, QpsWorker *worker) - : acquired_(false), server_port_(server_port), worker_(worker) {} + WorkerServiceImpl(int server_port, QpsWorker* worker) + : acquired_(false), server_port_(server_port), worker_(worker) {} Status RunClient(ServerContext* ctx, ServerReaderWriter<ClientStatus, ClientArgs>* stream) @@ -138,7 +138,7 @@ class WorkerServiceImpl GRPC_FINAL : public WorkerService::Service { return ret; } - Status QuitWorker(ServerContext *ctx, const Void*, Void*) GRPC_OVERRIDE { + Status QuitWorker(ServerContext* ctx, const Void*, Void*) GRPC_OVERRIDE { InstanceGuard g(this); if (!g.Acquired()) { return Status(StatusCode::RESOURCE_EXHAUSTED, ""); @@ -147,7 +147,7 @@ class WorkerServiceImpl GRPC_FINAL : public WorkerService::Service { worker_->MarkDone(); return Status::OK; } - + private: // Protect against multiple clients using this worker at once. class InstanceGuard { @@ -258,7 +258,7 @@ class WorkerServiceImpl GRPC_FINAL : public WorkerService::Service { std::mutex mu_; bool acquired_; int server_port_; - QpsWorker *worker_; + QpsWorker* worker_; }; QpsWorker::QpsWorker(int driver_port, int server_port) { diff --git a/test/cpp/qps/qps_worker.h b/test/cpp/qps/qps_worker.h index f14a5c95ad..624c182100 100644 --- a/test/cpp/qps/qps_worker.h +++ b/test/cpp/qps/qps_worker.h @@ -53,6 +53,7 @@ class QpsWorker { bool Done() const; void MarkDone(); + private: std::unique_ptr<WorkerServiceImpl> impl_; std::unique_ptr<Server> server_; -- GitLab