diff --git a/test/unit/account/test_backend.py b/test/unit/account/test_backend.py index 7b8cf44ca1..20622f420b 100644 --- a/test/unit/account/test_backend.py +++ b/test/unit/account/test_backend.py @@ -420,17 +420,18 @@ class TestAccountBroker(test_db.TestDbBase): def test_get_info(self): # Test AccountBroker.get_info broker = AccountBroker(self.get_db_path(), account='test1') - broker.initialize(Timestamp('1').internal) + put_ts = next(self.ts) + broker.initialize(put_ts.internal) info = broker.get_info() self.assertEqual(info['account'], 'test1') self.assertEqual(info['hash'], '00000000000000000000000000000000') - self.assertEqual(info['put_timestamp'], Timestamp(1).internal) + self.assertEqual(info['put_timestamp'], put_ts.internal) self.assertEqual(info['delete_timestamp'], '0') if self.__class__ == TestAccountBrokerBeforeMetadata: self.assertEqual(info['status_changed_at'], '0') else: - self.assertEqual(info['status_changed_at'], Timestamp(1).internal) + self.assertEqual(info['status_changed_at'], put_ts.internal) info = broker.get_info() self.assertEqual(info['container_count'], 0) @@ -597,20 +598,21 @@ class TestAccountBroker(test_db.TestDbBase): def test_list_objects_iter_order_and_reverse(self): # Test ContainerBroker.list_objects_iter broker = AccountBroker(self.get_db_path(), account='a') - broker.initialize(Timestamp('1').internal, 0) + put_ts = next(self.ts) + broker.initialize(put_ts.internal, 0) broker.put_container( - 'c1', Timestamp(0).internal, 0, 0, 0, POLICIES.default.idx) + 'c1', next(self.ts).internal, 0, 0, 0, POLICIES.default.idx) broker.put_container( - 'c10', Timestamp(0).internal, 0, 0, 0, POLICIES.default.idx) + 'c10', next(self.ts).internal, 0, 0, 0, POLICIES.default.idx) broker.put_container( - 'C1', Timestamp(0).internal, 0, 0, 0, POLICIES.default.idx) + 'C1', next(self.ts).internal, 0, 0, 0, POLICIES.default.idx) broker.put_container( - 'c2', Timestamp(0).internal, 0, 0, 0, POLICIES.default.idx) + 'c2', next(self.ts).internal, 0, 0, 0, POLICIES.default.idx) broker.put_container( - 'c3', Timestamp(0).internal, 0, 0, 0, POLICIES.default.idx) + 'c3', next(self.ts).internal, 0, 0, 0, POLICIES.default.idx) broker.put_container( - 'C4', Timestamp(0).internal, 0, 0, 0, POLICIES.default.idx) + 'C4', next(self.ts).internal, 0, 0, 0, POLICIES.default.idx) listing = broker.list_containers_iter(100, None, None, '', '', reverse=False) @@ -831,27 +833,30 @@ class TestAccountBroker(test_db.TestDbBase): def test_chexor(self): broker = AccountBroker(self.get_db_path(), account='a') - broker.initialize(Timestamp('1').internal) - broker.put_container('a', Timestamp(1).internal, - Timestamp(0).internal, 0, 0, + put_ts = next(self.ts) + delete_ts = Timestamp(0) + timestamps = [next(self.ts) for _ in range(3)] + broker.initialize(put_ts.internal) + broker.put_container('a', timestamps[0].internal, + delete_ts.internal, 0, 0, POLICIES.default.idx) - broker.put_container('b', Timestamp(2).internal, - Timestamp(0).internal, 0, 0, + broker.put_container('b', timestamps[1].internal, + delete_ts.internal, 0, 0, POLICIES.default.idx) text = '%s-%s' % ('a', "%s-%s-%s-%s" % ( - Timestamp(1).internal, Timestamp(0).internal, 0, 0)) + timestamps[0].internal, delete_ts.internal, 0, 0)) hasha = md5(text.encode('ascii'), usedforsecurity=False).digest() text = '%s-%s' % ('b', "%s-%s-%s-%s" % ( - Timestamp(2).internal, Timestamp(0).internal, 0, 0)) + timestamps[1].internal, delete_ts.internal, 0, 0)) hashb = md5(text.encode('ascii'), usedforsecurity=False).digest() hashc = ''.join(('%02x' % (a ^ b) for a, b in zip(hasha, hashb))) self.assertEqual(broker.get_info()['hash'], hashc) - broker.put_container('b', Timestamp(3).internal, - Timestamp(0).internal, 0, 0, + broker.put_container('b', timestamps[2].internal, + delete_ts.internal, 0, 0, POLICIES.default.idx) text = '%s-%s' % ('b', "%s-%s-%s-%s" % ( - Timestamp(3).internal, Timestamp(0).internal, 0, 0)) + timestamps[2].internal, delete_ts.internal, 0, 0)) hashb = md5(text.encode('ascii'), usedforsecurity=False).digest() hashc = ''.join(('%02x' % (a ^ b) for a, b in zip(hasha, hashb))) @@ -1889,11 +1894,13 @@ class TestAccountBrokerBeforePerPolicyContainerTrack( def test_policy_table_cont_count_update_get_stats(self): # add a few container entries + ts_zero = Timestamp(0) for policy in POLICIES: for i in range(0, policy.idx + 1): container_name = 'c%s_0' % policy.idx self.broker.put_container('c%s_%s' % (policy.idx, i), - 0, 0, 0, 0, policy.idx) + ts_zero.internal, ts_zero.internal, + 0, 0, policy.idx) # _commit_puts_stale_ok() called by get_policy_stats() # calling get_policy_stats() with do_migrations will alter the table @@ -1928,7 +1935,9 @@ class TestAccountBrokerBeforePerPolicyContainerTrack( # now put them back and make sure things are still cool for policy in POLICIES: container_name = 'c%s_0' % policy.idx - self.broker.put_container(container_name, 0, 0, 0, 0, policy.idx) + self.broker.put_container( + container_name, ts_zero.internal, ts_zero.internal, 0, 0, + policy.idx) # _commit_puts_stale_ok() called by get_policy_stats() # confirm stats reporting back correctly