diff options
author | 2016-01-11 09:54:23 -0800 | |
---|---|---|
committer | 2016-01-11 09:54:23 -0800 | |
commit | af2e1cf080037d44a641c69f5b566675bb9876c2 (patch) | |
tree | 64d3dd66f9c5d4c9b75eb0dcf3938d853b8cbdeb /test/cpp/qps/qps_worker.cc | |
parent | 083dc62cf60f66b40cf320f4d3c4c9d4791e1526 (diff) |
Fix bugs and include build files
Diffstat (limited to 'test/cpp/qps/qps_worker.cc')
-rw-r--r-- | test/cpp/qps/qps_worker.cc | 4 |
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(); } |