| 2639 | |
| 2640 | |
| 2641 | class _Atomic: |
| 2642 | __slots__ = ('_acquired',) |
| 2643 | |
| 2644 | def __init__(self): |
| 2645 | self._acquired = 0 |
| 2646 | |
| 2647 | def __enter__(self): |
| 2648 | if self._acquired: |
| 2649 | raise exceptions.InterfaceError( |
| 2650 | 'cannot perform operation: another operation is in progress') |
| 2651 | self._acquired = 1 |
| 2652 | |
| 2653 | def __exit__(self, t, e, tb): |
| 2654 | self._acquired = 0 |
| 2655 | |
| 2656 | |
| 2657 | class _ConnectionProxy: |
no outgoing calls
no test coverage detected
searching dependent graphs…