diff options
| author |  Vijay Pai <vpai@google.com> | 2016-02-02 09:43:35 -0800 |
|---|---|---|
| committer | Vijay Pai <vpai@google.com> | 2016-02-02 09:43:35 -0800 |
| commit | 2ed337aab35e227d329e435ec97d48660d6f1458 (patch) | |
| tree | cc2a8126170e8c8e66c28bdecd0864b2fa72bbb8 /test/cpp/qps/qps_worker.cc | |
| parent | 21e5d2b2f10bc6d175caf7ad44d729517528a78a (diff) | |
clang-format
Diffstat (limited to 'test/cpp/qps/qps_worker.cc')
| -rw-r--r-- | test/cpp/qps/qps_worker.cc | 10 |
1 files changed, 5 insertions, 5 deletions
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) { |