| /src/lib/libpthread/ |
| mtx.c | 1 /* $NetBSD: mtx.c,v 1.1 2019/04/24 11:43:19 kamil Exp $ */
33 __RCSID("$NetBSD: mtx.c,v 1.1 2019/04/24 11:43:19 kamil Exp $");
41 mtx_destroy(mtx_t *mtx)
44 _DIAGASSERT(mtx != NULL);
49 (void)pthread_mutex_destroy(mtx);
53 mtx_init_default(mtx_t *mtx)
56 _DIAGASSERT(mtx != NULL);
58 if (pthread_mutex_init(mtx, NULL) != 0)
65 mtx_init_recursive(mtx_t *mtx)
69 _DIAGASSERT(mtx != NULL)
[all...] |
| cnd.c | 89 cnd_timedwait(cnd_t * __restrict cond, mtx_t * __restrict mtx,
94 _DIAGASSERT(mtx != NULL);
97 switch (pthread_cond_timedwait(cond, mtx, ts)) {
108 cnd_wait(cnd_t *cond, mtx_t *mtx)
112 _DIAGASSERT(mtx != NULL);
114 if (pthread_cond_wait(cond, mtx) == 0)
|
| /src/sys/kern/ |
| 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...] |
| 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_condvar.c | 125 cv_enter(kcondvar_t *cv, kmutex_t *mtx, lwp_t *l, bool catch_p)
139 mutex_exit(mtx);
173 cv_wait(kcondvar_t *cv, kmutex_t *mtx)
178 KASSERT(mutex_owned(mtx));
180 nlocks = cv_enter(cv, mtx, l, false);
182 mutex_enter(mtx);
194 cv_wait_sig(kcondvar_t *cv, kmutex_t *mtx)
199 KASSERT(mutex_owned(mtx));
201 nlocks = cv_enter(cv, mtx, l, true);
203 mutex_enter(mtx);
[all...] |
| sys_aio.c | 329 mutex_enter(&job->mtx);
331 mutex_exit(&job->mtx);
332 mutex_destroy(&job->mtx);
341 mutex_enter(&job->mtx);
347 mutex_exit(&job->mtx);
401 mutex_enter(&job->mtx);
406 mutex_exit(&job->mtx);
420 mutex_destroy(&fg->mtx);
434 mutex_enter(&sp->mtx);
436 mutex_exit(&sp->mtx);
[all...] |
| /src/sys/arch/hppa/include/ |
| mutex.h | 105 MUTEX_SET_WAITERS(struct kmutex *mtx, uintptr_t owner)
108 mtx->mtx_waiters = 1;
110 return mtx->mtx_owner != MUTEX_ADAPTIVE_UNOWNED;
114 MUTEX_HAS_WAITERS(const volatile struct kmutex *mtx)
116 return mtx->mtx_waiters != 0;
120 MUTEX_INITIALIZE_SPIN(struct kmutex *mtx, bool dodebug, int ipl)
122 mtx->mtx_ipl = makeiplcookie(ipl);
123 mtx->mtx_dodebug = dodebug;
124 mtx->mtx_owner = MUTEX_SPIN_FLAG;
125 __cpu_simple_lock_init(&mtx->mtx_lock)
[all...] |
| /src/tests/lib/libpthread/dlopen/dso/ |
| h_pthread_dlopen.c | 59 testf_dso_mutex_lock(pthread_mutex_t *mtx)
61 ATF_REQUIRE(mtx != NULL);
62 ATF_REQUIRE(pthread_mutex_lock(mtx) == 0);
68 testf_dso_mutex_unlock(pthread_mutex_t *mtx)
70 ATF_REQUIRE(mtx != NULL);
71 ATF_REQUIRE(pthread_mutex_unlock(mtx) == 0);
|
| /src/sys/rump/librump/rumpkern/ |
| locks.c | 48 * Currently available only for mtx/rwlock.
106 #define RUMPMTX(mtx) (*(struct rumpuser_mtx *const *)(mtx))
109 _mutex_init(kmutex_t *mtx, kmutex_type_t type, int ipl,
137 rumpuser_mutex_init((struct rumpuser_mtx **)mtx, ruflags);
139 ALLOCK(mtx, &mutex_spin_lockops, return_address);
141 ALLOCK(mtx, &mutex_adaptive_lockops, return_address);
145 mutex_init(kmutex_t *mtx, kmutex_type_t type, int ipl)
148 _mutex_init(mtx, type, ipl, (uintptr_t)__builtin_return_address(0));
152 mutex_destroy(kmutex_t *mtx)
[all...] |
| locks_up.c | 55 #define UPMTX(mtx) struct upmtx *upm = *(struct upmtx **)mtx
66 mutex_init(kmutex_t *mtx, kmutex_type_t type, int ipl)
87 memcpy(mtx, &upm, sizeof(void *));
91 mutex_destroy(kmutex_t *mtx)
93 UPMTX(mtx);
102 mutex_enter(kmutex_t *mtx)
104 UPMTX(mtx);
107 if (mutex_tryenter(mtx))
114 while (!mutex_tryenter(mtx)) {
[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);
|
| 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...] |
| 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);
|
| /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...] |
| rumpuser_pth_dummy.c | 95 rumpuser_mutex_init(struct rumpuser_mtx **mtx, int flags)
98 *mtx = calloc(1, sizeof(struct rumpuser_mtx));
102 rumpuser_mutex_spin_p(struct rumpuser_mtx *mtx)
109 rumpuser_mutex_enter(struct rumpuser_mtx *mtx)
112 mtx->v++;
113 mtx->o = curlwp;
117 rumpuser_mutex_enter_nowrap(struct rumpuser_mtx *mtx)
120 rumpuser_mutex_enter(mtx);
124 rumpuser_mutex_tryenter(struct rumpuser_mtx *mtx)
127 mtx->v++
[all...] |
| rumpfiber.c | 687 struct rumpuser_mtx *mtx; local in function:rumpuser_mutex_init
689 mtx = malloc(sizeof(*mtx));
690 memset(mtx, 0, sizeof(*mtx));
691 mtx->flags = flags;
692 TAILQ_INIT(&mtx->waiters);
693 *mtxp = mtx;
697 rumpuser_mutex_spin_p(struct rumpuser_mtx *mtx)
700 return (mtx->flags & RUMPUSER_MTX_SPIN) != 0
[all...] |
| /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/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/tests/lib/libpthread/weak/lib/ |
| h_pthread_weak.c | 50 pthread_mutex_t mtx; local in function:test_mutex
52 RZ(pthread_mutex_init(&mtx, NULL));
53 RZ(pthread_mutex_lock(&mtx));
54 RZ(pthread_mutex_unlock(&mtx));
55 RZ(pthread_mutex_destroy(&mtx));
|
| /src/sys/external/bsd/vchiq/dist/interface/compat/ |
| vchi_bsd.c | 52 spin_lock(&t->mtx);
55 spin_unlock(&t->mtx);
60 spin_unlock(&t->mtx);
66 spin_unlock(&t->mtx);
74 spin_lock_init(&t->mtx);
94 spin_lock(&t->mtx);
96 spin_unlock(&t->mtx);
108 spin_lock(&t->mtx);
109 callout_halt(&t->callout, &t->mtx);
110 spin_unlock(&t->mtx);
[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) {
|
| /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/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/fs/nfs/common/ |
| nfs_fha.h | 63 struct mtx *mtx; member in struct:fha_hash_entry
76 struct mtx mtx; member in struct:fha_hash_slot
|
| /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...] |
