(self)
| 486 | return self._lock.__exit__(exc_type, exc_val, exc_tb) |
| 487 | |
| 488 | def _init(self): |
| 489 | if self._rlock: |
| 490 | self._lock = threading.RLock() |
| 491 | else: |
| 492 | self._lock = thread.allocate_lock() |
| 493 | |
| 494 | self.acquire = self._lock.acquire |
| 495 | self.release = self._lock.release |
| 496 | _fork_safe_locks.append(weakref.ref(self)) |
| 497 | |
| 498 | |
| 499 | def after_fork(): |
no test coverage detected