Commit f7b67cb9 authored by Julien Muchembled's avatar Julien Muchembled

tests: transaction.begin() does abort, not the contrary

parent 5b61b676
...@@ -525,7 +525,7 @@ class Test(NEOThreadedTest): ...@@ -525,7 +525,7 @@ class Test(NEOThreadedTest):
try: try:
t = self.newThread(t1.commit) t = self.newThread(t1.commit)
l1.acquire() l1.acquire()
t2.abort() t2.begin()
finally: finally:
del p del p
l2.release() l2.release()
...@@ -576,10 +576,10 @@ class Test(NEOThreadedTest): ...@@ -576,10 +576,10 @@ class Test(NEOThreadedTest):
finally: finally:
master_client() master_client()
x2._p_deactivate() x2._p_deactivate()
t1.abort() # process invalidation and sync connection storage t1.begin() # process invalidation and sync connection storage
self.assertEqual(x2.value, 0) self.assertEqual(x2.value, 0)
# New testing transaction. Now we can see the last value of x. # New testing transaction. Now we can see the last value of x.
t2.abort() t2.begin()
self.assertEqual(x2.value, 1) self.assertEqual(x2.value, 1)
# Now test cache invalidation during a load from a storage # Now test cache invalidation during a load from a storage
...@@ -610,7 +610,7 @@ class Test(NEOThreadedTest): ...@@ -610,7 +610,7 @@ class Test(NEOThreadedTest):
client.close() client.close()
client.setPoll(0) client.setPoll(0)
cluster.client.setPoll(1) cluster.client.setPoll(1)
t1.abort() # make sure invalidation is processed t1.begin() # make sure invalidation is processed
finally: finally:
del p del p
# Resume processing of answer from storage. An entry should be # Resume processing of answer from storage. An entry should be
......
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