diff options
Diffstat (limited to 'src/third_party/wiredtiger/test/suite/hook_tiered.py')
| -rwxr-xr-x | src/third_party/wiredtiger/test/suite/hook_tiered.py | 67 |
1 files changed, 64 insertions, 3 deletions
diff --git a/src/third_party/wiredtiger/test/suite/hook_tiered.py b/src/third_party/wiredtiger/test/suite/hook_tiered.py index 429bee56529..1d64644e549 100755 --- a/src/third_party/wiredtiger/test/suite/hook_tiered.py +++ b/src/third_party/wiredtiger/test/suite/hook_tiered.py @@ -55,8 +55,7 @@ # from __future__ import print_function -import os, sys, wthooks -import unittest +import os, sys, unittest, wthooks, wttimestamp from wttest import WiredTigerTestCase # These are the hook functions that are run when particular APIs are called. @@ -164,6 +163,13 @@ def connection_close_replace(orig_connection_close, connection_self, config): ret = orig_connection_close(connection_self, config) return ret +# Called to replace Connection.open_session +def connection_open_session_replace(orig_connection_open_session, connection_self, config): + ret_session = orig_connection_open_session(connection_self, config) + ret_session._connection = connection_self + ret_session._has_transaction = False + return ret_session + # Called to replace Session.checkpoint. # We add a call to flush_tier after the checkpoint to make sure we are exercising tiered # functionality. @@ -178,6 +184,24 @@ def session_checkpoint_replace(orig_session_checkpoint, session_self, config): ' Calling flush_tier() after checkpoint') return session_self.flush_tier(None) +# Called to replace Session.begin_transaction +def session_begin_transaction_replace(orig_session_begin_transaction, session_self, config): + ret = orig_session_begin_transaction(session_self, config) + session_self._has_transaction = True + return ret + +# Called to replace Session.commit_transaction +def session_commit_transaction_replace(orig_session_commit_transaction, session_self, config): + ret = orig_session_commit_transaction(session_self, config) + session_self._has_transaction = False + return ret + +# Called to replace Session.rollback_transaction +def session_rollback_transaction_replace(orig_session_rollback_transaction, session_self, config): + ret = orig_session_rollback_transaction(session_self, config) + session_self._has_transaction = False + return ret + # Called to replace Session.compact def session_compact_replace(orig_session_compact, session_self, uri, config): # Compact isn't implemented for tiered tables. Only call it if this can't be the uri @@ -218,7 +242,9 @@ def session_open_cursor_replace(orig_session_open_cursor, session_self, uri, dup if uri != None and uri.startswith("backup:"): testcase = WiredTigerTestCase.currentTestCase() testcase.skipTest("backup on tiered tables not yet implemented") - return orig_session_open_cursor(session_self, uri, dupcursor, config) + ret_cursor = orig_session_open_cursor(session_self, uri, dupcursor, config) + ret_cursor._session = session_self + return ret_cursor # Called to replace Session.rename def session_rename_replace(orig_session_rename, session_self, uri, newuri, config): @@ -263,6 +289,14 @@ class TieredHookCreator(wthooks.WiredTigerHookCreator): # Override some platform APIs self.platform_api = TieredPlatformAPI() + # This hook plays with timestamps, indirectly by modifying the behavior of the *DataSet classes. + # Here we declare our use of timestamp code, so that tests that have their own notion of + # timestamps can be skipped when running with this hook. + def uses(self, use_list): + if "timestamp" in use_list: + return True + return False + # Is this test one we should skip? def skip_test(self, test): # Skip any test that contains one of these strings as a substring @@ -367,6 +401,22 @@ class TieredHookCreator(wthooks.WiredTigerHookCreator): self.Connection['close'] = (wthooks.HOOK_REPLACE, lambda s, config=None: connection_close_replace(orig_connection_close, s, config)) + orig_connection_open_session = self.Connection['open_session'] + self.Connection['open_session'] = (wthooks.HOOK_REPLACE, lambda s, config=None: + connection_open_session_replace(orig_connection_open_session, s, config)) + + orig_session_begin_transaction = self.Session['begin_transaction'] + self.Session['begin_transaction'] = (wthooks.HOOK_REPLACE, lambda s, config=None: + session_begin_transaction_replace(orig_session_begin_transaction, s, config)) + + orig_session_commit_transaction = self.Session['commit_transaction'] + self.Session['commit_transaction'] = (wthooks.HOOK_REPLACE, lambda s, config=None: + session_commit_transaction_replace(orig_session_commit_transaction, s, config)) + + orig_session_rollback_transaction = self.Session['rollback_transaction'] + self.Session['rollback_transaction'] = (wthooks.HOOK_REPLACE, lambda s, config=None: + session_rollback_transaction_replace(orig_session_rollback_transaction, s, config)) + orig_session_compact = self.Session['compact'] self.Session['compact'] = (wthooks.HOOK_REPLACE, lambda s, uri, config=None: session_compact_replace(orig_session_compact, s, uri, config)) @@ -395,6 +445,12 @@ class TieredHookCreator(wthooks.WiredTigerHookCreator): # Override some platform APIs for this hook. class TieredPlatformAPI(wthooks.WiredTigerHookPlatformAPI): + def setUp(self): + self._timestamp = wttimestamp.WiredTigerTimeStamp() + + def tearDown(self): + pass + def tableExists(self, name): for i in range(1, 9): tablename = name + "-000000000{}.wtobj".format(i) @@ -408,6 +464,11 @@ class TieredPlatformAPI(wthooks.WiredTigerHookPlatformAPI): else: return wthooks.DefaultPlatformAPI.initialFileName(uri) + # By default, there is no timestamping by the data set classes. + def getTimestamp(self): + return self._timestamp + + # Every hook file must have a top level initialize function, # returning a list of WiredTigerHook objects. def initialize(arg): |