Commit 87ac03a7 authored by Joshua Woelfel's avatar Joshua Woelfel

Made zconn_at_test compatible with ZODB3

parent 82c3dfdd
......@@ -109,10 +109,18 @@ class Zconn_atTest(unittest.TestCase):
transaction.begin()
connection = self.db.open()
T1_is_connected.send(CONNECTED)
try:
tids[THREAD1] = u64(zconn_at(connection))
T2_is_connected.recv()
transaction.abort()
connection.close()
except AssertionError as error:
T2_is_connected.recv()
transaction.abort()
connection.close()
raise error
#transaction.abort()
#connection.close()
def T2(ctx, self):
T1_is_connected.recv()
......@@ -141,6 +149,7 @@ class Zconn_atTest(unittest.TestCase):
def T1(ctx, self):
transaction.begin()
connection = self.db.open()
try:
tids[START] = u64(zconn_at(connection))
T1_is_connected.send(CONNECTED)
......@@ -149,6 +158,12 @@ class Zconn_atTest(unittest.TestCase):
transaction.abort()
connection.close()
except AssertionError as error:
T1_is_connected.send(CONNECTED)
T2_is_done.recv()
transaction.abort()
connection.close()
raise error
def T2(ctx, self):
T1_is_connected.recv()
......
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