(self)
| 518 | raise exceptions.BrokenBarrierError("Barrier aborted") |
| 519 | |
| 520 | async def _release(self): |
| 521 | # Release the tasks waiting in the barrier. |
| 522 | |
| 523 | # Enter draining state. |
| 524 | # Next waiting tasks will be blocked until the end of draining. |
| 525 | self._state = _BarrierState.DRAINING |
| 526 | self._cond.notify_all() |
| 527 | |
| 528 | async def _wait(self): |
| 529 | # Wait in the barrier until we are released. Raise an exception |