| /src/tests/lib/libpthread/dlopen/ |
| t_dlopen.c | 77 pthread_mutex_t mtx; local in function:ATF_TC_BODY
81 ATF_REQUIRE(pthread_mutex_init(&mtx, NULL) == 0);
82 ATF_REQUIRE(pthread_mutex_lock(&mtx) == 0);
92 ATF_REQUIRE(pthread_mutex_unlock(&mtx) == 0);
96 pthread_mutex_destroy(&mtx);
109 pthread_mutex_t mtx; local in function:ATF_TC_BODY
113 ATF_REQUIRE(pthread_mutex_init(&mtx, NULL) == 0);
114 ATF_REQUIRE(pthread_mutex_lock(&mtx) == 0);
123 ATF_REQUIRE(testf_dso_mutex_unlock(&mtx) == 0xcafe);
127 pthread_mutex_destroy(&mtx);
141 pthread_mutex_t mtx; local in function:ATF_TC_BODY
[all...] |
| /src/tests/rump/kernspace/ |
| lockme.c | 52 kmutex_t mtx; local in function:rumptest_lockme
56 mutex_init(&mtx, MUTEX_DEFAULT, IPL_NONE);
60 mutex_enter(&mtx);
61 mutex_enter(&mtx);
76 mutex_init(&mtx, MUTEX_DEFAULT, IPL_NONE);
79 mutex_destroy(&mtx);
80 mutex_destroy(&mtx);
83 mutex_enter(&mtx);
84 mutex_destroy(&mtx);
|
| thread.c | 72 static kmutex_t mtx; variable in typeref:typename:kmutex_t
80 mutex_enter(&mtx);
83 mutex_exit(&mtx);
94 mutex_init(&mtx, MUTEX_DEFAULT, IPL_NONE);
101 mutex_enter(&mtx);
103 cv_wait(&cv, &mtx);
104 mutex_exit(&mtx);
|
| alloc.c | 51 static kmutex_t mtx; variable in typeref:typename:kmutex_t
60 mutex_enter(&mtx);
65 cv_wait(&kcv, &mtx);
66 mutex_exit(&mtx);
85 mutex_init(&mtx, MUTEX_DEFAULT, IPL_NONE);
103 mutex_enter(&mtx);
105 cv_wait(&kcv, &mtx);
106 mutex_exit(&mtx);
112 mutex_enter(&mtx);
115 mutex_exit(&mtx);
[all...] |
| workqueue.c | 46 kmutex_t mtx; member in struct:test_softc
64 mutex_enter(&sc->mtx);
67 mutex_exit(&sc->mtx);
77 mutex_init(&sc->mtx, MUTEX_DEFAULT, IPL_NONE);
94 mutex_destroy(&sc->mtx);
108 mutex_enter(&sc->mtx);
110 e = cv_timedwait(&sc->cv, &sc->mtx, hz * 2);
113 mutex_exit(&sc->mtx);
|
| /src/sys/ddb/ |
| db_syncobj.c | 52 volatile const struct kmutex *mtx = wchan; local in function:db_syncobj_owner
55 db_read_bytes((db_addr_t)&mtx->mtx_owner, sizeof(owner),
|
| /src/sys/external/bsd/compiler_rt/dist/lib/sanitizer_common/ |
| sanitizer_persistent_allocator.h | 30 StaticSpinMutex mtx; // Protects alloc of new blocks for region allocator. member in class:__sanitizer::PersistentAllocator
52 SpinMutexLock l(&mtx);
|
| sanitizer_deadlock_detector1.cc | 37 SpinMutex mtx; member in struct:__sanitizer::DD
109 SpinMutexLock lk(&mtx);
164 SpinMutexLock lk(&mtx);
181 SpinMutexLock lk(&mtx);
|
| sanitizer_addrhashmap.h | 60 RWMutex mtx; member in struct:__sanitizer::AddrHashMap::Bucket
197 b->mtx.ReadLock();
208 b->mtx.ReadUnlock();
214 b->mtx.Lock();
223 b->mtx.Unlock();
240 b->mtx.Unlock();
248 b->mtx.Unlock();
308 b->mtx.Unlock();
337 b->mtx.Unlock();
341 b->mtx.ReadUnlock()
[all...] |
| sanitizer_deadlock_detector2.cc | 78 StaticSpinMutex mtx; member in struct:__sanitizer::Mutex
102 void CycleCheck(DDPhysicalThread *pt, DDLogicalThread *lt, DDMutex *mtx);
112 SpinMutex mtx; member in struct:__sanitizer::DD
173 SpinMutexLock l(&mtx);
220 Mutex *mtx = getMutex(m->id); local in function:__sanitizer::DD::MutexBeforeLock
225 SpinMutexLock l(&mtx1->mtx);
234 if (link->seq != mtx->seq) {
235 link->seq = mtx->seq;
250 link->seq = mtx->seq;
260 if (!added || mtx->nlink == 0)
346 Mutex *mtx = getMutex(m->id); local in function:__sanitizer::DD::MutexDestroy
365 Mutex *mtx = getMutex(m->id); local in function:__sanitizer::DD::CycleCheck
[all...] |
| /src/sys/kern/ |
| kern_module_hook.c | 49 kmutex_t mtx; member in struct:__anone55dcd900108
89 mutex_enter(&module_hook.mtx);
98 localcount_drain(lc, &module_hook.cv, &module_hook.mtx);
101 mutex_exit(&module_hook.mtx);
124 localcount_release(lc, &module_hook.cv, &module_hook.mtx);
131 mutex_init(&module_hook.mtx, MUTEX_DEFAULT, IPL_NONE);
|
| kern_mutex.c | 80 #define MUTEX_WANTLOCK(mtx) \
81 LOCKDEBUG_WANTLOCK(MUTEX_DEBUG_P(mtx), (mtx), \
83 #define MUTEX_TESTLOCK(mtx) \
84 LOCKDEBUG_WANTLOCK(MUTEX_DEBUG_P(mtx), (mtx), \
86 #define MUTEX_LOCKED(mtx) \
87 LOCKDEBUG_LOCKED(MUTEX_DEBUG_P(mtx), (mtx), NULL, \
89 #define MUTEX_UNLOCKED(mtx) \
319 const volatile kmutex_t *mtx = cookie; local in function:mutex_dump
844 volatile const kmutex_t *mtx = wchan; local in function:mutex_owner
[all...] |
| /src/sys/external/bsd/compiler_rt/dist/lib/sanitizer_common/tests/ |
| sanitizer_mutex_test.cc | 27 explicit TestData(MutexType *mtx)
28 : mtx_(mtx) {
98 static void check_locked(MutexType *mtx) {
99 GenericScopedLock<MutexType> l(mtx);
100 mtx->CheckLocked();
104 SpinMutex mtx; local in function:__sanitizer::TEST
105 mtx.Init();
106 TestData<SpinMutex> data(&mtx);
115 SpinMutex mtx; local in function:__sanitizer::TEST
116 mtx.Init()
127 BlockingMutex *mtx = new(mtxmem) BlockingMutex(LINKER_INITIALIZED); local in function:__sanitizer::TEST
[all...] |
| /src/sys/external/bsd/compiler_rt/dist/lib/tsan/rtl/ |
| tsan_trace.h | 59 Mutex mtx; member in struct:__tsan::Trace
70 : mtx(MutexTypeTrace, StatMtxTrace) {
|
| tsan_sync.h | 57 Mutex mtx; member in struct:__tsan::SyncVar
68 // with the mtx. This reduces contention for hot sync objects.
|
| tsan_mman.cc | 71 Mutex mtx; member in struct:__tsan::GlobalProc
75 : mtx(MutexTypeGlobalProc, StatMtxGlobalProc)
104 gp->mtx.Lock();
114 gp->mtx.Unlock();
|
| /src/sys/external/bsd/compiler_rt/dist/lib/tsan/tests/rtl/ |
| tsan_posix.cc | 21 pthread_mutex_t *mtx; member in struct:thread_key
24 thread_key(pthread_key_t key, pthread_mutex_t *mtx, int val, int *cnt)
26 , mtx(mtx)
34 EXPECT_EQ(__interceptor_pthread_mutex_lock(k->mtx), 0);
37 EXPECT_EQ(__interceptor_pthread_mutex_unlock(k->mtx), 0);
58 pthread_mutex_t mtx; local in function:TEST
59 EXPECT_EQ(__interceptor_pthread_mutex_init(&mtx, 0), 0);
61 thread_key k1 = thread_key(key, &mtx, 42, &cnt);
62 thread_key k2 = thread_key(key, &mtx, 43, &cnt)
[all...] |
| /src/sys/external/bsd/compiler_rt/dist/lib/tsan/tests/unit/ |
| tsan_mutex_test.cc | 25 explicit TestData(MutexType *mtx)
26 : mtx_(mtx) {
97 Mutex mtx(MutexTypeAnnotations, StatMtxAnnotations); local in function:__tsan::TEST
98 TestData<Mutex> data(&mtx);
107 Mutex mtx(MutexTypeAnnotations, StatMtxAnnotations); local in function:__tsan::TEST
108 TestData<Mutex> data(&mtx);
117 SpinMutex mtx; local in function:__tsan::TEST
118 TestData<SpinMutex> data(&mtx);
|
| /src/sys/fs/nfs/common/ |
| nfs_fha.c | 60 mtx_init(&softc->fha_hash[i].mtx, "fhalock", NULL, MTX_DEF);
123 mtx_destroy(&softc->fha_hash[i].mtx);
212 mtx_assert(e->mtx, MA_OWNED);
226 mtx_assert(e->mtx, MA_OWNED);
241 new_fhe->mtx = &fhs->mtx;
242 mtx_lock(&fhs->mtx);
258 mtx_assert(fhe->mtx, MA_OWNED);
268 mtx_assert(fhe->mtx, MA_OWNED);
282 mtx_assert(fhe->mtx, MA_OWNED)
447 struct mtx *mtx; local in function:fha_nd_complete
[all...] |
| nfs_fha.h | 63 struct mtx *mtx; member in struct:fha_hash_entry
76 struct mtx mtx; member in struct:fha_hash_slot
|
| nfsrvcache.h | 120 struct kmutex mtx; member in struct:nfsrchash_bucket
|
| /src/sys/dev/i2c/ |
| nxt2k.c | 50 kmutex_t mtx; member in struct:nxt2k
193 mutex_enter(&nxt->mtx);
194 cv_timedwait(&nxt->cv, &nxt->mtx, mstohz(10));
195 mutex_exit(&nxt->mtx);
235 mutex_enter(&nxt->mtx);
236 cv_timedwait(&nxt->cv, &nxt->mtx, mstohz(25));
237 mutex_exit(&nxt->mtx);
803 mutex_init(&nxt->mtx, MUTEX_DEFAULT, IPL_NONE);
|
| /src/sys/dev/pci/ |
| if_nfevar.h | 67 kmutex_t mtx; member in struct:nfe_rx_ring
|
| /src/sys/arch/xen/xenbus/ |
| xenbus_dev.c | 135 kmutex_t mtx; member in struct:xenbus_dev_lwp
141 kmutex_t mtx; member in struct:xenbus_dev_data
167 mutex_enter(&u->mtx);
175 mutex_exit(&u->mtx);
178 mutex_enter(&xlwp->mtx);
179 mutex_exit(&u->mtx);
202 mutex_exit(&xlwp->mtx);
211 KASSERT(mutex_owned(&xlwp->mtx));
243 mutex_enter(&u->mtx);
251 mutex_exit(&u->mtx);
[all...] |
| /src/lib/librumpuser/ |
| rumpuser_pth.c | 143 struct rumpuser_mtx *mtx; local in function:rumpuser_mutex_init
147 allocsz = (sizeof(*mtx)+RUMPUSER_LOCKALIGN) & ~(RUMPUSER_LOCKALIGN-1);
148 NOFAIL(mtx = aligned_alloc(RUMPUSER_LOCKALIGN, allocsz));
152 NOFAIL_ERRNO(pthread_mutex_init(&mtx->pthmtx, &att));
155 mtx->owner = NULL;
157 mtx->flags = flags;
159 *mtxp = mtx;
163 rumpuser_mutex_spin_p(struct rumpuser_mtx *mtx)
166 return (mtx->flags & RUMPUSER_MTX_SPIN) != 0;
170 mtxenter(struct rumpuser_mtx *mtx)
[all...] |
