diff options
author | Richard Oudkerk <shibturn@gmail.com> | 2012-06-18 13:11:10 (GMT) |
---|---|---|
committer | Richard Oudkerk <shibturn@gmail.com> | 2012-06-18 13:11:10 (GMT) |
commit | 13758848912933b99acb59261184a70fa6c7a5b4 (patch) | |
tree | b2875f7fdd9cb42675ca101b0537a0bfb1193ca2 /Lib/test/test_multiprocessing.py | |
parent | 10e65881d5baf13d186821fcf7451f25f06db95e (diff) | |
download | cpython-13758848912933b99acb59261184a70fa6c7a5b4.zip cpython-13758848912933b99acb59261184a70fa6c7a5b4.tar.gz cpython-13758848912933b99acb59261184a70fa6c7a5b4.tar.bz2 |
Fiddle with timeouts in barrier tests
Diffstat (limited to 'Lib/test/test_multiprocessing.py')
-rw-r--r-- | Lib/test/test_multiprocessing.py | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/Lib/test/test_multiprocessing.py b/Lib/test/test_multiprocessing.py index 2704827..08f87cd 100644 --- a/Lib/test/test_multiprocessing.py +++ b/Lib/test/test_multiprocessing.py @@ -1151,7 +1151,7 @@ class _TestBarrier(BaseTestCase): Tests for Barrier objects. """ N = 5 - defaultTimeout = 10.0 # XXX Slow Windows buildbots need generous timeout + defaultTimeout = 30.0 # XXX Slow Windows buildbots need generous timeout def setUp(self): self.barrier = self.Barrier(self.N, timeout=self.defaultTimeout) @@ -1327,10 +1327,10 @@ class _TestBarrier(BaseTestCase): @classmethod def _test_timeout_f(cls, barrier, results): - i = barrier.wait(20) + i = barrier.wait() if i == cls.N//2: # One thread is late! - time.sleep(4.0) + time.sleep(1.0) try: barrier.wait(0.5) except threading.BrokenBarrierError: @@ -1346,10 +1346,10 @@ class _TestBarrier(BaseTestCase): @classmethod def _test_default_timeout_f(cls, barrier, results): - i = barrier.wait(20) + i = barrier.wait(cls.defaultTimeout) if i == cls.N//2: # One thread is later than the default timeout - time.sleep(4.0) + time.sleep(1.0) try: barrier.wait() except threading.BrokenBarrierError: @@ -1359,7 +1359,7 @@ class _TestBarrier(BaseTestCase): """ Test the barrier's default timeout """ - barrier = self.Barrier(self.N, timeout=1.0) + barrier = self.Barrier(self.N, timeout=0.5) results = self.DummyList() self.run_threads(self._test_default_timeout_f, (barrier, results)) self.assertEqual(len(results), barrier.parties) |