Lines Matching defs:_BarrierState
439 class _BarrierState(enum.Enum):
463 self._state = _BarrierState.FILLING
512 _BarrierState.DRAINING, _BarrierState.RESETTING
517 if self._state is _BarrierState.BROKEN:
525 self._state = _BarrierState.DRAINING
534 await self._cond.wait_for(lambda: self._state is not _BarrierState.FILLING)
536 if self._state in (_BarrierState.BROKEN, _BarrierState.RESETTING):
543 if self._state in (_BarrierState.RESETTING, _BarrierState.DRAINING):
544 self._state = _BarrierState.FILLING
555 if self._state is not _BarrierState.RESETTING:
557 self._state = _BarrierState.RESETTING
559 self._state = _BarrierState.FILLING
569 self._state = _BarrierState.BROKEN
580 if self._state is _BarrierState.FILLING:
587 return self._state is _BarrierState.BROKEN