FazBrowse GitHub Viewer | Trending |
URL:
| Home
Tools: [Download Repo ZIP]   [Original HTTPS Page]

Adjusted timeouts in wait tests for futures to improve CI reliability. · boostorg/thread@c8c283c · GitHub

Repository navigation

Commit c8c283c

Browse files
committed
Adjusted timeouts in wait tests for futures to improve CI reliability.
1 parent d5c457a commit c8c283c

4 files changed

Lines changed: 24 additions & 24 deletions

File tree

‎test/sync/futures/future/wait_for_pass.cpp‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -86,13 +86,13 @@ int main()
8686
boost::thread(func1, boost::move(p)).detach();
8787
#endif
8888
BOOST_TEST(f.valid());
89-
BOOST_TEST_EQ(f.wait_for(ms(250)) , boost::future_status::timeout);
89+
BOOST_TEST_EQ(f.wait_for(ms(100)) , boost::future_status::timeout);
9090
#if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
9191
#else
9292
func1(boost::move(p));
9393
#endif
9494
BOOST_TEST(f.valid());
95-
BOOST_TEST_EQ(f.wait_for(ms(750)) , boost::future_status::ready);
95+
BOOST_TEST_EQ(f.wait_for(ms(2000)) , boost::future_status::ready);
9696
BOOST_TEST(f.valid());
9797
Clock::time_point t0 = Clock::now();
9898
f.wait();
@@ -109,13 +109,13 @@ int main()
109109
boost::thread(func3, boost::move(p)).detach();
110110
#endif
111111
BOOST_TEST(f.valid());
112-
BOOST_TEST_EQ(f.wait_for(ms(250)) , boost::future_status::timeout);
112+
BOOST_TEST_EQ(f.wait_for(ms(100)) , boost::future_status::timeout);
113113
BOOST_TEST(f.valid());
114114
#if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
115115
#else
116116
func3(boost::move(p));
117117
#endif
118-
BOOST_TEST_EQ(f.wait_for(ms(750)) , boost::future_status::ready);
118+
BOOST_TEST_EQ(f.wait_for(ms(2000)) , boost::future_status::ready);
119119
BOOST_TEST(f.valid());
120120
Clock::time_point t0 = Clock::now();
121121
f.wait();
@@ -132,13 +132,13 @@ int main()
132132
boost::thread(func5, boost::move(p)).detach();
133133
#endif
134134
BOOST_TEST(f.valid());
135-
BOOST_TEST_EQ(f.wait_for(ms(250)) , boost::future_status::timeout);
135+
BOOST_TEST_EQ(f.wait_for(ms(100)) , boost::future_status::timeout);
136136
BOOST_TEST(f.valid());
137137
#if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
138138
#else
139139
func5(boost::move(p));
140140
#endif
141-
BOOST_TEST_EQ(f.wait_for(ms(750)) , boost::future_status::ready);
141+
BOOST_TEST_EQ(f.wait_for(ms(2000)) , boost::future_status::ready);
142142
BOOST_TEST(f.valid());
143143
Clock::time_point t0 = Clock::now();
144144
f.wait();

‎test/sync/futures/future/wait_until_pass.cpp‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -87,13 +87,13 @@ int main()
8787
boost::thread(func1, boost::move(p)).detach();
8888
#endif
8989
BOOST_TEST(f.valid());
90-
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(250)) , boost::future_status::timeout);
90+
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(100)) , boost::future_status::timeout);
9191
#if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
9292
#else
9393
func1(boost::move(p));
9494
#endif
9595
BOOST_TEST(f.valid());
96-
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(750)) , boost::future_status::ready);
96+
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(2000)) , boost::future_status::ready);
9797
BOOST_TEST(f.valid());
9898
Clock::time_point t0 = Clock::now();
9999
f.wait();
@@ -110,13 +110,13 @@ int main()
110110
boost::thread(func3, boost::move(p)).detach();
111111
#endif
112112
BOOST_TEST(f.valid());
113-
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(250)) , boost::future_status::timeout);
113+
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(100)) , boost::future_status::timeout);
114114
BOOST_TEST(f.valid());
115115
#if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
116116
#else
117117
func3(boost::move(p));
118118
#endif
119-
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(750)) , boost::future_status::ready);
119+
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(2000)) , boost::future_status::ready);
120120
BOOST_TEST(f.valid());
121121
Clock::time_point t0 = Clock::now();
122122
f.wait();
@@ -133,13 +133,13 @@ int main()
133133
boost::thread(func5, boost::move(p)).detach();
134134
#endif
135135
BOOST_TEST(f.valid());
136-
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(250)) , boost::future_status::timeout);
136+
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(100)) , boost::future_status::timeout);
137137
BOOST_TEST(f.valid());
138138
#if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
139139
#else
140140
func5(boost::move(p));
141141
#endif
142-
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(750)) , boost::future_status::ready);
142+
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(2000)) , boost::future_status::ready);
143143
BOOST_TEST(f.valid());
144144
Clock::time_point t0 = Clock::now();
145145
f.wait();

