Home
last modified time | relevance | path

Searched refs:mtx (Results 1 – 25 of 137) sorted by relevance

123456

/netbsd-src/sys/kern/
H A Dkern_mutex.c80 #define MUTEX_WANTLOCK(mtx) \ argument
81 LOCKDEBUG_WANTLOCK(MUTEX_DEBUG_P(mtx), (mtx), \
83 #define MUTEX_TESTLOCK(mtx) \ argument
84 LOCKDEBUG_WANTLOCK(MUTEX_DEBUG_P(mtx), (mtx), \
86 #define MUTEX_LOCKED(mtx) \ argument
87 LOCKDEBUG_LOCKED(MUTEX_DEBUG_P(mtx), (mtx), NULL, \
89 #define MUTEX_UNLOCKED(mtx) \ argument
90 LOCKDEBUG_UNLOCKED(MUTEX_DEBUG_P(mtx), (mtx), \
92 #define MUTEX_ABORT(mtx, msg) \ argument
93 mutex_abort(__func__, __LINE__, mtx, msg)
[all …]
H A Dkern_condvar.c125 cv_enter(kcondvar_t *cv, kmutex_t *mtx, lwp_t *l, bool catch_p) in cv_enter() argument
139 mutex_exit(mtx); in cv_enter()
173 cv_wait(kcondvar_t *cv, kmutex_t *mtx) in cv_wait() argument
178 KASSERT(mutex_owned(mtx)); in cv_wait()
180 nlocks = cv_enter(cv, mtx, l, false); in cv_wait()
182 mutex_enter(mtx); in cv_wait()
194 cv_wait_sig(kcondvar_t *cv, kmutex_t *mtx) in cv_wait_sig() argument
199 KASSERT(mutex_owned(mtx)); in cv_wait_sig()
201 nlocks = cv_enter(cv, mtx, l, true); in cv_wait_sig()
203 mutex_enter(mtx); in cv_wait_sig()
[all …]
/netbsd-src/external/bsd/ipf/dist/lib/
H A Dmutex_emul.c20 eMmutex_enter(mtx, file, line) in eMmutex_enter() argument
21 eMmutex_t *mtx; in eMmutex_enter()
27 mtx->eMm_owner);
28 if (mtx->eMm_magic != EMM_MAGIC) {
30 mtx->eMm_owner, mtx, mtx->eMm_magic);
33 if (mtx->eMm_held != 0) {
35 mtx->eMm_owner, mtx, mtx->eMm_held);
38 mtx->eMm_held++;
39 mtx->eMm_heldin = file;
40 mtx->eMm_heldat = line;
[all …]
/netbsd-src/lib/libpthread/
H A Dmtx.c41 mtx_destroy(mtx_t *mtx) in mtx_destroy() argument
44 _DIAGASSERT(mtx != NULL); in mtx_destroy()
49 (void)pthread_mutex_destroy(mtx); in mtx_destroy()
53 mtx_init_default(mtx_t *mtx) in mtx_init_default() argument
56 _DIAGASSERT(mtx != NULL); in mtx_init_default()
58 if (pthread_mutex_init(mtx, NULL) != 0) in mtx_init_default()
65 mtx_init_recursive(mtx_t *mtx) in mtx_init_recursive() argument
69 _DIAGASSERT(mtx != NULL); in mtx_init_recursive()
80 if (pthread_mutex_init(mtx, &attr) == 0) in mtx_init_recursive()
89 mtx_init(mtx_t *mtx, int type) in mtx_init() argument
[all …]
/netbsd-src/sys/arch/hppa/include/
H A Dmutex.h105 MUTEX_SET_WAITERS(struct kmutex *mtx, uintptr_t owner) in MUTEX_SET_WAITERS() argument
108 mtx->mtx_waiters = 1; in MUTEX_SET_WAITERS()
110 return mtx->mtx_owner != MUTEX_ADAPTIVE_UNOWNED; in MUTEX_SET_WAITERS()
114 MUTEX_HAS_WAITERS(const volatile struct kmutex *mtx) in MUTEX_HAS_WAITERS() argument
116 return mtx->mtx_waiters != 0; in MUTEX_HAS_WAITERS()
120 MUTEX_INITIALIZE_SPIN(struct kmutex *mtx, bool dodebug, int ipl) in MUTEX_INITIALIZE_SPIN() argument
122 mtx->mtx_ipl = makeiplcookie(ipl); in MUTEX_INITIALIZE_SPIN()
123 mtx->mtx_dodebug = dodebug; in MUTEX_INITIALIZE_SPIN()
124 mtx->mtx_owner = MUTEX_SPIN_FLAG; in MUTEX_INITIALIZE_SPIN()
125 __cpu_simple_lock_init(&mtx->mtx_lock); in MUTEX_INITIALIZE_SPIN()
[all …]
/netbsd-src/sys/rump/librump/rumpkern/
H A Dlocks.c106 #define RUMPMTX(mtx) (*(struct rumpuser_mtx *const *)(mtx)) argument
109 _mutex_init(kmutex_t *mtx, kmutex_type_t type, int ipl, in _mutex_init() argument
137 rumpuser_mutex_init((struct rumpuser_mtx **)mtx, ruflags); in _mutex_init()
139 ALLOCK(mtx, &mutex_spin_lockops, return_address); in _mutex_init()
141 ALLOCK(mtx, &mutex_adaptive_lockops, return_address); in _mutex_init()
145 mutex_init(kmutex_t *mtx, kmutex_type_t type, int ipl) in mutex_init() argument
148 _mutex_init(mtx, type, ipl, (uintptr_t)__builtin_return_address(0)); in mutex_init()
152 mutex_destroy(kmutex_t *mtx) in mutex_destroy() argument
155 FREELOCK(mtx); in mutex_destroy()
156 rumpuser_mutex_destroy(RUMPMTX(mtx)); in mutex_destroy()
[all …]
H A Dlocks_up.c55 #define UPMTX(mtx) struct upmtx *upm = *(struct upmtx **)mtx argument
66 mutex_init(kmutex_t *mtx, kmutex_type_t type, int ipl) in mutex_init() argument
87 memcpy(mtx, &upm, sizeof(void *)); in mutex_init()
91 mutex_destroy(kmutex_t *mtx) in mutex_destroy() argument
93 UPMTX(mtx); in mutex_destroy()
102 mutex_enter(kmutex_t *mtx) in mutex_enter() argument
104 UPMTX(mtx); in mutex_enter()
107 if (mutex_tryenter(mtx)) in mutex_enter()
114 while (!mutex_tryenter(mtx)) { in mutex_enter()
123 mutex_spin_enter(kmutex_t *mtx) in mutex_spin_enter() argument
[all …]
/netbsd-src/lib/librumpuser/
H A Drumpuser_pth.c143 struct rumpuser_mtx *mtx; in rumpuser_mutex_init() local
147 allocsz = (sizeof(*mtx)+RUMPUSER_LOCKALIGN) & ~(RUMPUSER_LOCKALIGN-1); in rumpuser_mutex_init()
148 NOFAIL(mtx = aligned_alloc(RUMPUSER_LOCKALIGN, allocsz)); in rumpuser_mutex_init()
152 NOFAIL_ERRNO(pthread_mutex_init(&mtx->pthmtx, &att)); in rumpuser_mutex_init()
155 mtx->owner = NULL; in rumpuser_mutex_init()
157 mtx->flags = flags; in rumpuser_mutex_init()
159 *mtxp = mtx; in rumpuser_mutex_init()
163 rumpuser_mutex_spin_p(struct rumpuser_mtx *mtx) in rumpuser_mutex_spin_p() argument
166 return (mtx->flags & RUMPUSER_MTX_SPIN) != 0; in rumpuser_mutex_spin_p()
170 mtxenter(struct rumpuser_mtx *mtx) in mtxenter() argument
[all …]
H A Drumpuser_pth_dummy.c95 rumpuser_mutex_init(struct rumpuser_mtx **mtx, int flgas) in rumpuser_mutex_init() argument
98 *mtx = calloc(1, sizeof(struct rumpuser_mtx)); in rumpuser_mutex_init()
102 rumpuser_mutex_spin_p(struct rumpuser_mtx *mtx) in rumpuser_mutex_spin_p() argument
109 rumpuser_mutex_enter(struct rumpuser_mtx *mtx) in rumpuser_mutex_enter() argument
112 mtx->v++; in rumpuser_mutex_enter()
113 mtx->o = curlwp; in rumpuser_mutex_enter()
117 rumpuser_mutex_enter_nowrap(struct rumpuser_mtx *mtx) in rumpuser_mutex_enter_nowrap() argument
120 rumpuser_mutex_enter(mtx); in rumpuser_mutex_enter_nowrap()
124 rumpuser_mutex_tryenter(struct rumpuser_mtx *mtx) in rumpuser_mutex_tryenter() argument
127 mtx->v++; in rumpuser_mutex_tryenter()
[all …]
H A Drumpfiber.c687 struct rumpuser_mtx *mtx; in rumpuser_mutex_init() local
689 mtx = malloc(sizeof(*mtx)); in rumpuser_mutex_init()
690 memset(mtx, 0, sizeof(*mtx)); in rumpuser_mutex_init()
691 mtx->flags = flags; in rumpuser_mutex_init()
692 TAILQ_INIT(&mtx->waiters); in rumpuser_mutex_init()
693 *mtxp = mtx; in rumpuser_mutex_init()
697 rumpuser_mutex_spin_p(struct rumpuser_mtx *mtx) in rumpuser_mutex_spin_p() argument
700 return (mtx->flags & RUMPUSER_MTX_SPIN) != 0; in rumpuser_mutex_spin_p()
704 rumpuser_mutex_enter(struct rumpuser_mtx *mtx) in rumpuser_mutex_enter() argument
708 if (rumpuser_mutex_tryenter(mtx) != 0) { in rumpuser_mutex_enter()
[all …]
/netbsd-src/sys/external/bsd/vchiq/dist/interface/compat/
H A Dvchi_bsd.c52 spin_lock(&t->mtx); in run_timer()
55 spin_unlock(&t->mtx); in run_timer()
60 spin_unlock(&t->mtx); in run_timer()
66 spin_unlock(&t->mtx); in run_timer()
74 spin_lock_init(&t->mtx); in init_timer()
94 spin_lock(&t->mtx); in mod_timer()
96 spin_unlock(&t->mtx); in mod_timer()
108 spin_lock(&t->mtx); in del_timer_sync()
109 callout_halt(&t->callout, &t->mtx); in del_timer_sync()
110 spin_unlock(&t->mtx); in del_timer_sync()
[all …]
/netbsd-src/tests/lib/libpthread/dlopen/
H A Dt_dlopen.c77 pthread_mutex_t mtx; in ATF_TC_BODY() local
81 ATF_REQUIRE(pthread_mutex_init(&mtx, NULL) == 0); in ATF_TC_BODY()
82 ATF_REQUIRE(pthread_mutex_lock(&mtx) == 0); in ATF_TC_BODY()
92 ATF_REQUIRE(pthread_mutex_unlock(&mtx) == 0); in ATF_TC_BODY()
96 pthread_mutex_destroy(&mtx); in ATF_TC_BODY()
109 pthread_mutex_t mtx; in ATF_TC_BODY() local
113 ATF_REQUIRE(pthread_mutex_init(&mtx, NULL) == 0); in ATF_TC_BODY()
114 ATF_REQUIRE(pthread_mutex_lock(&mtx) == 0); in ATF_TC_BODY()
123 ATF_REQUIRE(testf_dso_mutex_unlock(&mtx) == 0xcafe); in ATF_TC_BODY()
127 pthread_mutex_destroy(&mtx); in ATF_TC_BODY()
[all …]
/netbsd-src/sys/arch/xen/xenbus/
H A Dxenbus_dev.c135 kmutex_t mtx; member
141 kmutex_t mtx; member
167 mutex_enter(&u->mtx); in xenbus_dev_read()
175 mutex_exit(&u->mtx); in xenbus_dev_read()
178 mutex_enter(&xlwp->mtx); in xenbus_dev_read()
179 mutex_exit(&u->mtx); in xenbus_dev_read()
202 mutex_exit(&xlwp->mtx); in xenbus_dev_read()
211 KASSERT(mutex_owned(&xlwp->mtx)); in queue_reply()
243 mutex_enter(&u->mtx); in xenbus_dev_write()
251 mutex_exit(&u->mtx); in xenbus_dev_write()
[all …]
/netbsd-src/sys/external/bsd/compiler_rt/dist/lib/sanitizer_common/tests/
H A Dsanitizer_mutex_test.cc27 explicit TestData(MutexType *mtx) in TestData() argument
28 : mtx_(mtx) { in TestData()
98 static void check_locked(MutexType *mtx) { in check_locked() argument
99 GenericScopedLock<MutexType> l(mtx); in check_locked()
100 mtx->CheckLocked(); in check_locked()
104 SpinMutex mtx; in TEST() local
105 mtx.Init(); in TEST()
106 TestData<SpinMutex> data(&mtx); in TEST()
115 SpinMutex mtx; in TEST() local
116 mtx.Init(); in TEST()
[all …]
/netbsd-src/external/gpl3/gcc/dist/libphobos/libdruntime/rt/
H A Dcritical_.d23 initMutex(cast(Mutex*)&gcs.mtx); in _d_critical_init()
33 destroyMutex(cast(Mutex*)&p.mtx); in _d_critical_term()
40 lockMutex(&cs.mtx); in _d_criticalenter()
47 lockMutex(cast(Mutex*)&gcs.mtx); in _d_criticalenter2()
51 initMutex(cast(Mutex*)&cs.mtx); in _d_criticalenter2()
54 unlockMutex(cast(Mutex*)&gcs.mtx); in _d_criticalenter2()
56 lockMutex(&(*pcs).mtx); in _d_criticalenter2()
62 unlockMutex(&cs.mtx); in _d_criticalexit()
73 Mutex mtx; member
80 lockMutex(cast(Mutex*)&gcs.mtx); in ensureMutex()
[all …]
/netbsd-src/tests/rump/kernspace/
H A Dalloc.c51 static kmutex_t mtx; variable
60 mutex_enter(&mtx); in hthr()
65 cv_wait(&kcv, &mtx); in hthr()
66 mutex_exit(&mtx); in hthr()
85 mutex_init(&mtx, MUTEX_DEFAULT, IPL_NONE); in rumptest_alloc()
103 mutex_enter(&mtx); in rumptest_alloc()
105 cv_wait(&kcv, &mtx); in rumptest_alloc()
106 mutex_exit(&mtx); in rumptest_alloc()
112 mutex_enter(&mtx); in rumptest_alloc()
115 mutex_exit(&mtx); in rumptest_alloc()
H A Dlockme.c52 kmutex_t mtx; in rumptest_lockme() local
56 mutex_init(&mtx, MUTEX_DEFAULT, IPL_NONE); in rumptest_lockme()
60 mutex_enter(&mtx); in rumptest_lockme()
61 mutex_enter(&mtx); in rumptest_lockme()
76 mutex_init(&mtx, MUTEX_DEFAULT, IPL_NONE); in rumptest_lockme()
79 mutex_destroy(&mtx); in rumptest_lockme()
80 mutex_destroy(&mtx); in rumptest_lockme()
83 mutex_enter(&mtx); in rumptest_lockme()
84 mutex_destroy(&mtx); in rumptest_lockme()
H A Dthread.c72 static kmutex_t mtx; variable
80 mutex_enter(&mtx); in thethread()
83 mutex_exit(&mtx); in thethread()
94 mutex_init(&mtx, MUTEX_DEFAULT, IPL_NONE); in rumptest_thread()
101 mutex_enter(&mtx); in rumptest_thread()
103 cv_wait(&cv, &mtx); in rumptest_thread()
104 mutex_exit(&mtx); in rumptest_thread()
/netbsd-src/external/gpl3/gcc.old/dist/libphobos/libdruntime/rt/
H A Dmonitor_.d73 lockMutex(&m.mtx);
83 unlockMutex(&m.mtx); in _d_monitorexit()
174 void initMutex(Mutex* mtx) in version()
178 void destroyMutex(Mutex* mtx) in version()
182 void lockMutex(Mutex* mtx) in version()
186 void unlockMutex(Mutex* mtx) in version()
214 void initMutex(pthread_mutex_t* mtx) in version()
216 pthread_mutex_init(mtx, &gattr) && assert(0); in version()
219 void destroyMutex(pthread_mutex_t* mtx) in version()
221 pthread_mutex_destroy(mtx) && assert(0); in version()
[all …]
H A Dcritical_.d22 initMutex(cast(Mutex*)&gcs.mtx); in _d_critical_init()
29 destroyMutex(cast(Mutex*)&p.mtx); in _d_critical_term()
35 lockMutex(&cs.mtx); in _d_criticalenter()
40 unlockMutex(&cs.mtx); in _d_criticalexit()
51 Mutex mtx; member
58 lockMutex(cast(Mutex*)&gcs.mtx); in ensureMutex()
61 initMutex(cast(Mutex*)&cs.mtx); in ensureMutex()
66 unlockMutex(cast(Mutex*)&gcs.mtx); in ensureMutex()
/netbsd-src/sys/fs/nfs/common/
H A Dnfs_fha.c60 mtx_init(&softc->fha_hash[i].mtx, "fhalock", NULL, MTX_DEF); in fha_init()
123 mtx_destroy(&softc->fha_hash[i].mtx); in fha_uninit()
212 mtx_assert(e->mtx, MA_OWNED); in fha_hash_entry_destroy()
226 mtx_assert(e->mtx, MA_OWNED); in fha_hash_entry_remove()
241 new_fhe->mtx = &fhs->mtx; in fha_hash_entry_lookup()
242 mtx_lock(&fhs->mtx); in fha_hash_entry_lookup()
258 mtx_assert(fhe->mtx, MA_OWNED); in fha_hash_entry_add_thread()
268 mtx_assert(fhe->mtx, MA_OWNED); in fha_hash_entry_remove_thread()
282 mtx_assert(fhe->mtx, MA_OWNED); in fha_hash_entry_add_op()
430 mtx_unlock(fhe->mtx); in fha_assign()
[all …]
/netbsd-src/sys/external/bsd/compiler_rt/dist/lib/tsan/tests/rtl/
H A Dtsan_posix.cc21 pthread_mutex_t *mtx; member
24 thread_key(pthread_key_t key, pthread_mutex_t *mtx, int val, int *cnt) in thread_key()
26 , mtx(mtx) in thread_key()
34 EXPECT_EQ(__interceptor_pthread_mutex_lock(k->mtx), 0); in thread_secific_dtor()
37 EXPECT_EQ(__interceptor_pthread_mutex_unlock(k->mtx), 0); in thread_secific_dtor()
58 pthread_mutex_t mtx; in TEST() local
59 EXPECT_EQ(__interceptor_pthread_mutex_init(&mtx, 0), 0); in TEST()
61 thread_key k1 = thread_key(key, &mtx, 42, &cnt); in TEST()
62 thread_key k2 = thread_key(key, &mtx, 43, &cnt); in TEST()
63 thread_key k3 = thread_key(key, &mtx, 44, &cnt); in TEST()
/netbsd-src/external/cddl/osnet/sys/sys/
H A Dmutex_impl.h39 #define MUTEX_OWNER(mtx) \ argument
40 ((mtx)->mtx_owner & MUTEX_THREAD)
44 #define MUTEX_TYPE_ADAPTIVE(mtx) (((mtx)->mtx_owner & MUTEX_BIT_SPIN) == 0) argument
45 #define MUTEX_TYPE_SPIN(mtx) (((mtx)->mtx_owner & MUTEX_BIT_SPIN) != 0) argument
/netbsd-src/external/gpl3/gcc.old/dist/libsanitizer/sanitizer_common/
H A Dsanitizer_deadlock_detector2.cc76 StaticSpinMutex mtx; member
100 void CycleCheck(DDPhysicalThread *pt, DDLogicalThread *lt, DDMutex *mtx);
110 SpinMutex mtx; member
171 SpinMutexLock l(&mtx); in allocateId()
218 Mutex *mtx = getMutex(m->id); in MutexBeforeLock() local
223 SpinMutexLock l(&mtx1->mtx); in MutexBeforeLock()
232 if (link->seq != mtx->seq) { in MutexBeforeLock()
233 link->seq = mtx->seq; in MutexBeforeLock()
248 link->seq = mtx->seq; in MutexBeforeLock()
258 if (!added || mtx->nlink == 0) { in MutexBeforeLock()
[all …]
/netbsd-src/external/gpl3/gcc/dist/libsanitizer/sanitizer_common/
H A Dsanitizer_deadlock_detector2.cpp77 StaticSpinMutex mtx; member
101 void CycleCheck(DDPhysicalThread *pt, DDLogicalThread *lt, DDMutex *mtx);
111 SpinMutex mtx; member
170 SpinMutexLock l(&mtx); in allocateId()
217 MutexState *mtx = getMutex(m->id); in MutexBeforeLock() local
222 SpinMutexLock l(&mtx1->mtx); in MutexBeforeLock()
231 if (link->seq != mtx->seq) { in MutexBeforeLock()
232 link->seq = mtx->seq; in MutexBeforeLock()
247 link->seq = mtx->seq; in MutexBeforeLock()
257 if (!added || mtx->nlink == 0) { in MutexBeforeLock()
[all …]

123456