/third_party/python/Lib/ |
H A 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:
|
H A 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 281 # This method is called only if _lock doesn't have _is_owned(). 282 if self._lock.acquire(False): 283 self._lock [all...] |
H A D | webbrowser.py | 18 _lock = threading.RLock() variable 25 with _lock: 41 with _lock: 82 with _lock:
|
H A D | zipfile.py | 754 self._lock = lock 762 with self._lock: 772 with self._lock: 1299 self._lock = threading.RLock() 1569 self._fpclose, self._lock, lambda: self._writing) 1846 with self._lock: 1869 with self._lock: 1902 with self._lock:
|
/third_party/python/Lib/multiprocessing/ |
H A 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
|
H A 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 [all...] |
H A 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)
|
H A D | resource_sharer.py | 66 self._lock = threading.Lock() 74 with self._lock: 93 with self._lock: 115 self._lock._at_fork_reinit()
|
H A D | resource_tracker.py | 57 self._lock = threading.Lock() 62 with self._lock: 83 with self._lock:
|
H A D | heap.py | 125 self._lock = threading.Lock() 271 # that it's called while self._lock is held: in that case, 272 # self._lock.acquire() would deadlock (issue #12352). To avoid that, a 282 if not self._lock.acquire(False): 294 self._lock.release() 304 with self._lock:
|
H A D | forkserver.py | 39 self._lock = threading.Lock() 44 with self._lock: 112 with self._lock:
|
/third_party/python/Lib/test/test_asyncio/ |
H A D | test_pep492.py | 56 async with lock as _lock: 57 self.assertIs(_lock, None)
|
H A D | test_locks.py | 697 self.assertIs(cond._lock, lock)
|
/third_party/protobuf/python/google/protobuf/ |
H A 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/ |
H A 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")
|
H A D | _test_multiprocessing.py | 1729 (self._wrapper, self._lock) = state 1733 return (self._wrapper, self._lock) 1736 with self._lock: 1740 with self._lock: 3701 with heap._lock:
|
/third_party/skia/third_party/externals/libwebp/src/dsp/ |
H A 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/asyncio/ |
H A D | unix_events.py | 1127 self._lock = threading.Lock() 1137 with self._lock: 1143 with self._lock: 1159 with self._lock: 1193 with self._lock: 1443 with events._lock:
|
H A D | events.py | 705 _lock = threading.Lock() variable 752 with _lock:
|
H A D | locks.py | 233 self._lock = lock
|
/third_party/python/Lib/importlib/ |
H A 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/ |
H A D | __init__.py | 219 #_lock is used to serialize access to shared data structures in this module. 226 _lock = threading.RLock() variable 234 if _lock: 235 _lock.acquire() 241 if _lock: 242 _lock.release() 269 _lock._at_fork_reinit()
|
/third_party/python/Lib/unittest/ |
H A D | mock.py | 418 _lock = RLock() variable in NonCallableMock 662 with NonCallableMock._lock:
|
/third_party/rust/crates/bindgen/bindgen-tests/tests/ |
H A D | stylo.hpp | 2027 _IO_lock_t *_lock; [all...] |