Commit 5f691de4 authored by Tim Peters's avatar Tim Peters

class TimeoutTests: close the storage when done.

parent 35703a50
...@@ -793,6 +793,7 @@ class TimeoutTests(CommonSetupTearDown): ...@@ -793,6 +793,7 @@ class TimeoutTests(CommonSetupTearDown):
storage.tpc_vote(txn) storage.tpc_vote(txn)
time.sleep(2) time.sleep(2)
self.assertRaises(ClientDisconnected, storage.tpc_finish, txn) self.assertRaises(ClientDisconnected, storage.tpc_finish, txn)
storage.close()
def checkTimeoutOnAbort(self): def checkTimeoutOnAbort(self):
storage = self.openClientStorage() storage = self.openClientStorage()
...@@ -800,12 +801,14 @@ class TimeoutTests(CommonSetupTearDown): ...@@ -800,12 +801,14 @@ class TimeoutTests(CommonSetupTearDown):
storage.tpc_begin(txn) storage.tpc_begin(txn)
storage.tpc_vote(txn) storage.tpc_vote(txn)
storage.tpc_abort(txn) storage.tpc_abort(txn)
storage.close()
def checkTimeoutOnAbortNoLock(self): def checkTimeoutOnAbortNoLock(self):
storage = self.openClientStorage() storage = self.openClientStorage()
txn = Transaction() txn = Transaction()
storage.tpc_begin(txn) storage.tpc_begin(txn)
storage.tpc_abort(txn) storage.tpc_abort(txn)
storage.close()
class MSTThread(threading.Thread): class MSTThread(threading.Thread):
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment