Commit baf9c7fd authored by Grégory Wisniewski's avatar Grégory Wisniewski

- expectCondition define default values for timeout and delay

- replication check first if all storage are up
- add a test to check that nodes with conflicting UUIDs are rejected.


git-svn-id: https://svn.erp5.org/repos/neo/branches/prototype3@1235 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 47265fb3
...@@ -378,7 +378,7 @@ class NEOCluster(object): ...@@ -378,7 +378,7 @@ class NEOCluster(object):
current_try = None current_try = None
return current_try return current_try
def expectCondition(self, condition, timeout, delay): def expectCondition(self, condition, timeout=0, delay=1):
end = time.time() + timeout + DELAY_SAFETY_MARGIN end = time.time() + timeout + DELAY_SAFETY_MARGIN
opaque = None opaque = None
opaque_history = [] opaque_history = []
......
...@@ -79,7 +79,7 @@ class StorageTests(unittest.TestCase): ...@@ -79,7 +79,7 @@ class StorageTests(unittest.TestCase):
def callback(last_try): def callback(last_try):
object_number = self.queryCount(db, 'select count(*) from obj') object_number = self.queryCount(db, 'select count(*) from obj')
return object_number == OBJECT_NUMBER + 2, object_number return object_number == OBJECT_NUMBER + 2, object_number
self.neo.expectCondition(callback, 0, 1) self.neo.expectCondition(callback)
# no more temporarily objects # no more temporarily objects
t_objects = self.queryCount(db, 'select count(*) from tobj') t_objects = self.queryCount(db, 'select count(*) from tobj')
self.assertEqual(t_objects, 0) self.assertEqual(t_objects, 0)
...@@ -93,6 +93,10 @@ class StorageTests(unittest.TestCase): ...@@ -93,6 +93,10 @@ class StorageTests(unittest.TestCase):
def __checkReplicationDone(self): def __checkReplicationDone(self):
# wait for replication to finish # wait for replication to finish
def expect_all_storages(last_try):
storage_number = len(self.neo.getStorageNodeList())
return storage_number == len(self.neo.db_list), storage_number
self.neo.expectCondition(expect_all_storages, timeout=10)
self.neo.expectOudatedCells(number=0, timeout=10) self.neo.expectOudatedCells(number=0, timeout=10)
# check databases # check databases
for db_name in self.neo.db_list: for db_name in self.neo.db_list:
...@@ -220,6 +224,26 @@ class StorageTests(unittest.TestCase): ...@@ -220,6 +224,26 @@ class StorageTests(unittest.TestCase):
self.neo.expectOudatedCells(number=20) self.neo.expectOudatedCells(number=20)
self.neo.expectClusterVeryfing() self.neo.expectClusterVeryfing()
def testConflictingStorageRejected(self):
# start with one storage
(started, stopped) = self.__setup(storage_number=2, pending_number=1)
self.__expectRunning(started[0])
self.neo.expectClusterRunning()
# start the second with the same UUID as the first
stopped[0].setUUID(started[0].getUUID())
stopped[0].start()
# check the first and the cluster are still running
self.__expectRunning(started[0])
self.neo.expectClusterRunning()
# XXX: should wait for the storage rejection
# check that no node were added
storage_number = len(self.neo.getStorageNodeList())
self.assertEqual(storage_number, 1)
if __name__ == "__main__": if __name__ == "__main__":
unittest.main() unittest.main()
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