diff --git a/test/cpp/qps/client.h b/test/cpp/qps/client.h index b015f2287e8..f028fc7c0f7 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 3d5ff5295e1..e91a7a191c1 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);