Commit ce645dc5 authored by Julien Muchembled's avatar Julien Muchembled

Update replication test wrt r2777

git-svn-id: https://svn.erp5.org/repos/neo/trunk@2779 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 7924cd62
...@@ -531,7 +531,8 @@ class StorageReplicationHandlerTests(NeoUnitTestBase): ...@@ -531,7 +531,8 @@ class StorageReplicationHandlerTests(NeoUnitTestBase):
# ...and delete partition tail # ...and delete partition tail
calls = app.dm.mockGetNamedCalls('deleteObjectsAbove') calls = app.dm.mockGetNamedCalls('deleteObjectsAbove')
self.assertEqual(len(calls), 1) self.assertEqual(len(calls), 1)
calls[0].checkArgs(num_partitions, rid, max_oid, add64(max_serial, 1)) calls[0].checkArgs(num_partitions, rid, max_oid, add64(max_serial, 1),
ZERO_TID)
def test_answerCheckSerialRangeDifferentBigChunk(self): def test_answerCheckSerialRangeDifferentBigChunk(self):
min_oid = self.getOID(1) min_oid = self.getOID(1)
...@@ -625,7 +626,8 @@ class StorageReplicationHandlerTests(NeoUnitTestBase): ...@@ -625,7 +626,8 @@ class StorageReplicationHandlerTests(NeoUnitTestBase):
# ...and delete partition tail # ...and delete partition tail
calls = app.dm.mockGetNamedCalls('deleteObjectsAbove') calls = app.dm.mockGetNamedCalls('deleteObjectsAbove')
self.assertEqual(len(calls), 1) self.assertEqual(len(calls), 1)
calls[0].checkArgs(num_partitions, rid, max_oid, add64(max_serial, 1)) calls[0].checkArgs(num_partitions, rid, max_oid, add64(max_serial, 1),
critical_tid)
if __name__ == "__main__": if __name__ == "__main__":
unittest.main() unittest.main()
...@@ -383,7 +383,7 @@ class StorageDBTests(NeoUnitTestBase): ...@@ -383,7 +383,7 @@ class StorageDBTests(NeoUnitTestBase):
txn, objs = self.getTransaction([oid1, oid2, oid3]) txn, objs = self.getTransaction([oid1, oid2, oid3])
self.db.storeTransaction(tid, objs, txn) self.db.storeTransaction(tid, objs, txn)
self.db.finishTransaction(tid) self.db.finishTransaction(tid)
self.db.deleteObjectsAbove(2, 0, oid1, tid2) self.db.deleteObjectsAbove(2, 0, oid1, tid2, tid3)
# Check getObjectHistoryFrom because MySQL adapter use two tables # Check getObjectHistoryFrom because MySQL adapter use two tables
# that must be synchronized # that must be synchronized
self.assertEqual(self.db.getObjectHistoryFrom(ZERO_OID, ZERO_TID, self.assertEqual(self.db.getObjectHistoryFrom(ZERO_OID, ZERO_TID,
......
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