pull/1948/head
Vijay Pai 10 years ago
parent 7abc4e720c
commit 8559485c23
  1. 2
      test/cpp/qps/client.h
  2. 2
      test/cpp/qps/client_async.cc

@ -124,7 +124,7 @@ class Client {
void EndThreads() { threads_.clear(); } void EndThreads() { threads_.clear(); }
virtual bool ThreadFunc(Histogram* histogram, size_t thread_idx) = 0; virtual bool ThreadFunc(Histogram* histogram, size_t thread_idx) = 0;
void SetupLoadTest(const ClientConfig& config, size_t num_threads) { void SetupLoadTest(const ClientConfig& config, size_t num_threads) {
// Set up the load distribution based on the number of threads // Set up the load distribution based on the number of threads
if (config.load_type() == CLOSED_LOOP) { if (config.load_type() == CLOSED_LOOP) {

@ -144,7 +144,7 @@ class AsyncClient : public Client {
const SimpleRequest&)> setup_ctx) : const SimpleRequest&)> setup_ctx) :
Client(config), channel_rpc_lock_(config.client_channels()) { 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++) { for (int i = 0; i < config.async_client_threads(); i++) {
cli_cqs_.emplace_back(new CompletionQueue); cli_cqs_.emplace_back(new CompletionQueue);

Loading…
Cancel
Save