[Zodb-checkins] CVS: ZODB3/ZEO/tests - ConnectionTests.py:1.4.2.1.6.4

Jeremy Hylton jeremy@zope.com
Wed, 18 Dec 2002 11:23:55 -0500


Update of /cvs-repository/ZODB3/ZEO/tests
In directory cvs.zope.org:/tmp/cvs-serv22461/tests

Modified Files:
      Tag: ZODB3-fast-restart-branch
	ConnectionTests.py 
Log Message:
Add event to TestClientStorage to wait for verification to end.


=== ZODB3/ZEO/tests/ConnectionTests.py 1.4.2.1.6.3 => 1.4.2.1.6.4 ===
--- ZODB3/ZEO/tests/ConnectionTests.py:1.4.2.1.6.3	Tue Dec 17 18:28:03 2002
+++ ZODB3/ZEO/tests/ConnectionTests.py	Wed Dec 18 11:23:54 2002
@@ -18,7 +18,8 @@
 import socket
 import sys
 import tempfile
-import thread
+import thread # XXX do we really need to catch thread.error
+import threading
 import time
 
 import zLOG
@@ -36,6 +37,11 @@
 
     def verify_cache(self, stub):
         self.verify_result = ClientStorage.verify_cache(self, stub)
+        self.end_verify = threading.Event()
+
+    def endVerify(self):
+        ClientStorage.endVerify(self)
+        self.end_verify.set()
 
 class DummyDB:
     def invalidate(self, *args, **kwargs):
@@ -604,7 +610,11 @@
 
         perstorage = self.openClientStorage(cache="test")
         self.assertEqual(perstorage.verify_result, "full verification")
-        perstorage.sync()
+        t = time.time() + 30
+        while not perstorage.end_verify.isSet():
+            perstorage.sync()
+            if time.time() > t:
+                self.fail("timed out waiting for endVerify")
 
         self.assertEqual(self._storage.load(oid, '')[1], revid)
         self.assertEqual(perstorage.load(oid, ''),