

def notify_all(self):
    assert self._lock._semlock._is_mine(), 'lock is not owned'
    assert (not self._wait_semaphore.acquire(False))
    while self._woken_count.acquire(False):
        res = self._sleeping_count.acquire(False)
        assert res
    sleepers = 0
    while self._sleeping_count.acquire(False):
        self._wait_semaphore.release()
        sleepers += 1
    if sleepers:
        for i in xrange(sleepers):
            i._woken_count.acquire()
        while self._wait_semaphore.acquire(False):
            pass

dataset/ETHPy150Open deanhiller/databus/webapp/play1.3.x/python/Lib/multiprocessing/synchronize.py Condition.notify_all/VarMisuse@107/149 `self`->`i`