def notifyAll(self): # pylint: disable=C0103
    self._check_owned()
    self._single_condition.notifyAll()
    self._single_condition = self._single_condition_class(self._lock)
Notify all currently waiting threads.
dataset/ETHPy150Open ganeti/ganeti/lib/locking.py/PipeCondition.notifyAll