Lines Matching defs:mutexp
37 static __inline int get_handle(env, mutexp, eventp)
39 DB_MUTEX *mutexp;
47 for (id = (mutexp)->id; id != 0; id >>= 4)
82 DB_MUTEX *mutexp;
88 mutexp = MUTEXP_SET(mutex);
90 mutexp->id = ((getpid() & 0xffff) << 16) ^ P_TO_UINT32(mutexp);
107 DB_MUTEX *mutexp;
126 mutexp = MUTEXP_SET(mutex);
128 CHECK_MTX_THREAD(env, mutexp);
152 tmp_tid = mutexp->tid;
153 mutexp->tid = tmp_tid;
155 if (mutexp->tas || !MUTEX_SET(&mutexp->tas)) {
167 if (F_ISSET(mutexp, DB_MUTEX_LOCKED)) {
172 mutexp->pid, mutexp->tid, buf));
176 F_SET(mutexp, DB_MUTEX_LOCKED);
177 dbenv->thread_id(dbenv, &mutexp->pid, &mutexp->tid);
181 ++mutexp->mutex_set_nowait;
183 ++mutexp->mutex_set_wait;
187 InterlockedDecrement(&mutexp->nwaiters);
193 now.QuadPart, mutexp, mutexp->id, ms);
220 now.QuadPart, mutexp, mutexp->id);
222 InterlockedIncrement(&mutexp->nwaiters);
223 if ((ret = get_handle(env, mutexp, &event)) != 0)
252 DB_MUTEX *mutexp;
267 mutexp = MUTEXP_SET(mutex);
270 if (!mutexp->tas || !F_ISSET(mutexp, DB_MUTEX_LOCKED)) {
275 F_CLR(mutexp, DB_MUTEX_LOCKED);
276 MUTEX_UNSET(&mutexp->tas);
278 if (mutexp->nwaiters > 0) {
279 if ((ret = get_handle(env, mutexp, &event)) != 0)
285 now.QuadPart, mutexp, mutexp->id);