Commit a87ed448 authored by Barry Warsaw's avatar Barry Warsaw

pollUp(): Take an optional storage argument and poll on that if given.

checkNoVerificationOnServerRestartWith2Clients(): Pass perstorage to
pollUp(), which should eliminate the None != 'no verification'
failures.
parent fb75a08d
...@@ -145,11 +145,13 @@ class CommonSetupTearDown(StorageTestBase): ...@@ -145,11 +145,13 @@ class CommonSetupTearDown(StorageTestBase):
forker.shutdown_zeo_server(adminaddr) forker.shutdown_zeo_server(adminaddr)
self._servers[index] = None self._servers[index] = None
def pollUp(self, timeout=30.0): def pollUp(self, timeout=30.0, storage=None):
if storage is None:
storage = self._storage
# Poll until we're connected # Poll until we're connected
now = time.time() now = time.time()
giveup = now + timeout giveup = now + timeout
while not self._storage.is_connected(): while not storage.is_connected():
asyncore.poll(0.1) asyncore.poll(0.1)
now = time.time() now = time.time()
if now > giveup: if now > giveup:
...@@ -645,14 +647,15 @@ class ReconnectionTests(CommonSetupTearDown): ...@@ -645,14 +647,15 @@ class ReconnectionTests(CommonSetupTearDown):
self.pollDown() self.pollDown()
self._storage.verify_result = None self._storage.verify_result = None
perstorage.verify_result = None perstorage.verify_result = None
zLOG.LOG("testZEO", zLOG.INFO, '2ALLBEEF')
self.startServer(create=0) self.startServer(create=0)
self.pollUp() self.pollUp()
self.pollUp(storage=perstorage)
# There were no transactions committed, so no verification # There were no transactions committed, so no verification
# should be needed. # should be needed.
self.assertEqual(self._storage.verify_result, "no verification") self.assertEqual(self._storage.verify_result, "no verification")
perstorage.close()
self.assertEqual(perstorage.verify_result, "no verification") self.assertEqual(perstorage.verify_result, "no verification")
perstorage.close()
def checkQuickVerificationWith2Clients(self): def checkQuickVerificationWith2Clients(self):
perstorage = self.openClientStorage(cache="test") perstorage = self.openClientStorage(cache="test")
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment