aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/qps/worker.cc
diff options
context:
space:
mode:
authorGravatar Yang Gao <yangg@google.com>2015-03-30 10:44:05 -0700
committerGravatar Yang Gao <yangg@google.com>2015-03-30 10:44:05 -0700
commitfbf8a37c5eafcb1f9b27d9bdaac73040785dd6b6 (patch)
tree10211221689f95049b3156d6c153297c23de88cb /test/cpp/qps/worker.cc
parent1205f6f534412f3e2deb88b86f66ae58b07aab8a (diff)
parent675de61e4ba46f6910eab9051ea77ee73cdf8c28 (diff)
Merge branch 'master' into cancel
Diffstat (limited to 'test/cpp/qps/worker.cc')
-rw-r--r--test/cpp/qps/worker.cc7
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();
}