Lines Matching defs:mutexp
62 DB_MUTEX *mutexp;
69 mutexp = MUTEXP_SET(mutex);
88 RET_SET((pthread_mutex_init(&mutexp->mutex, mutexattrp)), ret);
105 (pthread_cond_init(&mutexp->cond, condattrp)), ret);
107 F_SET(mutexp, DB_MUTEX_SELF_BLOCK);
126 mutexp->mutex = mi;
130 mutexp->mutex = mi;
136 mutexp->cond = ci;
140 mutexp->cond = ci;
142 F_SET(mutexp, DB_MUTEX_SELF_BLOCK);
151 ret = mutex_init(&mutexp->mutex, type, NULL);
153 ret = cond_init(&mutexp->cond, type, NULL);
155 F_SET(mutexp, DB_MUTEX_SELF_BLOCK);
177 DB_MUTEX *mutexp;
189 mutexp = MUTEXP_SET(mutex);
191 CHECK_MTX_THREAD(env, mutexp);
201 if (F_ISSET(mutexp, DB_MUTEX_LOCKED))
202 ++mutexp->mutex_set_wait;
204 ++mutexp->mutex_set_nowait;
207 RET_SET((pthread_mutex_lock(&mutexp->mutex)), ret);
211 if (F_ISSET(mutexp, DB_MUTEX_SELF_BLOCK)) {
220 mutexp->wait++;
221 MUTEX_MEMBAR(mutexp->wait);
223 while (F_ISSET(mutexp, DB_MUTEX_LOCKED)) {
225 &mutexp->cond, &mutexp->mutex)), ret);
241 (void)pthread_mutex_unlock(&mutexp->mutex);
247 mutexp->wait--;
249 F_SET(mutexp, DB_MUTEX_LOCKED);
250 dbenv->thread_id(dbenv, &mutexp->pid, &mutexp->tid);
264 RET_SET((pthread_mutex_unlock(&mutexp->mutex)), ret);
270 if (F_ISSET(mutexp, DB_MUTEX_LOCKED)) {
273 mutexp->pid, mutexp->tid, buf);
281 F_SET(mutexp, DB_MUTEX_LOCKED);
282 dbenv->thread_id(dbenv, &mutexp->pid, &mutexp->tid);
311 DB_MUTEX *mutexp;
323 mutexp = MUTEXP_SET(mutex);
326 if (!F_ISSET(mutexp, DB_MUTEX_LOCKED)) {
332 if (F_ISSET(mutexp, DB_MUTEX_SELF_BLOCK)) {
333 RET_SET((pthread_mutex_lock(&mutexp->mutex)), ret);
337 F_CLR(mutexp, DB_MUTEX_LOCKED);
339 RET_SET((pthread_cond_signal(&mutexp->cond)), ret);
343 F_CLR(mutexp, DB_MUTEX_LOCKED);
348 RET_SET((pthread_mutex_unlock(&mutexp->mutex)), ret);
369 DB_MUTEX *mutexp;
379 mutexp = MUTEXP_SET(mutex);
382 if (F_ISSET(mutexp, DB_MUTEX_SELF_BLOCK)) {
383 RET_SET((pthread_cond_destroy(&mutexp->cond)), ret);
387 RET_SET((pthread_mutex_destroy(&mutexp->mutex)), t_ret);