Revision 6252c0bd
| b/test/ganeti.locking_unittest.py | ||
|---|---|---|
| 187 | 187 |
self.cond.acquire() |
| 188 | 188 |
self.assertEqual(len(self.cond._waiters), 3) |
| 189 | 189 |
self.assertEqual(self.cond._waiters, set(threads)) |
| 190 |
|
|
| 191 |
self.assertTrue(repr(self.cond).startswith("<"))
|
|
| 192 |
self.assertTrue("waiters=" in repr(self.cond))
|
|
| 193 |
|
|
| 190 | 194 |
# This new thread can't acquire the lock, and thus call wait, before we |
| 191 | 195 |
# release it |
| 192 | 196 |
self._addThread(target=fn) |
| ... | ... | |
| 268 | 272 |
_ThreadedTestCase.setUp(self) |
| 269 | 273 |
self.sl = locking.SharedLock("TestSharedLock")
|
| 270 | 274 |
|
| 275 |
self.assertTrue(repr(self.sl).startswith("<"))
|
|
| 276 |
self.assertTrue("name=TestSharedLock" in repr(self.sl))
|
|
| 277 |
|
|
| 271 | 278 |
def testSequenceAndOwnership(self): |
| 272 | 279 |
self.assertFalse(self.sl.is_owned()) |
| 273 | 280 |
self.sl.acquire(shared=1) |
Also available in: Unified diff