diff options
Diffstat (limited to 'src/third_party/wiredtiger/test/suite/test_rollback_to_stable17.py')
-rw-r--r-- | src/third_party/wiredtiger/test/suite/test_rollback_to_stable17.py | 13 |
1 files changed, 5 insertions, 8 deletions
diff --git a/src/third_party/wiredtiger/test/suite/test_rollback_to_stable17.py b/src/third_party/wiredtiger/test/suite/test_rollback_to_stable17.py index 829e5d13680..1697cd50c8b 100644 --- a/src/third_party/wiredtiger/test/suite/test_rollback_to_stable17.py +++ b/src/third_party/wiredtiger/test/suite/test_rollback_to_stable17.py @@ -33,9 +33,6 @@ from wiredtiger import stat from wtdataset import SimpleDataSet from wtscenario import make_scenarios -def timestamp_str(t): - return '%x' % t - # test_rollback_to_stable17.py # Test that rollback to stable handles updates present on history store and data store for variable # length column store. @@ -67,12 +64,12 @@ class test_rollback_to_stable17(wttest.WiredTigerTestCase): for i in range(start_row, end_row): self.session.begin_transaction() cursor[i] = value - self.session.commit_transaction('commit_timestamp=' + timestamp_str(timestamp)) + self.session.commit_transaction('commit_timestamp=' + self.timestamp_str(timestamp)) cursor.close() def check(self, check_value, uri, nrows, read_ts): session = self.session - session.begin_transaction('read_timestamp=' + timestamp_str(read_ts)) + session.begin_transaction('read_timestamp=' + self.timestamp_str(read_ts)) cursor = session.open_cursor(uri) count = 0 @@ -96,15 +93,15 @@ class test_rollback_to_stable17(wttest.WiredTigerTestCase): self.session.create(uri, create_params) # Pin oldest and stable to timestamp 1. - self.conn.set_timestamp('oldest_timestamp=' + timestamp_str(1) + - ',stable_timestamp=' + timestamp_str(1)) + self.conn.set_timestamp('oldest_timestamp=' + self.timestamp_str(1) + + ',stable_timestamp=' + self.timestamp_str(1)) # Make a series of updates for the same keys with different values at different timestamps. for i in range(len(values)): self.insert_update_data(uri, values[i], start_row, nrows, ts[i]) # Set the stable timestamp to 5. - self.conn.set_timestamp('stable_timestamp=' + timestamp_str(5)) + self.conn.set_timestamp('stable_timestamp=' + self.timestamp_str(5)) if not self.in_memory: # Checkpoint to ensure that all the updates are flushed to disk. |