Method ParallelQuery

euler/client/rpc_manager_test.cc:31–55

  }

  void ParallelQuery(int num_threads,
                     int num_times_per_replica, int num_replicas,
                     std::vector<std::atomic_int> *counters) {
    EXPECT_EQ(0, num_replicas * num_times_per_replica % num_threads);
    int num_times = num_replicas * num_times_per_replica / num_threads;
    std::vector<std::thread> threads;
    for (int i = 0; i < num_threads; ++i) {
      threads.emplace_back(
        [num_times, counters, this] {
          std::vector<int> local_counters(counters->size());
          for (int i = 0; i < num_times; ++i) {
            const std::string &host_port =
                rpc_manager_.GetChannel()->host_port();
            ++local_counters[std::stoi(host_port)];
          }
          for (size_t i = 0; i < counters->size(); ++i) {
            (*counters)[i] += local_counters[i];
          }
        });
    }

    for (auto &thread : threads) {
      thread.join();
    }
  }

  testing::MockRpcManager rpc_manager_;
  std::shared_ptr<ServerRegister> regs_;