diff options
author | 2017-05-07 20:02:30 -0700 | |
---|---|---|
committer | 2017-05-07 20:02:30 -0700 | |
commit | d868a07d7c666795f3e83bf28f81a45b1814250c (patch) | |
tree | 6d1f301d99d0c31446b5ac3d3e74eb029833669b /test/cpp/qps/qps_worker.cc | |
parent | 7188c9d05a2e67d74bc3db1d18e1e13985c63f97 (diff) | |
parent | c9016893f72c6469b8616f33c8243e4a1cd416fc (diff) |
Merge github.com:grpc/grpc into uberpoll
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(); } |