| /external/llvm-project/libunwind/src/ |
| D | RWMutex.hpp | 42 AcquireSRWLockShared(&_lock);
46 ReleaseSRWLockShared(&_lock);
50 AcquireSRWLockExclusive(&_lock);
54 ReleaseSRWLockExclusive(&_lock);
59 SRWLOCK _lock = SRWLOCK_INIT;
66 bool lock_shared() { return pthread_rwlock_rdlock(&_lock) == 0; }
67 bool unlock_shared() { return pthread_rwlock_unlock(&_lock) == 0; }
68 bool lock() { return pthread_rwlock_wrlock(&_lock) == 0; }
69 bool unlock() { return pthread_rwlock_unlock(&_lock) == 0; }
72 pthread_rwlock_t _lock = PTHREAD_RWLOCK_INITIALIZER;
[all …]
|
| /external/python/cpython3/Lib/ |
| D | bz2.py | 58 self._lock = RLock()
107 with self._lock:
156 with self._lock:
169 with self._lock:
180 with self._lock:
191 with self._lock:
206 with self._lock:
221 with self._lock:
232 with self._lock:
247 with self._lock:
[all …]
|
| D | sched.py | 61 self._lock = threading.RLock()
75 with self._lock:
95 with self._lock:
101 with self._lock:
130 lock = self._lock
165 with self._lock:
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | synchronize.py | 198 self._lock = lock or RLock()
206 return (self._lock, self._sleeping_count,
210 (self._lock, self._sleeping_count,
215 return self._lock.__enter__()
218 return self._lock.__exit__(*args)
221 self.acquire = self._lock.acquire
222 self.release = self._lock.release
230 return '<Condition(%s, %s)>' % (self._lock, num_waiters)
233 assert self._lock._semlock._is_mine(), \
240 count = self._lock._semlock._count()
[all …]
|
| D | sharedctypes.py | 213 self._lock = lock or RLock()
214 self.acquire = self._lock.acquire
215 self.release = self._lock.release
219 return synchronized, (self._obj, self._lock)
225 return self._lock
|
| D | heap.py | 96 self._lock = threading.Lock()
201 if not self._lock.acquire(False):
212 self._lock.release()
219 self._lock.acquire()
231 self._lock.release()
|
| D | reduction.py | 92 global _lock, _listener, _cache
96 _lock = threading.Lock()
106 _lock.acquire()
115 _lock.release()
|
| /external/arm-trusted-firmware/plat/brcm/board/stingray/src/ |
| D | brcm_pm_ops.c | 41 #define event_lock_get(_lock) spin_lock(&_lock) argument
42 #define event_lock_release(_lock) spin_unlock(&_lock) argument
50 #define event_lock_get(_lock) bakery_lock_get(&_lock) argument
51 #define event_lock_release(_lock) bakery_lock_release(&_lock) argument
|
| /external/python/cpython3/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()
|
| /external/toolchain-utils/crosperf/ |
| D | image_checksummer.py | 24 self._lock = threading.Lock()
30 with self._lock:
49 _lock = threading.Lock() variable in ImageChecksummer
53 with cls._lock:
62 with self._lock:
|
| /external/tensorflow/tensorflow/python/training/ |
| D | coordinator.py | 146 self._lock = threading.Lock()
201 with self._lock:
251 with self._lock:
319 with self._lock:
353 with self._lock:
385 with self._lock:
405 with self._lock:
|
| /external/autotest/server/hosts/ |
| D | ssh_multiplex.py | 45 self._lock = multiprocessing.Lock()
79 with self._lock:
123 with self._lock:
144 self._lock = threading.Lock()
162 with self._lock:
|
| D | file_store.py | 41 self._lock = locking.FileLock(
104 functor=self._lock.write_lock,
111 with self._lock:
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _thread_pool.py | 24 self._lock = threading.Lock()
28 with self._lock:
33 with self._lock:
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/qps/ |
| D | histogram.py | 28 self._lock = threading.Lock()
40 with self._lock:
49 with self._lock:
58 with self._lock:
|
| /external/tensorflow/tensorflow/python/summary/writer/ |
| D | writer_cache.py | 38 _lock = threading.RLock() variable in FileWriterCache
43 with FileWriterCache._lock:
60 with FileWriterCache._lock:
|
| /external/grpc-grpc/src/python/grpcio/grpc/framework/foundation/ |
| D | stream_util.py | 89 self._lock = threading.Lock()
110 with self._lock:
125 with self._lock:
134 with self._lock:
142 with self._lock:
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/framework/foundation/ |
| D | _logging_pool_test.py | 27 self._lock = threading.Lock()
31 with self._lock:
35 with self._lock:
|
| /external/rust/crates/crossbeam-utils/tests/ |
| D | sharded_lock.rs | 55 let _lock = arc2.write().unwrap(); in arc_poison_wr() localVariable
70 let _lock = arc2.write().unwrap(); in arc_poison_ww() localVariable
85 let _lock = arc2.read().unwrap(); in arc_no_poison_rr() localVariable
99 let _lock = arc2.read().unwrap(); in arc_no_poison_sl() localVariable
227 let _lock = m2.write().unwrap(); in test_into_inner_poison() localVariable
253 let _lock = m2.write().unwrap(); in test_get_mut_poison() localVariable
|
| /external/tensorflow/tensorflow/python/util/ |
| D | lock_util.py | 124 self._lock = lock
128 self._lock.acquire(self._group_id)
132 self._lock.release(self._group_id)
|
| /external/autotest/client/site_tests/platform_PrinterPpds/ |
| D | archiver.py | 89 self._lock = threading.Lock()
122 with self._lock:
171 with self._lock:
190 with self._lock:
|
| /external/python/cffi/cffi/ |
| D | api.py | 67 self._lock = allocate_lock()
87 with self._lock:
124 with self._lock:
145 with self._lock:
181 with self._lock:
205 with self._lock:
430 assert self._lock.acquire(False) is False
482 with self._lock:
528 with ffi_to_include._lock:
529 with self._lock:
[all …]
|
| /external/autotest/site_utils/rpm_control_system/ |
| D | frontend_server.py | 92 self._lock = threading.Lock()
240 with self._lock:
275 with self._lock:
308 with self._lock:
330 with self._lock:
|