From af2e1cf080037d44a641c69f5b566675bb9876c2 Mon Sep 17 00:00:00 2001
From: Vijay Pai <vpai@google.com>
Date: Mon, 11 Jan 2016 09:54:23 -0800
Subject: Fix bugs and include build files

---
 test/cpp/qps/qps_worker.cc | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

(limited to 'test/cpp/qps/qps_worker.cc')

diff --git a/test/cpp/qps/qps_worker.cc b/test/cpp/qps/qps_worker.cc
index dc59eab7ef..ea5bb4cd3c 100644
--- a/test/cpp/qps/qps_worker.cc
+++ b/test/cpp/qps/qps_worker.cc
@@ -69,7 +69,9 @@ static std::unique_ptr<Client> CreateClient(const ClientConfig& config) {
     case ClientType::ASYNC_CLIENT:
       return (config.rpc_type() == RpcType::UNARY)
                  ? CreateAsyncUnaryClient(config)
-                 : CreateAsyncStreamingClient(config);
+                 : (config.payload_config().has_bytebuf_params()
+                       ? CreateGenericAsyncStreamingClient(config)
+                       : CreateAsyncStreamingClient(config));
     default:
       abort();
   }
-- 
cgit v1.2.3


From 78268212bae4e745606108beeeff317af393e033 Mon Sep 17 00:00:00 2001
From: Vijay Pai <vpai@google.com>
Date: Mon, 11 Jan 2016 09:55:02 -0800
Subject: clang-format

---
 test/cpp/qps/client.h      |  3 ++-
 test/cpp/qps/qps_worker.cc | 16 ++++++++--------
 2 files changed, 10 insertions(+), 9 deletions(-)

(limited to 'test/cpp/qps/qps_worker.cc')

diff --git a/test/cpp/qps/client.h b/test/cpp/qps/client.h
index e4659d1a28..4a915a7801 100644
--- a/test/cpp/qps/client.h
+++ b/test/cpp/qps/client.h
@@ -373,7 +373,8 @@ std::unique_ptr<Client> CreateSynchronousStreamingClient(
     const ClientConfig& args);
 std::unique_ptr<Client> CreateAsyncUnaryClient(const ClientConfig& args);
 std::unique_ptr<Client> CreateAsyncStreamingClient(const ClientConfig& args);
-std::unique_ptr<Client> CreateGenericAsyncStreamingClient(const ClientConfig& args);
+std::unique_ptr<Client> CreateGenericAsyncStreamingClient(
+    const ClientConfig& args);
 
 }  // namespace testing
 }  // namespace grpc
diff --git a/test/cpp/qps/qps_worker.cc b/test/cpp/qps/qps_worker.cc
index ea5bb4cd3c..765dea8d8d 100644
--- a/test/cpp/qps/qps_worker.cc
+++ b/test/cpp/qps/qps_worker.cc
@@ -36,20 +36,20 @@
 #include <cassert>
 #include <memory>
 #include <mutex>
+#include <sstream>
 #include <string>
 #include <thread>
 #include <vector>
-#include <sstream>
 
+#include <grpc++/client_context.h>
+#include <grpc++/security/server_credentials.h>
+#include <grpc++/server.h>
+#include <grpc++/server_builder.h>
 #include <grpc/grpc.h>
 #include <grpc/support/alloc.h>
 #include <grpc/support/histogram.h>
-#include <grpc/support/log.h>
 #include <grpc/support/host_port.h>
-#include <grpc++/client_context.h>
-#include <grpc++/server.h>
-#include <grpc++/server_builder.h>
-#include <grpc++/security/server_credentials.h>
+#include <grpc/support/log.h>
 
 #include "test/core/util/grpc_profiler.h"
 #include "test/cpp/qps/client.h"
@@ -70,8 +70,8 @@ static std::unique_ptr<Client> CreateClient(const ClientConfig& config) {
       return (config.rpc_type() == RpcType::UNARY)
                  ? CreateAsyncUnaryClient(config)
                  : (config.payload_config().has_bytebuf_params()
-                       ? CreateGenericAsyncStreamingClient(config)
-                       : CreateAsyncStreamingClient(config));
+                        ? CreateGenericAsyncStreamingClient(config)
+                        : CreateAsyncStreamingClient(config));
     default:
       abort();
   }
-- 
cgit v1.2.3