diff options
author | 2017-12-04 09:58:44 -0800 | |
---|---|---|
committer | 2017-12-04 09:58:44 -0800 | |
commit | f230ffd476fb095f0143a1b673320d93dfab8f6a (patch) | |
tree | 45cc63af0204a9355346af0a6735cf27aa2185c8 /test | |
parent | 083b9be1a214f2ff67581f186684313c8d6b75fe (diff) |
clang-format
Diffstat (limited to 'test')
-rw-r--r-- | test/cpp/qps/client_sync.cc | 23 |
1 files changed, 9 insertions, 14 deletions
diff --git a/test/cpp/qps/client_sync.cc b/test/cpp/qps/client_sync.cc index 20aa5f5435..69ba866233 100644 --- a/test/cpp/qps/client_sync.cc +++ b/test/cpp/qps/client_sync.cc @@ -196,9 +196,9 @@ class SynchronousStreamingClient : public SynchronousClient { for (size_t i = 0; i < num_threads_; i++) { cleanup_threads.emplace_back([this, i] { std::lock_guard<std::mutex> l(stream_mu_[i]); - shutdown_[i].val = true; + shutdown_[i].val = true; if (stream_[i]) { - CleanStream(i); + CleanStream(i); } }); } @@ -206,6 +206,7 @@ class SynchronousStreamingClient : public SynchronousClient { th.join(); } } + private: void DestroyMultithreading() override final { CleanupAllStreams(); @@ -219,9 +220,8 @@ class SynchronousStreamingPingPongClient final public: SynchronousStreamingPingPongClient(const ClientConfig& config) : SynchronousStreamingClient(config) {} - ~SynchronousStreamingPingPongClient() { - CleanupAllStreams(); - } + ~SynchronousStreamingPingPongClient() { CleanupAllStreams(); } + private: bool InitThreadFuncImpl(size_t thread_idx) override { auto* stub = channels_[thread_idx % channels_.size()].get_stub(); @@ -280,9 +280,7 @@ class SynchronousStreamingFromClientClient final public: SynchronousStreamingFromClientClient(const ClientConfig& config) : SynchronousStreamingClient(config), last_issue_(num_threads_) {} - ~SynchronousStreamingFromClientClient() { - CleanupAllStreams(); - } + ~SynchronousStreamingFromClientClient() { CleanupAllStreams(); } private: std::vector<double> last_issue_; @@ -338,9 +336,7 @@ class SynchronousStreamingFromServerClient final public: SynchronousStreamingFromServerClient(const ClientConfig& config) : SynchronousStreamingClient(config), last_recv_(num_threads_) {} - ~SynchronousStreamingFromServerClient() { - CleanupAllStreams(); - } + ~SynchronousStreamingFromServerClient() { CleanupAllStreams(); } private: std::vector<double> last_recv_; @@ -391,9 +387,8 @@ class SynchronousStreamingBothWaysClient final public: SynchronousStreamingBothWaysClient(const ClientConfig& config) : SynchronousStreamingClient(config) {} - ~SynchronousStreamingBothWaysClient() { - CleanupAllStreams(); - } + ~SynchronousStreamingBothWaysClient() { CleanupAllStreams(); } + private: bool InitThreadFuncImpl(size_t thread_idx) override { auto* stub = channels_[thread_idx % channels_.size()].get_stub(); |