diff options
| author |  Vijay Pai <vpai@google.com> | 2016-01-13 13:29:41 -0800 |
|---|---|---|
| committer | Vijay Pai <vpai@google.com> | 2016-01-13 13:29:41 -0800 |
| commit | b9a8f1ba396becc94b09e4e123ea6445444ac09a (patch) | |
| tree | ca9ecd0c4b4520c8383285b95b35769cebee66b0 /test/cpp/qps/qps_worker.cc | |
| parent | 3448c27275aced9d591b70358d130f3059499b73 (diff) | |
| parent | 16a7dee6141785092ee2aae4a11d2e9f590a1847 (diff) | |
Merge branch 'master' into corelimit2
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 f7864224c1..1dbf1d0e53 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(); } |