summaryrefslogtreecommitdiff
path: root/src/third_party/wiredtiger/test/suite/test_rollback_to_stable17.py
diff options
context:
space:
mode:
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.py13
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.