From 36ff3f00e2c05d16338cd251d3f90a90fcaf4597 Mon Sep 17 00:00:00 2001 From: Vijay Pai Date: Mon, 4 May 2015 14:40:21 -0700 Subject: [PATCH] clang-format --- test/cpp/qps/client_sync.cc | 37 ++++++++++++++++++++----------------- 1 file changed, 20 insertions(+), 17 deletions(-) diff --git a/test/cpp/qps/client_sync.cc b/test/cpp/qps/client_sync.cc index be3d73844fd..565b8dcc0ba 100644 --- a/test/cpp/qps/client_sync.cc +++ b/test/cpp/qps/client_sync.cc @@ -66,11 +66,11 @@ class SynchronousClient : public Client { public: SynchronousClient(const ClientConfig& config) : Client(config) { num_threads_ = - config.outstanding_rpcs_per_channel() * config.client_channels(); + config.outstanding_rpcs_per_channel() * config.client_channels(); responses_.resize(num_threads_); } - virtual ~SynchronousClient() {}; + virtual ~SynchronousClient(){}; protected: size_t num_threads_; @@ -79,10 +79,12 @@ class SynchronousClient : public Client { class SynchronousUnaryClient GRPC_FINAL : public SynchronousClient { public: - SynchronousUnaryClient(const ClientConfig& config): - SynchronousClient(config) {StartThreads(num_threads_);} - ~SynchronousUnaryClient() {EndThreads();} - + SynchronousUnaryClient(const ClientConfig& config) + : SynchronousClient(config) { + StartThreads(num_threads_); + } + ~SynchronousUnaryClient() { EndThreads(); } + bool ThreadFunc(Histogram* histogram, size_t thread_idx) GRPC_OVERRIDE { auto* stub = channels_[thread_idx % channels_.size()].get_stub(); double start = Timer::Now(); @@ -96,9 +98,9 @@ class SynchronousUnaryClient GRPC_FINAL : public SynchronousClient { class SynchronousStreamingClient GRPC_FINAL : public SynchronousClient { public: - SynchronousStreamingClient(const ClientConfig& config): - SynchronousClient(config), context_(num_threads_) { - for (size_t thread_idx=0;thread_idxStreamingCall(&context_[thread_idx]); } @@ -121,18 +123,19 @@ class SynchronousStreamingClient GRPC_FINAL : public SynchronousClient { } return false; } - private: - std::vector context_; - std::unique_ptr> stream_; + + private: + std::vector context_; + std::unique_ptr> + stream_; }; -std::unique_ptr -CreateSynchronousUnaryClient(const ClientConfig& config) { +std::unique_ptr CreateSynchronousUnaryClient( + const ClientConfig& config) { return std::unique_ptr(new SynchronousUnaryClient(config)); } -std::unique_ptr -CreateSynchronousStreamingClient(const ClientConfig& config) { +std::unique_ptr CreateSynchronousStreamingClient( + const ClientConfig& config) { return std::unique_ptr(new SynchronousStreamingClient(config)); }