diff options
Diffstat (limited to 'src/third_party/wiredtiger/test/suite/test_rollback_to_stable19.py')
| -rw-r--r-- | src/third_party/wiredtiger/test/suite/test_rollback_to_stable19.py | 20 |
1 files changed, 17 insertions, 3 deletions
diff --git a/src/third_party/wiredtiger/test/suite/test_rollback_to_stable19.py b/src/third_party/wiredtiger/test/suite/test_rollback_to_stable19.py index 3a24113fa32..284499dae64 100644 --- a/src/third_party/wiredtiger/test/suite/test_rollback_to_stable19.py +++ b/src/third_party/wiredtiger/test/suite/test_rollback_to_stable19.py @@ -29,7 +29,7 @@ import fnmatch, os, shutil, time from helper import simulate_crash_restart from test_rollback_to_stable01 import test_rollback_to_stable_base -from wiredtiger import stat +from wiredtiger import stat, WT_NOTFOUND from wtdataset import SimpleDataSet from wtscenario import make_scenarios @@ -102,11 +102,18 @@ class test_rollback_to_stable19(test_rollback_to_stable_base): # Search for the key so we position our cursor on the page that we want to evict. self.session.begin_transaction("ignore_prepare = true") evict_cursor.set_key(1) - evict_cursor.search() + self.assertEquals(evict_cursor.search(), WT_NOTFOUND) evict_cursor.reset() evict_cursor.close() self.session.commit_transaction() + # Search to make sure the data is not visible + self.session.begin_transaction("ignore_prepare = true") + cursor2 = self.session.open_cursor(uri) + cursor2.set_key(1) + self.assertEquals(cursor2.search(), WT_NOTFOUND) + self.session.commit_transaction() + # Pin stable timestamp to 20. self.conn.set_timestamp('stable_timestamp=' + timestamp_str(20)) if not self.in_memory: @@ -175,11 +182,18 @@ class test_rollback_to_stable19(test_rollback_to_stable_base): # Search for the key so we position our cursor on the page that we want to evict. self.session.begin_transaction("ignore_prepare = true") evict_cursor.set_key(1) - evict_cursor.search() + self.assertEquals(evict_cursor.search(), WT_NOTFOUND) evict_cursor.reset() evict_cursor.close() self.session.commit_transaction() + # Search to make sure the data is not visible + self.session.begin_transaction("ignore_prepare = true") + cursor2 = self.session.open_cursor(uri) + cursor2.set_key(1) + self.assertEquals(cursor2.search(), WT_NOTFOUND) + self.session.commit_transaction() + # Pin stable timestamp to 40. self.conn.set_timestamp('stable_timestamp=' + timestamp_str(40)) if not self.in_memory: |