diff options
author | Vijay Pai <vpai@google.com> | 2017-03-23 16:19:00 -0700 |
---|---|---|
committer | Vijay Pai <vpai@google.com> | 2017-05-02 09:26:12 -0700 |
commit | eea8cf0fe3a836b78e9ba122a01f6f1552ad8402 (patch) | |
tree | 5e417bb6bc0a3c872281cb6ba6f81b8a829ace99 /test/cpp/qps/qps_worker.cc | |
parent | 6626a86923aaebae86aeeba151c99ed3089d02fc (diff) |
Add QPS tests for one-sided streaming
Diffstat (limited to 'test/cpp/qps/qps_worker.cc')
-rw-r--r-- | test/cpp/qps/qps_worker.cc | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/test/cpp/qps/qps_worker.cc b/test/cpp/qps/qps_worker.cc index d437920e68..92408974bd 100644 --- a/test/cpp/qps/qps_worker.cc +++ b/test/cpp/qps/qps_worker.cc @@ -68,15 +68,11 @@ static std::unique_ptr<Client> CreateClient(const ClientConfig& config) { switch (config.client_type()) { case ClientType::SYNC_CLIENT: - return (config.rpc_type() == RpcType::UNARY) - ? CreateSynchronousUnaryClient(config) - : CreateSynchronousStreamingClient(config); + return CreateSynchronousClient(config); case ClientType::ASYNC_CLIENT: - return (config.rpc_type() == RpcType::UNARY) - ? CreateAsyncUnaryClient(config) - : (config.payload_config().has_bytebuf_params() - ? CreateGenericAsyncStreamingClient(config) - : CreateAsyncStreamingClient(config)); + return config.payload_config().has_bytebuf_params() + ? CreateGenericAsyncStreamingClient(config) + : CreateAsyncClient(config); default: abort(); } |