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