(self)
| 464 | self.acquire(exclusive=True, remove=SHARED) |
| 465 | |
| 466 | def downgrade(self): |
| 467 | if self.is_exclusive: |
| 468 | self.acquire(exclusive=False, remove=EXCLUSIVE) |
| 469 | |
| 470 | def got_exclusive_lock(self): |
| 471 | return self.is_exclusive and self._lock.is_locked() and self._lock.by_me() |