diff options
author | Vijay Pai <vpai@google.com> | 2016-02-04 07:32:29 -0800 |
---|---|---|
committer | Vijay Pai <vpai@google.com> | 2016-02-04 07:32:29 -0800 |
commit | 0a3a766960cdc04dc920acf8c21175930b4e5431 (patch) | |
tree | 6e2c91c91f099c5b3c21393e2c53ed2c658b6db6 | |
parent | 912fe05ed38f55a69c47d6753cdf5073f9250345 (diff) |
Give tsan a chance
-rw-r--r-- | test/cpp/end2end/thread_stress_test.cc | 8 |
1 files 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<std::thread*> 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]; } |