Revision 0ef4d576 test/ganeti.locking_unittest.py
| b/test/ganeti.locking_unittest.py | ||
|---|---|---|
| 1703 | 1703 |
|
| 1704 | 1704 |
self.ls.release() |
| 1705 | 1705 |
|
| 1706 |
def testDowngradeEverything(self): |
|
| 1707 |
self.assertEqual(self.ls.acquire(locking.ALL_SET, shared=0), |
|
| 1708 |
set(["one", "two", "three"])) |
|
| 1709 |
|
|
| 1710 |
# Ensure all locks are now owned in exclusive mode |
|
| 1711 |
for name in self.ls._names(): |
|
| 1712 |
self.assertTrue(self.ls.check_owned(name, shared=0)) |
|
| 1713 |
|
|
| 1714 |
# Downgrade everything |
|
| 1715 |
self.assertTrue(self.ls.downgrade()) |
|
| 1716 |
|
|
| 1717 |
# Ensure all locks are now owned in shared mode |
|
| 1718 |
for name in self.ls._names(): |
|
| 1719 |
self.assertTrue(self.ls.check_owned(name, shared=1)) |
|
| 1720 |
|
|
| 1706 | 1721 |
def testPriority(self): |
| 1707 | 1722 |
def _Acquire(prev, next, name, priority, success_fn): |
| 1708 | 1723 |
prev.wait() |
Also available in: Unified diff