From: Mike Bayer <mike_mp@zzzcomputing.com>
Date: Tue, 17 Jul 2012 13:32:11 +0000 (-0400)
Subject: try to loosen the times up here to reduce failures due to latency
X-Git-Tag: rel_0_7_9~62
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=30e8cd5960de3c2c72d60ee51ade31232775d76a;p=thirdparty%2Fsqlalchemy%2Fsqlalchemy.git

try to loosen the times up here to reduce failures due to latency
---

diff --git a/test/engine/test_pool.py b/test/engine/test_pool.py
index 492582f153..d8013b8902 100644
--- a/test/engine/test_pool.py
+++ b/test/engine/test_pool.py
@@ -110,7 +110,7 @@ class PoolTest(PoolTestBase):
         def creator():
             raise Exception("no creates allowed")
 
-        for cls in (pool.SingletonThreadPool, pool.StaticPool, 
+        for cls in (pool.SingletonThreadPool, pool.StaticPool,
                     pool.QueuePool, pool.NullPool, pool.AssertionPool):
             p = cls(creator=creator)
             p.dispose()
@@ -449,7 +449,7 @@ class DeprecatedPoolListenerTest(PoolTestBase):
                 eq_(len(innerself.first_connected), fconn)
                 eq_(len(innerself.checked_out), cout)
                 eq_(len(innerself.checked_in), cin)
-            def assert_in(innerself, item, in_conn, in_fconn, 
+            def assert_in(innerself, item, in_conn, in_fconn,
                                                 in_cout, in_cin):
                 self.assert_((item in innerself.connected) == in_conn)
                 self.assert_((item in innerself.first_connected) == in_fconn)
@@ -716,7 +716,7 @@ class QueuePoolTest(PoolTestBase):
 
     def test_timeout(self):
         p = self._queuepool_fixture(pool_size=3,
-                           max_overflow=0, 
+                           max_overflow=0,
                            timeout=2)
         c1 = p.connect()
         c2 = p.connect()
@@ -738,8 +738,8 @@ class QueuePoolTest(PoolTestBase):
         # them back to the start of do_get()
         dbapi = MockDBAPI()
         p = pool.QueuePool(
-                creator = lambda: dbapi.connect(delay=.05), 
-                pool_size = 2, 
+                creator = lambda: dbapi.connect(delay=.05),
+                pool_size = 2,
                 max_overflow = 1, use_threadlocal = False, timeout=3)
         timeouts = []
         def checkout():
@@ -759,7 +759,7 @@ class QueuePoolTest(PoolTestBase):
             th.start()
             threads.append(th)
         for th in threads:
-            th.join() 
+            th.join()
 
         assert len(timeouts) > 0
         for t in timeouts:
@@ -775,7 +775,7 @@ class QueuePoolTest(PoolTestBase):
         def creator():
             time.sleep(.05)
             return dbapi.connect()
- 
+
         p = pool.QueuePool(creator=creator,
                            pool_size=3, timeout=2,
                            max_overflow=max_overflow)
@@ -797,7 +797,7 @@ class QueuePoolTest(PoolTestBase):
             threads.append(th)
         for th in threads:
             th.join()
- 
+
         self.assert_(max(peaks) <= max_overflow)
 
         lazy_gc()
@@ -806,12 +806,12 @@ class QueuePoolTest(PoolTestBase):
     def test_waiters_handled(self):
         """test that threads waiting for connections are
         handled when the pool is replaced.
-        
+
         """
         dbapi = MockDBAPI()
         def creator():
             return dbapi.connect()
- 
+
         success = []
         for timeout in (None, 30):
             for max_overflow in (0, -1, 3):
@@ -820,7 +820,7 @@ class QueuePoolTest(PoolTestBase):
                                    max_overflow=max_overflow)
                 def waiter(p):
                     conn = p.connect()
-                    time.sleep(1)
+                    time.sleep(.5)
                     success.append(True)
                     conn.close()
 
@@ -836,7 +836,7 @@ class QueuePoolTest(PoolTestBase):
                 c1.invalidate()
                 c2.invalidate()
                 p2 = p._replace()
-        time.sleep(1)
+        time.sleep(2)
         eq_(len(success), 12)
 
     @testing.requires.python26
@@ -876,7 +876,7 @@ class QueuePoolTest(PoolTestBase):
         dbapi = MockDBAPI()
         def creator():
             return dbapi.connect()
- 
+
         p = pool.QueuePool(creator=creator,
                            pool_size=2, timeout=None,
                            max_overflow=0)
@@ -902,10 +902,10 @@ class QueuePoolTest(PoolTestBase):
 
     def test_no_overflow(self):
         self._test_overflow(40, 0)
- 
+
     def test_max_overflow(self):
         self._test_overflow(40, 5)
- 
+
     def test_mixed_close(self):
         p = self._queuepool_fixture(pool_size=3, max_overflow=-1, use_threadlocal=True)
         c1 = p.connect()
@@ -930,7 +930,7 @@ class QueuePoolTest(PoolTestBase):
         p = self._queuepool_fixture(pool_size=2,
                            max_overflow=2)
 
-        # disable weakref collection of the 
+        # disable weakref collection of the
         # underlying connections
         strong_refs = set()
         def _conn():
@@ -978,10 +978,10 @@ class QueuePoolTest(PoolTestBase):
         self.assert_(p.checkedout() != 0)
         c2.close()
         self.assert_(p.checkedout() == 0)
- 
+
     def test_recycle(self):
         p = self._queuepool_fixture(pool_size=1,
-                           max_overflow=0, 
+                           max_overflow=0,
                            recycle=3)
         c1 = p.connect()
         c_id = id(c1.connection)