| /third_party/python/Lib/multiprocessing/ |
| D | synchronize.py | 213 self._lock = lock or ctx.RLock()
221 return (self._lock, self._sleeping_count,
225 (self._lock, self._sleeping_count,
230 return self._lock.__enter__()
233 return self._lock.__exit__(*args)
236 self.acquire = self._lock.acquire
237 self.release = self._lock.release
245 return '<%s(%s, %s)>' % (self.__class__.__name__, self._lock, num_waiters)
248 assert self._lock._semlock._is_mine(), \
255 count = self._lock._semlock._count()
[all …]
|
| D | sharedctypes.py | 185 self._lock = lock
188 self._lock = ctx.RLock()
189 self.acquire = self._lock.acquire
190 self.release = self._lock.release
193 return self._lock.__enter__()
196 return self._lock.__exit__(*args)
200 return synchronized, (self._obj, self._lock)
206 return self._lock
|
| D | resource_sharer.py | 66 self._lock = threading.Lock()
74 with self._lock:
93 with self._lock:
115 self._lock._at_fork_reinit()
|
| D | util.py | 370 self._lock = threading.Lock()
371 self.acquire = self._lock.acquire
372 self.release = self._lock.release
376 self._lock._at_fork_reinit()
379 return self._lock.__enter__()
382 return self._lock.__exit__(*args)
|
| D | resource_tracker.py | 57 self._lock = threading.Lock()
62 with self._lock:
83 with self._lock:
|
| D | heap.py | 125 self._lock = threading.Lock()
282 if not self._lock.acquire(False):
294 self._lock.release()
304 with self._lock:
|
| D | forkserver.py | 39 self._lock = threading.Lock()
44 with self._lock:
112 with self._lock:
|
| /third_party/python/Lib/ |
| D | sched.py | 57 self._lock = threading.RLock()
72 with self._lock:
94 with self._lock:
100 with self._lock:
129 lock = self._lock
165 with self._lock:
|
| D | threading.py | 239 self._lock = lock
261 self._lock._at_fork_reinit()
265 return self._lock.__enter__()
268 return self._lock.__exit__(*args)
271 return "<Condition(%s, %d)>" % (self._lock, len(self._waiters))
274 self._lock.release() # No state to save
277 self._lock.acquire() # Ignore saved state
282 if self._lock.acquire(False):
283 self._lock.release()
|
| D | webbrowser.py | 17 _lock = threading.RLock() variable
24 with _lock:
40 with _lock:
81 with _lock:
|
| D | zipfile.py | 723 self._lock = lock
729 with self._lock:
739 with self._lock:
1254 self._lock = threading.RLock()
1524 self._fpclose, self._lock, lambda: self._writing)
1758 with self._lock:
1814 with self._lock:
1835 with self._lock:
|
| /third_party/protobuf/python/google/protobuf/ |
| D | descriptor.py | 82 self._lock = threading.Lock() # pylint: disable=protected-access
86 self._lock.acquire()
89 self._lock.release()
92 _lock = threading.Lock() variable
175 with _lock:
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_pep492.py | 56 async with lock as _lock:
57 self.assertIs(_lock, None)
|
| D | test_locks.py | 704 self.assertIs(cond._lock, lock)
|
| /third_party/skia/third_party/externals/libwebp/src/dsp/ |
| D | dsp.h | 177 static pthread_mutex_t func ## _lock = PTHREAD_MUTEX_INITIALIZER; \
178 if (pthread_mutex_lock(&func ## _lock)) break; \
181 (void)pthread_mutex_unlock(&func ## _lock); \
|
| /third_party/python/Lib/test/ |
| D | _test_eintr.py | 489 def _lock(self, lock_func, lock_name): member in FNTLEINTRTest
523 self._lock(fcntl.lockf, "lockf")
526 self._lock(fcntl.flock, "flock")
|
| D | _test_multiprocessing.py | 1666 (self._wrapper, self._lock) = state
1670 return (self._wrapper, self._lock)
1673 with self._lock:
1677 with self._lock:
3628 with heap._lock:
|
| /third_party/python/Lib/asyncio/ |
| D | unix_events.py | 1108 self._lock = threading.Lock()
1118 with self._lock:
1124 with self._lock:
1140 with self._lock:
1174 with self._lock:
1424 with events._lock:
|
| D | events.py | 683 _lock = threading.Lock() variable
730 with _lock:
|
| D | locks.py | 234 self._lock = lock
|
| /third_party/python/Lib/importlib/ |
| D | _bootstrap.py | 167 self._lock = None
170 self._lock = _get_module_lock(self._name)
171 self._lock.acquire()
174 self._lock.release()
|
| /third_party/python/Lib/logging/ |
| D | __init__.py | 217 _lock = threading.RLock() variable
225 if _lock:
226 _lock.acquire()
232 if _lock:
233 _lock.release()
260 _lock._at_fork_reinit()
|
| /third_party/libunwind/libunwind/tests/ |
| D | check-namespace.sh.in | 176 match ${plat}_lock
290 match ${plat}_lock
|
| D | check-namespace.sh | 182 match ${plat}_lock
298 match ${plat}_lock
|
| /third_party/elfutils/tests/ |
| D | run-show-die-info.sh | 671 Name : _lock
|