| /external/python/cpython2/Python/ |
| D | thread_lwp.h | 9 struct lock { struct
63 struct lock *lock; in PyThread_allocate_lock() local
70 lock = (struct lock *) malloc(sizeof(struct lock)); in PyThread_allocate_lock()
71 lock->lock_locked = 0; in PyThread_allocate_lock()
72 (void) mon_create(&lock->lock_monitor); in PyThread_allocate_lock()
73 (void) cv_create(&lock->lock_condvar, lock->lock_monitor); in PyThread_allocate_lock()
74 dprintf(("PyThread_allocate_lock() -> %p\n", lock)); in PyThread_allocate_lock()
75 return (PyThread_type_lock) lock; in PyThread_allocate_lock()
78 void PyThread_free_lock(PyThread_type_lock lock) in PyThread_free_lock() argument
80 dprintf(("PyThread_free_lock(%p) called\n", lock)); in PyThread_free_lock()
[all …]
|
| D | thread_pthread.h | 259 sem_t *lock; in PyThread_allocate_lock() local
266 lock = (sem_t *)malloc(sizeof(sem_t)); in PyThread_allocate_lock()
268 if (lock) { in PyThread_allocate_lock()
269 status = sem_init(lock,0,1); in PyThread_allocate_lock()
273 free((void *)lock); in PyThread_allocate_lock()
274 lock = NULL; in PyThread_allocate_lock()
278 dprintf(("PyThread_allocate_lock() -> %p\n", lock)); in PyThread_allocate_lock()
279 return (PyThread_type_lock)lock; in PyThread_allocate_lock()
283 PyThread_free_lock(PyThread_type_lock lock) in PyThread_free_lock() argument
285 sem_t *thelock = (sem_t *)lock; in PyThread_free_lock()
[all …]
|
| D | thread_atheos.h | 156 fastmutex_t *lock; in PyThread_allocate_lock() local
166 lock = (fastmutex_t *) malloc(sizeof(fastmutex_t)); in PyThread_allocate_lock()
167 if (lock == NULL) { in PyThread_allocate_lock()
176 if (fastmutex_create(name, lock) < 0) { in PyThread_allocate_lock()
179 free(lock); in PyThread_allocate_lock()
180 lock = NULL; in PyThread_allocate_lock()
182 dprintf(("PyThread_allocate_lock()-> %p\n", lock)); in PyThread_allocate_lock()
183 return (PyThread_type_lock) lock; in PyThread_allocate_lock()
197 void PyThread_free_lock(PyThread_type_lock lock) in PyThread_free_lock() argument
199 dprintf(("PyThread_free_lock(%p) called\n", lock)); in PyThread_free_lock()
[all …]
|
| D | thread_cthread.h | 68 mutex_t lock; in PyThread_allocate_lock() local
74 lock = mutex_alloc(); in PyThread_allocate_lock()
75 if (mutex_init(lock)) { in PyThread_allocate_lock()
77 free((void *) lock); in PyThread_allocate_lock()
78 lock = 0; in PyThread_allocate_lock()
80 dprintf(("PyThread_allocate_lock() -> %p\n", lock)); in PyThread_allocate_lock()
81 return (PyThread_type_lock) lock; in PyThread_allocate_lock()
85 PyThread_free_lock(PyThread_type_lock lock) in PyThread_free_lock() argument
87 dprintf(("PyThread_free_lock(%p) called\n", lock)); in PyThread_free_lock()
88 mutex_free(lock); in PyThread_free_lock()
[all …]
|
| D | thread_solaris.h | 82 mutex_t *lock; in PyThread_allocate_lock() local
88 lock = (mutex_t *) malloc(sizeof(mutex_t)); in PyThread_allocate_lock()
89 if (mutex_init(lock, USYNC_THREAD, 0)) { in PyThread_allocate_lock()
91 free((void *) lock); in PyThread_allocate_lock()
92 lock = 0; in PyThread_allocate_lock()
94 dprintf(("PyThread_allocate_lock() -> %p\n", lock)); in PyThread_allocate_lock()
95 return (PyThread_type_lock) lock; in PyThread_allocate_lock()
99 PyThread_free_lock(PyThread_type_lock lock) in PyThread_free_lock() argument
101 dprintf(("PyThread_free_lock(%p) called\n", lock)); in PyThread_free_lock()
102 mutex_destroy((mutex_t *) lock); in PyThread_free_lock()
[all …]
|
| /external/libevent/ |
| D | evthread.c | 118 target->lock == cbs->lock && in evthread_set_lock_callbacks()
127 if (cbs->alloc && cbs->free && cbs->lock && cbs->unlock) { in evthread_set_lock_callbacks()
191 void *lock; member
201 if (!(result->lock = original_lock_fns_.alloc( in debug_lock_alloc()
207 result->lock = NULL; in debug_lock_alloc()
219 struct debug_lock *lock = lock_; in debug_lock_free() local
220 EVUTIL_ASSERT(lock->count == 0); in debug_lock_free()
221 EVUTIL_ASSERT(locktype == lock->locktype); in debug_lock_free()
222 EVUTIL_ASSERT(DEBUG_LOCK_SIG == lock->signature); in debug_lock_free()
224 original_lock_fns_.free(lock->lock, in debug_lock_free()
[all …]
|
| D | evthread-internal.h | 93 evthread_lock_fns_.lock(mode, lockvar); \
126 #define EVLOCK_ASSERT_LOCKED(lock) \ argument
128 if ((lock) && evthread_lock_debugging_enabled_) { \
129 EVUTIL_ASSERT(evthread_is_debug_lock_held_(lock)); \
135 static inline int EVLOCK_TRY_LOCK_(void *lock);
137 EVLOCK_TRY_LOCK_(void *lock) in EVLOCK_TRY_LOCK_() argument
139 if (lock && evthread_lock_fns_.lock) { in EVLOCK_TRY_LOCK_()
140 int r = evthread_lock_fns_.lock(EVTHREAD_TRY, lock); in EVLOCK_TRY_LOCK_()
171 #define EVTHREAD_COND_WAIT(cond, lock) \ argument
172 ( (cond) ? evthread_cond_fns_.wait_condition((cond), (lock), NULL) : 0 )
[all …]
|
| D | evthread_win32.c | 53 CRITICAL_SECTION *lock = mm_malloc(sizeof(CRITICAL_SECTION)); in evthread_win32_lock_create() local
54 if (!lock) in evthread_win32_lock_create()
56 if (InitializeCriticalSectionAndSpinCount(lock, SPIN_COUNT) == 0) { in evthread_win32_lock_create()
57 mm_free(lock); in evthread_win32_lock_create()
60 return lock; in evthread_win32_lock_create()
66 CRITICAL_SECTION *lock = lock_; in evthread_win32_lock_free() local
67 DeleteCriticalSection(lock); in evthread_win32_lock_free()
68 mm_free(lock); in evthread_win32_lock_free()
74 CRITICAL_SECTION *lock = lock_; in evthread_win32_lock() local
76 return ! TryEnterCriticalSection(lock); in evthread_win32_lock()
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | CycleDetectingLockFactoryTest.java | 102 lockA.lock(); in testDeadlock_twoLocks()
103 lockB.lock(); in testDeadlock_twoLocks()
109 lockB.lock(); in testDeadlock_twoLocks()
111 lockA.lock(); in testDeadlock_twoLocks()
120 lockA.lock(); in testDeadlock_twoLocks()
130 lockA.lock(); in testDeadlock_twoLocks()
136 lockA.lock(); in testDeadlock_threeLocks()
137 lockB.lock(); in testDeadlock_threeLocks()
142 lockB.lock(); in testDeadlock_threeLocks()
143 lockC.lock(); in testDeadlock_threeLocks()
[all …]
|
| /external/linux-kselftest/tools/testing/selftests/rcutorture/formal/srcu-cbmc/src/ |
| D | locks.h | 26 static inline void lock_impl_lock(struct lock_impl *lock) in lock_impl_lock() argument
28 BUG_ON(pthread_mutex_lock(&lock->mutex)); in lock_impl_lock()
31 static inline void lock_impl_unlock(struct lock_impl *lock) in lock_impl_unlock() argument
33 BUG_ON(pthread_mutex_unlock(&lock->mutex)); in lock_impl_unlock()
36 static inline bool lock_impl_trylock(struct lock_impl *lock) in lock_impl_trylock() argument
38 int err = pthread_mutex_trylock(&lock->mutex); in lock_impl_trylock()
47 static inline void lock_impl_init(struct lock_impl *lock) in lock_impl_init() argument
49 pthread_mutex_init(&lock->mutex, NULL); in lock_impl_init()
61 static inline bool lock_impl_trylock(struct lock_impl *lock) in lock_impl_trylock() argument
65 return __sync_bool_compare_and_swap(&lock->locked, false, true); in lock_impl_trylock()
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Monitor.java | 305 this.condition = monitor.lock.newCondition(); in Guard()
325 private final ReentrantLock lock; field in Monitor
350 this.lock = new ReentrantLock(fair); in Monitor()
357 lock.lock(); in enter()
364 lock.lockInterruptibly(); in enterInterruptibly()
374 final ReentrantLock lock = this.lock; in enter() local
375 if (!fair && lock.tryLock()) { in enter()
383 return lock.tryLock(timeoutNanos, TimeUnit.NANOSECONDS); in enter()
402 return lock.tryLock(time, unit); in enterInterruptibly()
413 return lock.tryLock(); in tryEnter()
[all …]
|
| /external/valgrind/helgrind/ |
| D | hg_lock_n_thread.c | 65 static Bool is_sane_Lock_BASE ( Lock* lock ) in is_sane_Lock_BASE() argument
67 if (lock == NULL in is_sane_Lock_BASE()
68 || (lock->magic != LockN_MAGIC && lock->magic != LockP_MAGIC)) in is_sane_Lock_BASE()
70 switch (lock->kind) { in is_sane_Lock_BASE()
74 if (lock->heldBy == NULL) { in is_sane_Lock_BASE()
75 if (lock->acquired_at != NULL) return False; in is_sane_Lock_BASE()
77 return !lock->heldW; in is_sane_Lock_BASE()
79 if (lock->acquired_at == NULL) return False; in is_sane_Lock_BASE()
84 if (VG_(isEmptyBag)(lock->heldBy)) in is_sane_Lock_BASE()
88 if (!is_sane_Bag_of_Threads(lock->heldBy)) in is_sane_Lock_BASE()
[all …]
|
| /external/fio/ |
| D | mutex.c | 118 ret = mutex_cond_init_pshared(&mutex->lock, &mutex->cond); in __fio_mutex_init()
171 pthread_mutex_lock(&mutex->lock); in fio_mutex_down_timeout()
179 ret = pthread_cond_timedwait(&mutex->cond, &mutex->lock, &t); in fio_mutex_down_timeout()
187 pthread_mutex_unlock(&mutex->lock); in fio_mutex_down_timeout()
191 pthread_mutex_unlock(&mutex->lock); in fio_mutex_down_timeout()
201 pthread_mutex_lock(&mutex->lock); in fio_mutex_down_trylock()
206 pthread_mutex_unlock(&mutex->lock); in fio_mutex_down_trylock()
215 pthread_mutex_lock(&mutex->lock); in fio_mutex_down()
219 pthread_cond_wait(&mutex->cond, &mutex->lock); in fio_mutex_down()
224 pthread_mutex_unlock(&mutex->lock); in fio_mutex_down()
[all …]
|
| /external/sfntly/cpp/src/test/ |
| D | lock_test.cc | 29 BasicLockTestThread(Lock* lock) : lock_(lock), acquired_(0) {} in BasicLockTestThread() argument
62 Lock lock; in BasicLockTest() local
63 BasicLockTestThread thread(&lock); in BasicLockTest()
70 lock.Acquire(); in BasicLockTest()
72 lock.Unlock(); in BasicLockTest()
75 lock.Acquire(); in BasicLockTest()
78 lock.Unlock(); in BasicLockTest()
81 if (lock.Try()) { in BasicLockTest()
84 lock.Unlock(); in BasicLockTest()
88 lock.Acquire(); in BasicLockTest()
[all …]
|
| /external/libchrome/base/synchronization/ |
| D | lock_unittest.cc | 20 explicit BasicLockTestThread(Lock* lock) : lock_(lock), acquired_(0) {} in BasicLockTestThread() argument
53 Lock lock; in TEST() local
54 BasicLockTestThread thread(&lock); in TEST()
61 lock.Acquire(); in TEST()
63 lock.Release(); in TEST()
66 lock.Acquire(); in TEST()
69 lock.Release(); in TEST()
72 if (lock.Try()) { in TEST()
75 lock.Release(); in TEST()
79 lock.Acquire(); in TEST()
[all …]
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowPowerManagerTest.java | 32 PowerManager.WakeLock lock = powerManager.newWakeLock(0, "TAG"); in acquire_shouldAcquireAndReleaseReferenceCountedLock() local
33 assertThat(lock.isHeld()).isFalse(); in acquire_shouldAcquireAndReleaseReferenceCountedLock()
34 lock.acquire(); in acquire_shouldAcquireAndReleaseReferenceCountedLock()
35 assertThat(lock.isHeld()).isTrue(); in acquire_shouldAcquireAndReleaseReferenceCountedLock()
36 lock.acquire(); in acquire_shouldAcquireAndReleaseReferenceCountedLock()
38 assertThat(lock.isHeld()).isTrue(); in acquire_shouldAcquireAndReleaseReferenceCountedLock()
39 lock.release(); in acquire_shouldAcquireAndReleaseReferenceCountedLock()
41 assertThat(lock.isHeld()).isTrue(); in acquire_shouldAcquireAndReleaseReferenceCountedLock()
42 lock.release(); in acquire_shouldAcquireAndReleaseReferenceCountedLock()
43 assertThat(lock.isHeld()).isFalse(); in acquire_shouldAcquireAndReleaseReferenceCountedLock()
[all …]
|
| /external/python/cpython2/Lib/test/ |
| D | lock_tests.py | 76 lock = self.locktype()
77 del lock
80 lock = self.locktype()
81 lock.acquire()
82 del lock
85 lock = self.locktype()
86 lock.acquire()
87 lock.release()
88 del lock
91 lock = self.locktype()
[all …]
|
| /external/androidplot/AndroidPlot-Core/src/main/java/com/androidplot/xy/ |
| D | SimpleXYSeries.java | 40 lock.readLock().lock(); in onBeforeDraw()
45 lock.readLock().unlock(); in onAfterDraw()
56 private ReentrantReadWriteLock lock = new ReentrantReadWriteLock(true); field in SimpleXYSeries
95 lock.writeLock().lock(); in useImplicitXVals()
99 lock.writeLock().unlock(); in useImplicitXVals()
111 lock.writeLock().lock(); in setModel()
155 lock.writeLock().unlock(); in setModel()
165 lock.writeLock().lock(); in setX()
169 lock.writeLock().unlock(); in setX()
179 lock.writeLock().lock(); in setY()
[all …]
|
| /external/llvm/test/CodeGen/X86/ |
| D | atomic8.ll | 12 ; X64: lock
14 ; X32: lock
17 ; X64: lock
19 ; X32: lock
22 ; X64: lock
24 ; X32: lock
27 ; X64: lock
29 ; X32: lock
40 ; X64: lock
42 ; X32: lock
[all …]
|
| D | atomic16.ll | 12 ; X64: lock
14 ; X32: lock
17 ; X64: lock
19 ; X32: lock
22 ; X64: lock
24 ; X32: lock
27 ; X64: lock
29 ; X32: lock
40 ; X64: lock
42 ; X32: lock
[all …]
|
| /external/python/cpython3/Lib/test/ |
| D | lock_tests.py | 85 lock = self.locktype()
86 del lock
89 lock = self.locktype()
90 self.assertRegex(repr(lock), "<unlocked .* object (.*)?at .*>")
91 del lock
94 lock = self.locktype()
95 lock.acquire()
96 self.assertRegex(repr(lock), "<locked .* object (.*)?at .*>")
97 del lock
100 lock = self.locktype()
[all …]
|
| /external/boringssl/src/crypto/ |
| D | thread_pthread.c | 30 void CRYPTO_MUTEX_init(CRYPTO_MUTEX *lock) { in CRYPTO_MUTEX_init() argument
31 if (pthread_rwlock_init((pthread_rwlock_t *) lock, NULL) != 0) { in CRYPTO_MUTEX_init()
36 void CRYPTO_MUTEX_lock_read(CRYPTO_MUTEX *lock) { in CRYPTO_MUTEX_lock_read() argument
37 if (pthread_rwlock_rdlock((pthread_rwlock_t *) lock) != 0) { in CRYPTO_MUTEX_lock_read()
42 void CRYPTO_MUTEX_lock_write(CRYPTO_MUTEX *lock) { in CRYPTO_MUTEX_lock_write() argument
43 if (pthread_rwlock_wrlock((pthread_rwlock_t *) lock) != 0) { in CRYPTO_MUTEX_lock_write()
48 void CRYPTO_MUTEX_unlock_read(CRYPTO_MUTEX *lock) { in CRYPTO_MUTEX_unlock_read() argument
49 if (pthread_rwlock_unlock((pthread_rwlock_t *) lock) != 0) { in CRYPTO_MUTEX_unlock_read()
54 void CRYPTO_MUTEX_unlock_write(CRYPTO_MUTEX *lock) { in CRYPTO_MUTEX_unlock_write() argument
55 if (pthread_rwlock_unlock((pthread_rwlock_t *) lock) != 0) { in CRYPTO_MUTEX_unlock_write()
[all …]
|
| /external/robolectric/v1/src/test/java/com/xtremelabs/robolectric/shadows/ |
| D | PowerManagerTest.java | 42 PowerManager.WakeLock lock = powerManager.newWakeLock(0, "TAG"); in shouldAcquireAndReleaseReferenceCountedLock() local
43 assertFalse(lock.isHeld()); in shouldAcquireAndReleaseReferenceCountedLock()
44 lock.acquire(); in shouldAcquireAndReleaseReferenceCountedLock()
45 assertTrue(lock.isHeld()); in shouldAcquireAndReleaseReferenceCountedLock()
46 lock.acquire(); in shouldAcquireAndReleaseReferenceCountedLock()
48 assertTrue(lock.isHeld()); in shouldAcquireAndReleaseReferenceCountedLock()
49 lock.release(); in shouldAcquireAndReleaseReferenceCountedLock()
51 assertTrue(lock.isHeld()); in shouldAcquireAndReleaseReferenceCountedLock()
52 lock.release(); in shouldAcquireAndReleaseReferenceCountedLock()
53 assertFalse(lock.isHeld()); in shouldAcquireAndReleaseReferenceCountedLock()
[all …]
|
| /external/python/cpython3/Python/ |
| D | thread_pthread.h | 278 sem_t *lock; in PyThread_allocate_lock() local
285 lock = (sem_t *)PyMem_RawMalloc(sizeof(sem_t)); in PyThread_allocate_lock()
287 if (lock) { in PyThread_allocate_lock()
288 status = sem_init(lock,0,1); in PyThread_allocate_lock()
292 PyMem_RawFree((void *)lock); in PyThread_allocate_lock()
293 lock = NULL; in PyThread_allocate_lock()
297 dprintf(("PyThread_allocate_lock() -> %p\n", lock)); in PyThread_allocate_lock()
298 return (PyThread_type_lock)lock; in PyThread_allocate_lock()
302 PyThread_free_lock(PyThread_type_lock lock) in PyThread_free_lock() argument
304 sem_t *thelock = (sem_t *)lock; in PyThread_free_lock()
[all …]
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/ |
| D | posix_event.hpp | 43 void signal(Lock& lock) in signal() argument
45 this->signal_all(lock); in signal()
50 void signal_all(Lock& lock) in signal_all() argument
52 ASIO_ASSERT(lock.locked()); in signal_all()
53 (void)lock; in signal_all()
60 void unlock_and_signal_one(Lock& lock) in unlock_and_signal_one() argument
62 ASIO_ASSERT(lock.locked()); in unlock_and_signal_one()
65 lock.unlock(); in unlock_and_signal_one()
72 bool maybe_unlock_and_signal_one(Lock& lock) in maybe_unlock_and_signal_one() argument
74 ASIO_ASSERT(lock.locked()); in maybe_unlock_and_signal_one()
[all …]
|