| /external/guava/guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ |
| D | Synchronized.java | 59 final Object mutex; field in Synchronized.SynchronizedObject
61 SynchronizedObject(Object delegate, @Nullable Object mutex) { in SynchronizedObject() argument
63 this.mutex = (mutex == null) ? this : mutex; in SynchronizedObject()
73 synchronized (mutex) { in toString()
85 Collection<E> collection, @Nullable Object mutex) { in collection() argument
86 return new SynchronizedCollection<E>(collection, mutex); in collection()
92 Collection<E> delegate, @Nullable Object mutex) { in SynchronizedCollection() argument
93 super(delegate, mutex); in SynchronizedCollection()
103 synchronized (mutex) { in add()
110 synchronized (mutex) { in addAll()
[all …]
|
| /external/guava/guava/src/com/google/common/collect/ |
| D | Synchronized.java | 65 final Object mutex; field in Synchronized.SynchronizedObject
67 SynchronizedObject(Object delegate, @Nullable Object mutex) { in SynchronizedObject() argument
69 this.mutex = (mutex == null) ? this : mutex; in SynchronizedObject()
79 synchronized (mutex) { in toString()
91 synchronized (mutex) { in writeObject()
101 Collection<E> collection, @Nullable Object mutex) { in collection() argument
102 return new SynchronizedCollection<E>(collection, mutex); in collection()
108 Collection<E> delegate, @Nullable Object mutex) { in SynchronizedCollection() argument
109 super(delegate, mutex); in SynchronizedCollection()
119 synchronized (mutex) { in add()
[all …]
|
| /external/fio/ |
| D | mutex.c | 21 void __fio_mutex_remove(struct fio_mutex *mutex) in __fio_mutex_remove() argument
23 assert(mutex->magic == FIO_MUTEX_MAGIC); in __fio_mutex_remove()
24 pthread_cond_destroy(&mutex->cond); in __fio_mutex_remove()
27 void fio_mutex_remove(struct fio_mutex *mutex) in fio_mutex_remove() argument
29 __fio_mutex_remove(mutex); in fio_mutex_remove()
30 munmap((void *) mutex, sizeof(*mutex)); in fio_mutex_remove()
33 int __fio_mutex_init(struct fio_mutex *mutex, int value) in __fio_mutex_init() argument
39 mutex->value = value; in __fio_mutex_init()
40 mutex->magic = FIO_MUTEX_MAGIC; in __fio_mutex_init()
63 pthread_cond_init(&mutex->cond, &cond); in __fio_mutex_init()
[all …]
|
| /external/valgrind/drd/ |
| D | drd_qtcore_intercepts.c | 87 void* mutex, in QT4CORE_FUNC() argument
94 mutex, qt_to_drd_mutex_type(mode), 0, 0, 0); in QT4CORE_FUNC()
95 CALL_FN_W_WW(ret, fn, mutex, mode); in QT4CORE_FUNC()
97 mutex, 0, 0, 0, 0); in QT4CORE_FUNC()
102 void* mutex, in QT4CORE_FUNC() argument
109 mutex, qt_to_drd_mutex_type(mode), 0, 0, 0); in QT4CORE_FUNC()
110 CALL_FN_W_WW(ret, fn, mutex, mode); in QT4CORE_FUNC()
112 mutex, 0, 0, 0, 0); in QT4CORE_FUNC()
117 void* mutex) in QT4CORE_FUNC() argument
123 mutex, 0, 0, 0, 0); in QT4CORE_FUNC()
[all …]
|
| D | drd_mutex.c | 69 const Addr mutex, const MutexT mutex_type) in DRD_()
71 tl_assert(mutex); in DRD_()
72 tl_assert(p->a1 == mutex); in DRD_()
86 void DRD_(mutex_ignore_ordering)(const Addr mutex) in DRD_()
88 struct mutex_info* p = DRD_(mutex_get)(mutex); in DRD_()
94 mutex); in DRD_()
99 DRD_(not_a_mutex)(mutex); in DRD_()
131 void DRD_(not_a_mutex)(const Addr mutex) in DRD_()
134 mutex, -1, DRD_INVALID_THREADID }; in DRD_()
146 static void wrong_mutex_type(const Addr mutex) in wrong_mutex_type() argument
[all …]
|
| D | drd_pthread_intercepts.c | 213 pthread_mutex_t mutex; member
265 static __always_inline void DRD_(ignore_mutex_ordering)(pthread_mutex_t *mutex) in DRD_()
268 mutex, 0, 0, 0, 0); in DRD_()
274 pthread_mutex_init(&sema->mutex, NULL); in DRD_()
275 DRD_(ignore_mutex_ordering)(&sema->mutex); in DRD_()
282 pthread_mutex_destroy(&sema->mutex); in DRD_()
288 pthread_mutex_lock(&sema->mutex); in DRD_()
290 pthread_cond_wait(&sema->cond, &sema->mutex); in DRD_()
292 pthread_mutex_unlock(&sema->mutex); in DRD_()
297 pthread_mutex_lock(&sema->mutex); in DRD_()
[all …]
|
| /external/mesa3d/src/gallium/auxiliary/os/ |
| D | os_thread.h | 87 #define pipe_static_mutex(mutex) \ argument
88 static pipe_mutex mutex = PTHREAD_MUTEX_INITIALIZER
90 #define pipe_mutex_init(mutex) \ argument
91 (void) pthread_mutex_init(&(mutex), NULL)
93 #define pipe_mutex_destroy(mutex) \ argument
94 pthread_mutex_destroy(&(mutex))
96 #define pipe_mutex_lock(mutex) \ argument
97 (void) pthread_mutex_lock(&(mutex))
99 #define pipe_mutex_unlock(mutex) \ argument
100 (void) pthread_mutex_unlock(&(mutex))
[all …]
|
| /external/valgrind/none/tests/ |
| D | pth_cvsimple.stdout.exp | 1 inc_counter(): count = 1, unlocking mutex
2 inc_counter(): count = 2, unlocking mutex
3 inc_counter(): count = 3, unlocking mutex
4 inc_counter(): count = 4, unlocking mutex
5 inc_counter(): count = 5, unlocking mutex
6 inc_counter(): count = 6, unlocking mutex
7 inc_counter(): count = 7, unlocking mutex
8 inc_counter(): count = 8, unlocking mutex
9 inc_counter(): count = 9, unlocking mutex
10 inc_counter(): count = 10, unlocking mutex
[all …]
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | SynchronizedDequeTest.java | 34 Deque<String> outer = Synchronized.deque(inner, inner.mutex); in create()
41 public final Object mutex = new Integer(1); // something Serializable field in SynchronizedDequeTest.TestDeque
45 assertTrue(Thread.holdsLock(mutex)); in offer()
51 assertTrue(Thread.holdsLock(mutex)); in poll()
57 assertTrue(Thread.holdsLock(mutex)); in remove()
63 assertTrue(Thread.holdsLock(mutex)); in peek()
69 assertTrue(Thread.holdsLock(mutex)); in element()
76 assertFalse(Thread.holdsLock(mutex)); in iterator()
82 assertTrue(Thread.holdsLock(mutex)); in size()
88 assertTrue(Thread.holdsLock(mutex)); in removeAll()
[all …]
|
| D | SynchronizedNavigableMapTest.java | 49 TestMap<K, V> inner = new TestMap<K, V>(innermost, mutex); in create()
50 NavigableMap<K, V> outer = Synchronized.navigableMap(inner, mutex); in create()
57 private final Object mutex; field in SynchronizedNavigableMapTest.TestEntry
59 TestEntry(Entry<K, V> delegate, Object mutex) { in TestEntry() argument
61 this.mutex = mutex; in TestEntry()
69 assertTrue(Thread.holdsLock(mutex)); in equals()
74 assertTrue(Thread.holdsLock(mutex)); in getKey()
79 assertTrue(Thread.holdsLock(mutex)); in getValue()
84 assertTrue(Thread.holdsLock(mutex)); in hashCode()
89 assertTrue(Thread.holdsLock(mutex)); in setValue()
[all …]
|
| D | SynchronizedMapTest.java | 39 public final Object mutex = new Integer(1); // something Serializable field in SynchronizedMapTest
42 TestMap<K, V> inner = new TestMap<K, V>(new HashMap<K, V>(), mutex); in create()
43 Map<K, V> outer = Synchronized.map(inner, mutex); in create()
49 public final Object mutex; field in SynchronizedMapTest.TestMap
51 public TestMap(Map<K, V> delegate, Object mutex) { in TestMap() argument
52 checkNotNull(mutex); in TestMap()
54 this.mutex = mutex; in TestMap()
62 assertTrue(Thread.holdsLock(mutex)); in size()
67 assertTrue(Thread.holdsLock(mutex)); in isEmpty()
72 assertTrue(Thread.holdsLock(mutex)); in remove()
[all …]
|
| D | SynchronizedSetTest.java | 51 Set<String> outer = Synchronized.set(inner, inner.mutex); in suite()
66 public final Object mutex;
68 public TestSet(Set<E> delegate, Object mutex) {
69 checkNotNull(mutex);
71 this.mutex = mutex;
79 assertTrue(Thread.holdsLock(mutex));
84 assertTrue(Thread.holdsLock(mutex));
89 assertTrue(Thread.holdsLock(mutex));
94 assertTrue(Thread.holdsLock(mutex));
99 assertTrue(Thread.holdsLock(mutex));
[all …]
|
| D | SynchronizedQueueTest.java | 34 Queue<String> outer = Synchronized.queue(inner, inner.mutex); in create()
41 public final Object mutex = new Integer(1); // something Serializable field in SynchronizedQueueTest.TestQueue
45 assertTrue(Thread.holdsLock(mutex)); in offer()
51 assertTrue(Thread.holdsLock(mutex)); in poll()
57 assertTrue(Thread.holdsLock(mutex)); in remove()
63 assertTrue(Thread.holdsLock(mutex)); in peek()
69 assertTrue(Thread.holdsLock(mutex)); in element()
76 assertFalse(Thread.holdsLock(mutex)); in iterator()
82 assertTrue(Thread.holdsLock(mutex)); in size()
88 assertTrue(Thread.holdsLock(mutex)); in removeAll()
[all …]
|
| /external/deqp/framework/delibs/dethread/unix/ |
| D | deMutexUnix.c | 40 pthread_mutex_t* mutex = deMalloc(sizeof(pthread_mutex_t)); in deMutex_create() local
42 if (!mutex) in deMutex_create()
47 deFree(mutex); in deMutex_create()
58 deFree(mutex); in deMutex_create()
69 deFree(mutex); in deMutex_create()
75 ret = pthread_mutex_init(mutex, &attr); in deMutex_create()
79 deFree(mutex); in deMutex_create()
85 return (deMutex)mutex; in deMutex_create()
88 void deMutex_destroy (deMutex mutex) in deMutex_destroy() argument
90 pthread_mutex_t* pMutex = (pthread_mutex_t*)mutex; in deMutex_destroy()
[all …]
|
| /external/deqp/framework/delibs/dethread/win32/ |
| D | deMutexWin32.c | 65 void deMutex_destroy (deMutex mutex) in deMutex_destroy() argument
67 DeleteCriticalSection((CRITICAL_SECTION*)mutex); in deMutex_destroy()
68 deFree((CRITICAL_SECTION*)mutex); in deMutex_destroy()
71 void deMutex_lock (deMutex mutex) in deMutex_lock() argument
73 EnterCriticalSection((CRITICAL_SECTION*)mutex); in deMutex_lock()
76 void deMutex_unlock (deMutex mutex) in deMutex_unlock() argument
78 LeaveCriticalSection((CRITICAL_SECTION*)mutex); in deMutex_unlock()
81 deBool deMutex_tryLock (deMutex mutex) in deMutex_tryLock() argument
83 return TryEnterCriticalSection((CRITICAL_SECTION*)mutex) == TRUE; in deMutex_tryLock()
101 void deMutex_destroy (deMutex mutex) in deMutex_destroy() argument
[all …]
|
| /external/jemalloc/include/jemalloc/internal/ |
| D | mutex.h | 55 bool malloc_mutex_init(malloc_mutex_t *mutex);
56 void malloc_mutex_prefork(malloc_mutex_t *mutex);
57 void malloc_mutex_postfork_parent(malloc_mutex_t *mutex);
58 void malloc_mutex_postfork_child(malloc_mutex_t *mutex);
66 void malloc_mutex_lock(malloc_mutex_t *mutex);
67 void malloc_mutex_unlock(malloc_mutex_t *mutex);
72 malloc_mutex_lock(malloc_mutex_t *mutex) in malloc_mutex_lock() argument
78 AcquireSRWLockExclusive(&mutex->lock); in malloc_mutex_lock()
80 EnterCriticalSection(&mutex->lock); in malloc_mutex_lock()
83 OSSpinLockLock(&mutex->lock); in malloc_mutex_lock()
[all …]
|
| /external/libmicrohttpd/src/include/ |
| D | platform_interface.h | 252 #define MHD_mutex_create_(mutex) \ argument
253 ((0 == pthread_mutex_init ((mutex), NULL)) ? MHD_YES : MHD_NO)
260 #define MHD_mutex_create_(mutex) \ argument
261 ((NULL != (mutex) && 0 != InitializeCriticalSectionAndSpinCount((mutex),2000)) ? MHD_YES : MHD_NO)
270 #define MHD_mutex_destroy_(mutex) \ argument
271 ((0 == pthread_mutex_destroy ((mutex))) ? MHD_YES : MHD_NO)
278 #define MHD_mutex_destroy_(mutex) \ argument
279 ((NULL != (mutex)) ? (DeleteCriticalSection(mutex), MHD_YES) : MHD_NO)
290 #define MHD_mutex_lock_(mutex) \ argument
291 ((0 == pthread_mutex_lock((mutex))) ? MHD_YES : MHD_NO)
[all …]
|
| /external/llvm/lib/Support/ |
| D | Mutex.cpp | 48 pthread_mutex_t* mutex = in MutexImpl() local
63 errorcode = pthread_mutex_init(mutex, &attr); in MutexImpl()
71 data_ = mutex; in MutexImpl()
77 pthread_mutex_t* mutex = static_cast<pthread_mutex_t*>(data_); in ~MutexImpl() local
78 assert(mutex != nullptr); in ~MutexImpl()
79 pthread_mutex_destroy(mutex); in ~MutexImpl()
80 free(mutex); in ~MutexImpl()
86 pthread_mutex_t* mutex = static_cast<pthread_mutex_t*>(data_); in acquire() local
87 assert(mutex != nullptr); in acquire()
89 int errorcode = pthread_mutex_lock(mutex); in acquire()
[all …]
|
| /external/jemalloc/src/ |
| D | mutex.c | 67 JEMALLOC_EXPORT int _pthread_mutex_init_calloc_cb(pthread_mutex_t *mutex,
72 malloc_mutex_init(malloc_mutex_t *mutex) in malloc_mutex_init() argument
77 InitializeSRWLock(&mutex->lock); in malloc_mutex_init()
79 if (!InitializeCriticalSectionAndSpinCount(&mutex->lock, in malloc_mutex_init()
84 mutex->lock = 0; in malloc_mutex_init()
87 mutex->postponed_next = postponed_mutexes; in malloc_mutex_init()
88 postponed_mutexes = mutex; in malloc_mutex_init()
90 if (_pthread_mutex_init_calloc_cb(&mutex->lock, in malloc_mutex_init()
100 if (pthread_mutex_init(&mutex->lock, &attr) != 0) { in malloc_mutex_init()
110 malloc_mutex_prefork(malloc_mutex_t *mutex) in malloc_mutex_prefork() argument
[all …]
|
| /external/squashfs-tools/squashfs-tools/ |
| D | caches-queues-lists.c | 56 pthread_mutex_init(&queue->mutex, NULL); in queue_init()
68 pthread_cleanup_push((void *) pthread_mutex_unlock, &queue->mutex); in queue_put()
69 pthread_mutex_lock(&queue->mutex); in queue_put()
72 pthread_cond_wait(&queue->full, &queue->mutex); in queue_put()
85 pthread_cleanup_push((void *) pthread_mutex_unlock, &queue->mutex); in queue_get()
86 pthread_mutex_lock(&queue->mutex); in queue_get()
89 pthread_cond_wait(&queue->empty, &queue->mutex); in queue_get()
104 pthread_cleanup_push((void *) pthread_mutex_unlock, &queue->mutex); in queue_empty()
105 pthread_mutex_lock(&queue->mutex); in queue_empty()
117 pthread_cleanup_push((void *) pthread_mutex_unlock, &queue->mutex); in queue_flush()
[all …]
|
| /external/icu/icu4c/source/common/ |
| D | umutex.cpp | 112 umtx_lock(UMutex *mutex) { in umtx_lock() argument
113 if (mutex == NULL) { in umtx_lock()
114 mutex = &globalMutex; in umtx_lock()
116 CRITICAL_SECTION *cs = &mutex->fCS; in umtx_lock()
117 umtx_initOnce(mutex->fInitOnce, winMutexInit, cs); in umtx_lock()
122 umtx_unlock(UMutex* mutex) in umtx_unlock() argument
124 if (mutex == NULL) { in umtx_unlock()
125 mutex = &globalMutex; in umtx_unlock()
127 LeaveCriticalSection(&mutex->fCS); in umtx_unlock()
153 umtx_condWait(UConditionVar *condition, UMutex *mutex) { in umtx_condWait() argument
[all …]
|
| /external/dbus/dbus/ |
| D | dbus-threads-internal.h | 51 void _dbus_rmutex_lock (DBusRMutex *mutex);
52 void _dbus_rmutex_unlock (DBusRMutex *mutex);
56 void _dbus_cmutex_lock (DBusCMutex *mutex);
57 void _dbus_cmutex_unlock (DBusCMutex *mutex);
64 DBusCMutex *mutex);
66 DBusCMutex *mutex,
75 void _dbus_platform_rmutex_free (DBusRMutex *mutex);
76 void _dbus_platform_rmutex_lock (DBusRMutex *mutex);
77 void _dbus_platform_rmutex_unlock (DBusRMutex *mutex);
80 void _dbus_platform_cmutex_free (DBusCMutex *mutex);
[all …]
|
| /external/deqp/framework/delibs/dethread/ |
| D | deThreadTest.c | 176 deMutex mutex = *((deMutex*)arg); in mutexTestThr1() local
178 deMutex_lock(mutex); in mutexTestThr1()
179 deMutex_unlock(mutex); in mutexTestThr1()
184 deMutex mutex; member
198 deMutex_lock(data->mutex); in mutexTestThr2()
202 deMutex_unlock(data->mutex); in mutexTestThr2()
213 deMutex_unlock(data->mutex); in mutexTestThr2()
218 deMutex_lock(data->mutex); in mutexTestThr2()
220 deMutex_unlock(data->mutex); in mutexTestThr2()
225 deMutex mutex = *((deMutex*)arg); in mutexTestThr3() local
[all …]
|
| /external/libcxx/test/std/thread/thread.mutex/thread.lock/thread.lock.unique/thread.lock.unique.mod/ |
| D | release.pass.cpp | 21 struct mutex struct
29 int mutex::lock_count = 0; argument
30 int mutex::unlock_count = 0;
32 mutex m;
36 std::unique_lock<mutex> lk(m); in main()
37 assert(lk.mutex() == &m); in main()
39 assert(mutex::lock_count == 1); in main()
40 assert(mutex::unlock_count == 0); in main()
42 assert(lk.mutex() == nullptr); in main()
44 assert(mutex::lock_count == 1); in main()
[all …]
|
| /external/libcxx/test/std/thread/thread.mutex/thread.lock/thread.lock.shared/thread.lock.shared.mod/ |
| D | release.pass.cpp | 23 struct mutex struct
31 int mutex::lock_count = 0; argument
32 int mutex::unlock_count = 0;
34 mutex m;
41 std::shared_lock<mutex> lk(m); in main()
42 assert(lk.mutex() == &m); in main()
44 assert(mutex::lock_count == 1); in main()
45 assert(mutex::unlock_count == 0); in main()
47 assert(lk.mutex() == nullptr); in main()
49 assert(mutex::lock_count == 1); in main()
[all …]
|