(self)
| 222 | test_with() |
| 223 | |
| 224 | def testAcquireRelease(self): |
| 225 | def test_acquire_release(): |
| 226 | mutex = self.mutex |
| 227 | self.assertFalse(mutex.locked()) |
| 228 | self.assertRaises(RuntimeError, mutex.release) |
| 229 | locked = mutex.acquire() |
| 230 | self.assertTrue(locked) |
| 231 | self.assertTrue(mutex.locked()) |
| 232 | self.assertRaises(RuntimeError, mutex.acquire) |
| 233 | mutex.release() |
| 234 | self.assertFalse(mutex.locked()) |
| 235 | self.assertRaises(RuntimeError, mutex.release) |
| 236 | |
| 237 | for _ in range(5): |
| 238 | self.COMM.Barrier() |
| 239 | test_acquire_release() |
| 240 | for _ in range(5): |
| 241 | random_sleep() |
| 242 | test_acquire_release() |
| 243 | |
| 244 | def testAcquireNonblocking(self): |
| 245 | def test_acquire_nonblocking(): |
nothing calls this directly
no test coverage detected