diff options
| -rw-r--r-- | test/cpp/qps/client_async.cc | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/test/cpp/qps/client_async.cc b/test/cpp/qps/client_async.cc index bd77424578..3d5ff5295e 100644 --- a/test/cpp/qps/client_async.cc +++ b/test/cpp/qps/client_async.cc @@ -143,6 +143,9 @@ class AsyncClient : public Client { std::function<ClientRpcContext*(CompletionQueue*, TestService::Stub*, const SimpleRequest&)> setup_ctx) : Client(config), channel_rpc_lock_(config.client_channels()) { + + SetupLoadTest(config, num_threads_); + for (int i = 0; i < config.async_client_threads(); i++) { cli_cqs_.emplace_back(new CompletionQueue); if (!closed_loop_) { |