‎test/sync/futures/shared_future/wait_for_pass.cpp‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -86,13 +86,13 @@ int main()
8686
boost::thread(func1, boost::move(p)).detach();
8787
#endif
8888
BOOST_TEST(f.valid());
89-
BOOST_TEST_EQ(f.wait_for(ms(250)) , boost::future_status::timeout);
89+
BOOST_TEST_EQ(f.wait_for(ms(100)) , boost::future_status::timeout);
9090
#if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
9191
#else
9292
func1(boost::move(p));
9393
#endif
9494
BOOST_TEST(f.valid());
95-
BOOST_TEST_EQ(f.wait_for(ms(750)) , boost::future_status::ready);
95+
BOOST_TEST_EQ(f.wait_for(ms(2000)) , boost::future_status::ready);
9696
BOOST_TEST(f.valid());
9797
Clock::time_point t0 = Clock::now();
9898
f.wait();
@@ -109,13 +109,13 @@ int main()
109109
boost::thread(func3, boost::move(p)).detach();
110110
#endif
111111
BOOST_TEST(f.valid());
112-
BOOST_TEST_EQ(f.wait_for(ms(250)) , boost::future_status::timeout);
112+
BOOST_TEST_EQ(f.wait_for(ms(100)) , boost::future_status::timeout);
113113
BOOST_TEST(f.valid());
114114
#if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
115115
#else
116116
func3(boost::move(p));
117117
#endif
118-
BOOST_TEST_EQ(f.wait_for(ms(750)) , boost::future_status::ready);
118+
BOOST_TEST_EQ(f.wait_for(ms(2000)) , boost::future_status::ready);
119119
BOOST_TEST(f.valid());
120120
Clock::time_point t0 = Clock::now();
121121
f.wait();
@@ -132,13 +132,13 @@ int main()
132132
boost::thread(func5, boost::move(p)).detach();
133133
#endif
134134
BOOST_TEST(f.valid());
135-
BOOST_TEST_EQ(f.wait_for(ms(250)) , boost::future_status::timeout);
135+
BOOST_TEST_EQ(f.wait_for(ms(100)) , boost::future_status::timeout);
136136
BOOST_TEST(f.valid());
137137
#if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
138138
#else
139139
func5(boost::move(p));
140140
#endif
141-
BOOST_TEST_EQ(f.wait_for(ms(750)) , boost::future_status::ready);
141+
BOOST_TEST_EQ(f.wait_for(ms(2000)) , boost::future_status::ready);
142142
BOOST_TEST(f.valid());
143143
Clock::time_point t0 = Clock::now();
144144
f.wait();

‎test/sync/futures/shared_future/wait_until_pass.cpp‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -87,13 +87,13 @@ int main()
8787
boost::thread(func1, boost::move(p)).detach();
8888
#endif
8989
BOOST_TEST(f.valid());
90-
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(250)) , boost::future_status::timeout);
90+
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(100)) , boost::future_status::timeout);
9191
#if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
9292
#else
9393
func1(boost::move(p));
9494
#endif
9595
BOOST_TEST(f.valid());
96-
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(750)) , boost::future_status::ready);
96+
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(2000)) , boost::future_status::ready);
9797
BOOST_TEST(f.valid());
9898
Clock::time_point t0 = Clock::now();
9999
f.wait();
@@ -110,13 +110,13 @@ int main()
110110
boost::thread(func3, boost::move(p)).detach();
111111
#endif
112112
BOOST_TEST(f.valid());
113-
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(250)) , boost::future_status::timeout);
113+
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(100)) , boost::future_status::timeout);
114114
BOOST_TEST(f.valid());
115115
#if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
116116
#else
117117
func3(boost::move(p));
118118
#endif
119-
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(750)) , boost::future_status::ready);
119+
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(2000)) , boost::future_status::ready);
120120
BOOST_TEST(f.valid());
121121
Clock::time_point t0 = Clock::now();
122122
f.wait();
@@ -133,13 +133,13 @@ int main()
133133
boost::thread(func5, boost::move(p)).detach();
134134
#endif
135135
BOOST_TEST(f.valid());
136-
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(250)) , boost::future_status::timeout);
136+
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(100)) , boost::future_status::timeout);
137137
BOOST_TEST(f.valid());
138138
#if defined BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK && defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
139139
#else
140140
func5(boost::move(p));
141141
#endif
142-
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(750)) , boost::future_status::ready);
142+
BOOST_TEST_EQ(f.wait_until(Clock::now() + ms(2000)) , boost::future_status::ready);
143143
BOOST_TEST(f.valid());
144144
Clock::time_point t0 = Clock::now();
145145
f.wait();

0 commit comments

Comments
 (0)

Back | FazBrowse Home | New Git URL