aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/qps
diff options
context:
space:
mode:
authorGravatar Vijay Pai <vpai@google.com>2015-06-03 11:01:25 -0700
committerGravatar Vijay Pai <vpai@google.com>2015-06-03 11:01:25 -0700
commit8559485c23e4c452c0f8dcc5329c902cea12ec80 (patch)
treeeb998fb5164e225170f2cdf8e5490f97e48cd265 /test/cpp/qps
parent7abc4e720c1c3bd0434d106ce6dbfb8681bdc2fd (diff)
Bug fix
Diffstat (limited to 'test/cpp/qps')
-rw-r--r--test/cpp/qps/client.h2
-rw-r--r--test/cpp/qps/client_async.cc2
2 files changed, 2 insertions, 2 deletions
diff --git a/test/cpp/qps/client.h b/test/cpp/qps/client.h
index b015f2287e..f028fc7c0f 100644
--- a/test/cpp/qps/client.h
+++ b/test/cpp/qps/client.h
@@ -124,7 +124,7 @@ class Client {
void EndThreads() { threads_.clear(); }
virtual bool ThreadFunc(Histogram* histogram, size_t thread_idx) = 0;
-
+
void SetupLoadTest(const ClientConfig& config, size_t num_threads) {
// Set up the load distribution based on the number of threads
if (config.load_type() == CLOSED_LOOP) {
diff --git a/test/cpp/qps/client_async.cc b/test/cpp/qps/client_async.cc
index 3d5ff5295e..e91a7a191c 100644
--- a/test/cpp/qps/client_async.cc
+++ b/test/cpp/qps/client_async.cc
@@ -144,7 +144,7 @@ class AsyncClient : public Client {
const SimpleRequest&)> setup_ctx) :
Client(config), channel_rpc_lock_(config.client_channels()) {
- SetupLoadTest(config, num_threads_);
+ SetupLoadTest(config, config.async_client_threads());
for (int i = 0; i < config.async_client_threads(); i++) {
cli_cqs_.emplace_back(new CompletionQueue);