(self)
| 438 | |
| 439 | class ForkAwareThreadLock(object): |
| 440 | def __init__(self): |
| 441 | self._lock = threading.Lock() |
| 442 | self.acquire = self._lock.acquire |
| 443 | self.release = self._lock.release |
| 444 | register_after_fork(self, ForkAwareThreadLock._at_fork_reinit) |
| 445 | |
| 446 | def _at_fork_reinit(self): |
| 447 | self._lock._at_fork_reinit() |
nothing calls this directly
no test coverage detected