diff options
| author |  Muxi Yan <mxyan@google.com> | 2017-10-06 18:47:09 -0700 |
|---|---|---|
| committer | Muxi Yan <mxyan@google.com> | 2017-10-06 18:47:09 -0700 |
| commit | 03fc857a6f3ad1ee0a6f46cd19b5c96e56c6fd3b (patch) | |
| tree | 38e03428954c3abdf2c88cafa9ffbd205789976b /test/cpp/interop | |
| parent | 63602748415fb836afd7a9685fbe5e85bf5ebfed (diff) | |
| parent | 03bd5daf5cd36373152cb6b06a5f259db1331e87 (diff) | |
Merge remote-tracking branch 'upstream/master' into fix-stream-compression-config-interface
Diffstat (limited to 'test/cpp/interop')
| -rw-r--r-- | test/cpp/interop/stress_test.cc | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/test/cpp/interop/stress_test.cc b/test/cpp/interop/stress_test.cc index 9cc5a8168b..c6d3600be8 100644 --- a/test/cpp/interop/stress_test.cc +++ b/test/cpp/interop/stress_test.cc @@ -257,6 +257,7 @@ int main(int argc, char** argv) { gpr_log(GPR_INFO, "Starting test(s).."); std::vector<std::thread> test_threads; + std::vector<std::unique_ptr<StressTestInteropClient>> clients; // Create and start the test threads. // Note that: @@ -282,9 +283,9 @@ int main(int argc, char** argv) { // Create stub(s) for each channel for (int stub_idx = 0; stub_idx < FLAGS_num_stubs_per_channel; stub_idx++) { - StressTestInteropClient* client = new StressTestInteropClient( + clients.emplace_back(new StressTestInteropClient( ++thread_idx, *it, channel, test_selector, FLAGS_test_duration_secs, - FLAGS_sleep_duration_ms, FLAGS_do_not_abort_on_transient_failures); + FLAGS_sleep_duration_ms, FLAGS_do_not_abort_on_transient_failures)); bool is_already_created = false; // QpsGauge name @@ -293,7 +294,7 @@ int main(int argc, char** argv) { server_idx, channel_idx, stub_idx); test_threads.emplace_back(std::thread( - &StressTestInteropClient::MainLoop, client, + &StressTestInteropClient::MainLoop, clients.back().get(), metrics_service.CreateQpsGauge(buffer, &is_already_created))); // The QpsGauge should not have been already created |