Home | History | Annotate | Download | only in multiprocessing

Lines Matching refs:_semlock

75         sl = self._semlock = _multiprocessing.SemLock(kind, value, maxvalue)
81 obj._semlock._after_fork()
85 self.acquire = self._semlock.acquire
86 self.release = self._semlock.release
89 return self._semlock.__enter__()
92 return self._semlock.__exit__(*args)
96 sl = self._semlock
100 self._semlock = _multiprocessing.SemLock._rebuild(*state)
114 return self._semlock._get_value()
118 value = self._semlock._get_value()
134 value = self._semlock._get_value()
138 (value, self._semlock.maxvalue)
151 if self._semlock._is_mine():
155 elif self._semlock._get_value() == 1:
157 elif self._semlock._count() > 0:
176 if self._semlock._is_mine():
180 count = self._semlock._count()
181 elif self._semlock._get_value() == 1:
183 elif self._semlock._count() > 0:
226 num_waiters = (self._sleeping_count._semlock._get_value() -
227 self._woken_count._semlock._get_value())
233 assert self._lock._semlock._is_mine(), \
240 count = self._lock._semlock._count()
256 assert self._lock._semlock._is_mine(), 'lock is not owned'
273 assert self._lock._semlock._is_mine(), 'lock is not owned'