diff options
author | 2015-03-30 10:44:05 -0700 | |
---|---|---|
committer | 2015-03-30 10:44:05 -0700 | |
commit | fbf8a37c5eafcb1f9b27d9bdaac73040785dd6b6 (patch) | |
tree | 10211221689f95049b3156d6c153297c23de88cb /test/cpp/qps/worker.cc | |
parent | 1205f6f534412f3e2deb88b86f66ae58b07aab8a (diff) | |
parent | 675de61e4ba46f6910eab9051ea77ee73cdf8c28 (diff) |
Merge branch 'master' into cancel
Diffstat (limited to 'test/cpp/qps/worker.cc')
-rw-r--r-- | test/cpp/qps/worker.cc | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/test/cpp/qps/worker.cc b/test/cpp/qps/worker.cc index fdcd9d5069..dddc4c9850 100644 --- a/test/cpp/qps/worker.cc +++ b/test/cpp/qps/worker.cc @@ -77,9 +77,12 @@ namespace testing { std::unique_ptr<Client> CreateClient(const ClientConfig& config) { switch (config.client_type()) { case ClientType::SYNCHRONOUS_CLIENT: - return CreateSynchronousClient(config); + return (config.rpc_type() == RpcType::UNARY) ? + CreateSynchronousUnaryClient(config) : + CreateSynchronousStreamingClient(config); case ClientType::ASYNC_CLIENT: - return CreateAsyncClient(config); + return (config.rpc_type() == RpcType::UNARY) ? + CreateAsyncUnaryClient(config) : CreateAsyncStreamingClient(config); } abort(); } |