aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/end2end/thread_stress_test.cc
diff options
context:
space:
mode:
authorGravatar Vijay Pai <vpai@google.com>2016-02-04 07:32:29 -0800
committerGravatar Vijay Pai <vpai@google.com>2016-02-04 07:32:29 -0800
commit0a3a766960cdc04dc920acf8c21175930b4e5431 (patch)
tree6e2c91c91f099c5b3c21393e2c53ed2c658b6db6 /test/cpp/end2end/thread_stress_test.cc
parent912fe05ed38f55a69c47d6753cdf5073f9250345 (diff)
Give tsan a chance
Diffstat (limited to 'test/cpp/end2end/thread_stress_test.cc')
-rw-r--r--test/cpp/end2end/thread_stress_test.cc8
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];
}