summaryrefslogtreecommitdiff
path: root/src/third_party/wiredtiger/test/suite/test_rollback_to_stable09.py
diff options
context:
space:
mode:
Diffstat (limited to 'src/third_party/wiredtiger/test/suite/test_rollback_to_stable09.py')
-rwxr-xr-xsrc/third_party/wiredtiger/test/suite/test_rollback_to_stable09.py33
1 files changed, 15 insertions, 18 deletions
diff --git a/src/third_party/wiredtiger/test/suite/test_rollback_to_stable09.py b/src/third_party/wiredtiger/test/suite/test_rollback_to_stable09.py
index d0a45f0522d..f061f071acd 100755
--- a/src/third_party/wiredtiger/test/suite/test_rollback_to_stable09.py
+++ b/src/third_party/wiredtiger/test/suite/test_rollback_to_stable09.py
@@ -32,9 +32,6 @@ from wtdataset import SimpleDataSet
from wtscenario import make_scenarios
from test_rollback_to_stable01 import test_rollback_to_stable_base
-def timestamp_str(t):
- return '%x' % t
-
# test_rollback_to_stable09.py
# Test that rollback to stable does not abort schema operations that are done
# as they don't have transaction support
@@ -58,7 +55,7 @@ class test_rollback_to_stable09(test_rollback_to_stable_base):
scenarios = make_scenarios(in_memory_values, prepare_values)
def conn_config(self):
- config = 'cache_size=250MB,statistics=(all)'
+ config = 'cache_size=250MB'
if self.in_memory:
config += ',in_memory=true'
else:
@@ -73,12 +70,12 @@ class test_rollback_to_stable09(test_rollback_to_stable_base):
if commit_ts == 0:
session.commit_transaction()
elif self.prepare:
- session.prepare_transaction('prepare_timestamp=' + timestamp_str(commit_ts-1))
- session.timestamp_transaction('commit_timestamp=' + timestamp_str(commit_ts))
- session.timestamp_transaction('durable_timestamp=' + timestamp_str(commit_ts+1))
+ session.prepare_transaction('prepare_timestamp=' + self.timestamp_str(commit_ts-1))
+ session.timestamp_transaction('commit_timestamp=' + self.timestamp_str(commit_ts))
+ session.timestamp_transaction('durable_timestamp=' + self.timestamp_str(commit_ts+1))
session.commit_transaction()
else:
- session.commit_transaction('commit_timestamp=' + timestamp_str(commit_ts))
+ session.commit_transaction('commit_timestamp=' + self.timestamp_str(commit_ts))
def drop_table(self, commit_ts):
self.pr('drop table')
@@ -88,12 +85,12 @@ class test_rollback_to_stable09(test_rollback_to_stable_base):
if commit_ts == 0:
session.commit_transaction()
elif self.prepare:
- session.prepare_transaction('prepare_timestamp=' + timestamp_str(commit_ts-1))
- session.timestamp_transaction('commit_timestamp=' + timestamp_str(commit_ts))
- session.timestamp_transaction('durable_timestamp=' + timestamp_str(commit_ts+1))
+ session.prepare_transaction('prepare_timestamp=' + self.timestamp_str(commit_ts-1))
+ session.timestamp_transaction('commit_timestamp=' + self.timestamp_str(commit_ts))
+ session.timestamp_transaction('durable_timestamp=' + self.timestamp_str(commit_ts+1))
session.commit_transaction()
else:
- session.commit_transaction('commit_timestamp=' + timestamp_str(commit_ts))
+ session.commit_transaction('commit_timestamp=' + self.timestamp_str(commit_ts))
def create_index(self, commit_ts):
session = self.session
@@ -102,17 +99,17 @@ class test_rollback_to_stable09(test_rollback_to_stable_base):
if commit_ts == 0:
session.commit_transaction()
elif self.prepare:
- session.prepare_transaction('prepare_timestamp=' + timestamp_str(commit_ts-1))
- session.timestamp_transaction('commit_timestamp=' + timestamp_str(commit_ts))
- session.timestamp_transaction('durable_timestamp=' + timestamp_str(commit_ts+1))
+ session.prepare_transaction('prepare_timestamp=' + self.timestamp_str(commit_ts-1))
+ session.timestamp_transaction('commit_timestamp=' + self.timestamp_str(commit_ts))
+ session.timestamp_transaction('durable_timestamp=' + self.timestamp_str(commit_ts+1))
session.commit_transaction()
else:
- session.commit_transaction('commit_timestamp=' + timestamp_str(commit_ts))
+ session.commit_transaction('commit_timestamp=' + self.timestamp_str(commit_ts))
def test_rollback_to_stable(self):
# Pin oldest and stable to timestamp 10.
- self.conn.set_timestamp('oldest_timestamp=' + timestamp_str(10) +
- ',stable_timestamp=' + timestamp_str(10))
+ self.conn.set_timestamp('oldest_timestamp=' + self.timestamp_str(10) +
+ ',stable_timestamp=' + self.timestamp_str(10))
# Create table and index at a later timestamp
self.create_table(20)