openstack
/
tooz
Code Issues Proposed changes

Merge "FileDriver:Support multiple processes"

This commit is contained in:
Jenkins 2017-03-20 18:23:10 +00:00 committed by Gerrit Code Review
parent 54496ff820 40e749598b
commit f624e16f62
2 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
tooz/drivers/file.py
View File

@ -155,6 +155,7 @@ class FileLock(locking.Lock):
with self._barrier.cond:
self.acquired = False
self._barrier.owner = None
self._lock.release()
self._barrier.cond.notify_all()
return True

16
tooz/tests/test_coordination.py
View File

@ -743,10 +743,26 @@ class TestAPI(tests.TestWithCoordinator):
tests.get_random_uuid())
self.assertFalse(f.result())
def _do_test_get_lock_serial_locking_two_lock(self, executor,
use_same_coord):
name = tests.get_random_uuid()
lock1 = self._coord.get_lock(name)
lock1.acquire()
lock1.release()
with executor(max_workers=1) as e:
coord = self._coord if use_same_coord else None
f = e.submit(try_to_lock_job, name, coord, self.url,
tests.get_random_uuid())
self.assertTrue(f.result())
def test_get_lock_concurrency_locking_two_lock_process(self):
self._do_test_get_lock_concurrency_locking_two_lock(
futures.ProcessPoolExecutor, False)
def test_get_lock_serial_locking_two_lock_process(self):
self._do_test_get_lock_serial_locking_two_lock(
futures.ProcessPoolExecutor, False)
def test_get_lock_concurrency_locking_two_lock_thread1(self):
self._do_test_get_lock_concurrency_locking_two_lock(
futures.ThreadPoolExecutor, False)