From 8559485c23e4c452c0f8dcc5329c902cea12ec80 Mon Sep 17 00:00:00 2001 From: Vijay Pai Date: Wed, 3 Jun 2015 11:01:25 -0700 Subject: Bug fix --- test/cpp/qps/client.h | 2 +- test/cpp/qps/client_async.cc | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) (limited to 'test/cpp/qps') 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); -- cgit v1.2.3