aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/qps/qps_worker.cc
diff options
context:
space:
mode:
authorGravatar Vijay Pai <vpai@google.com>2016-01-11 09:54:23 -0800
committerGravatar Vijay Pai <vpai@google.com>2016-01-11 09:54:23 -0800
commitaf2e1cf080037d44a641c69f5b566675bb9876c2 (patch)
tree64d3dd66f9c5d4c9b75eb0dcf3938d853b8cbdeb /test/cpp/qps/qps_worker.cc
parent083dc62cf60f66b40cf320f4d3c4c9d4791e1526 (diff)
Fix bugs and include build files
Diffstat (limited to 'test/cpp/qps/qps_worker.cc')
-rw-r--r--test/cpp/qps/qps_worker.cc4
1 files changed, 3 insertions, 1 deletions
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();
}