From 0a3a766960cdc04dc920acf8c21175930b4e5431 Mon Sep 17 00:00:00 2001 From: Vijay Pai Date: Thu, 4 Feb 2016 07:32:29 -0800 Subject: Give tsan a chance --- test/cpp/end2end/thread_stress_test.cc | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/test/cpp/end2end/thread_stress_test.cc b/test/cpp/end2end/thread_stress_test.cc index 64e17cf44f..4c7caa9b87 100644 --- a/test/cpp/end2end/thread_stress_test.cc +++ b/test/cpp/end2end/thread_stress_test.cc @@ -315,22 +315,22 @@ class AsyncClientEnd2endTest : public ::testing::Test { TEST_F(AsyncClientEnd2endTest, ThreadStress) { common_.ResetStub(); std::vector send_threads, completion_threads; - for (int i = 0; i < kNumThreads; ++i) { + for (int i = 0; i < kNumThreads / 2; ++i) { completion_threads.push_back(new std::thread( &AsyncClientEnd2endTest_ThreadStress_Test::AsyncCompleteRpc, this)); } - for (int i = 0; i < kNumThreads; ++i) { + for (int i = 0; i < kNumThreads / 2; ++i) { send_threads.push_back( new std::thread(&AsyncClientEnd2endTest_ThreadStress_Test::AsyncSendRpc, this, kNumRpcs)); } - for (int i = 0; i < kNumThreads; ++i) { + for (int i = 0; i < kNumThreads / 2; ++i) { send_threads[i]->join(); delete send_threads[i]; } Wait(); - for (int i = 0; i < kNumThreads; ++i) { + for (int i = 0; i < kNumThreads / 2; ++i) { completion_threads[i]->join(); delete completion_threads[i]; } -- cgit v1.2.3