libzpool/common/kernel.c

112 zmutex_init(kmutex_t *mp)
114 	mp->m_owner = NULL;
115 	mp->initialized = B_TRUE;
116 	(void) _mutex_init(&mp->m_lock, USYNC_THREAD, NULL);
120 zmutex_destroy(kmutex_t *mp)
122 	ASSERT(mp->initialized == B_TRUE);
123 	ASSERT(mp->m_owner == NULL);
124 	(void) _mutex_destroy(&(mp)->m_lock);
125 	mp->m_owner = (void *)-1UL;
126 	mp->initialized = B_FALSE;
130 zmutex_owned(kmutex_t *mp)
132 	ASSERT(mp->initialized == B_TRUE);
134 	return (mp->m_owner == curthread);
138 mutex_enter(kmutex_t *mp)
140 	ASSERT(mp->initialized == B_TRUE);
141 	ASSERT(mp->m_owner != (void *)-1UL);
142 	ASSERT(mp->m_owner != curthread);
143 	VERIFY(mutex_lock(&mp->m_lock) == 0);
144 	ASSERT(mp->m_owner == NULL);
145 	mp->m_owner = curthread;
149 mutex_tryenter(kmutex_t *mp)
151 	ASSERT(mp->initialized == B_TRUE);
152 	ASSERT(mp->m_owner != (void *)-1UL);
153 	if (0 == mutex_trylock(&mp->m_lock)) {
154 		ASSERT(mp->m_owner == NULL);
155 		mp->m_owner = curthread;
163 mutex_exit(kmutex_t *mp)
165 	ASSERT(mp->initialized == B_TRUE);
166 	ASSERT(mutex_owner(mp) == curthread);
167 	mp->m_owner = NULL;
168 	VERIFY(mutex_unlock(&mp->m_lock) == 0);
172 mutex_owner(kmutex_t *mp)
174 	ASSERT(mp->initialized == B_TRUE);
175 	return (mp->m_owner);
307 cv_wait(kcondvar_t *cv, kmutex_t *mp)
309 	ASSERT(mutex_owner(mp) == curthread);
310 	mp->m_owner = NULL;
311 	int ret = cond_wait(cv, &mp->m_lock);
313 	mp->m_owner = curthread;
317 cv_timedwait(kcondvar_t *cv, kmutex_t *mp, clock_t abstime)
342 	ASSERT(mutex_owner(mp) == curthread);
343 	mp->m_owner = NULL;
344 	error = pthread_cond_timedwait(cv, &mp->m_lock, &ts);
345 	mp->m_owner = curthread;
360 cv_timedwait_hires(kcondvar_t *cv, kmutex_t *mp, hrtime_t tim, hrtime_t res,
377 	ASSERT(mutex_owner(mp) == curthread);
378 	mp->m_owner = NULL;
379 	error = pthread_cond_timedwait(cv, &mp->m_lock, &ts);
380 	mp->m_owner = curthread;