diff --git a/test/cpp/qps/driver.cc b/test/cpp/qps/driver.cc index 370a3a834a32415a9aa3b9be09df3f0236c4db04..5fd0f21d1c9ba9c7bb5e32972f411ef2fe1f1c87 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 f33b13b5b24f1dd01425accf65ae190986899c7b..47b51fe3dd7e45ae1d9b542f37d08f01050f37bd 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 f14a5c95adedd94b7fb5c4101dc0d5b1b79d5d61..624c182100e9c59dad85c24e1a9b7fdd80c9f327 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_;