aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/qps
diff options
context:
space:
mode:
authorGravatar Vijay Pai <vpai@google.com>2017-12-04 09:58:44 -0800
committerGravatar Vijay Pai <vpai@google.com>2017-12-04 09:58:44 -0800
commitf230ffd476fb095f0143a1b673320d93dfab8f6a (patch)
tree45cc63af0204a9355346af0a6735cf27aa2185c8 /test/cpp/qps
parent083b9be1a214f2ff67581f186684313c8d6b75fe (diff)
clang-format
Diffstat (limited to 'test/cpp/qps')
-rw-r--r--test/cpp/qps/client_sync.cc23
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();