Lines Matching refs:env
74 ENV *env;
77 env = dbenv->env;
79 ENV_REQUIRES_CONFIG(env,
80 env->lk_handle, "DB_ENV->lock_detect", DB_INIT_LOCK);
83 if ((ret = __db_fchk(env, "DB_ENV->lock_detect", flags, 0)) != 0)
97 __db_errx(env,
102 ENV_ENTER(env, ip);
103 REPLICATION_WRAP(env, (__lock_detect(env, atype, rejectp)), 0, ret);
104 ENV_LEAVE(env, ip);
115 __lock_detect(env, atype, rejectp)
116 ENV *env;
133 if (IS_REP_CLIENT(env))
139 lt = env->lk_handle;
151 !__lock_expired(env, &now, ®ion->next_timeout))) {
161 ret = __dd_build(env,
172 if (FLD_ISSET(env->dbenv->verbose, DB_VERB_WAITSFOR))
173 __dd_debug(env, idmap, bitmap, nlockers, nalloc);
177 if ((ret = __os_calloc(env, (size_t)nlockers,
182 if ((ret = __os_calloc(env, sizeof(u_int32_t), nalloc, &tmpmap)) != 0)
187 __dd_find(env, bitmap, idmap, nlockers, nalloc, &deadlist)) != 0)
199 if (TXN_ON(env)) {
200 TXN_SYSTEM_LOCK(env);
202 env->tx_handle->reginfo.primary)->cur_maxid;
203 TXN_SYSTEM_UNLOCK(env);
329 if ((ret = __dd_abort(env, &idmap[killid], &status)) != 0)
338 __db_errx(env,
341 } else if (FLD_ISSET(env->dbenv->verbose, DB_VERB_DEADLOCK))
342 __db_msg(env,
346 __os_free(env, copymap);
348 __os_free(env, deadlist);
350 __os_free(env, tmpmap);
351 __os_free(env, bitmap);
352 __os_free(env, idmap);
376 __dd_build(env, atype, bmp, nlockers, allocp, idmap, rejectp)
377 ENV *env;
395 lt = env->lk_handle;
410 skip: LOCK_DD(env, region);
415 UNLOCK_DD(env, region);
425 if (__lock_expired(env,
429 env, lp->mtx_lock);
441 LOCK_DD(env, region);
445 UNLOCK_DD(env, region);
454 LOCK_LOCKERS(env, region);
457 UNLOCK_LOCKERS(env, region);
462 if (FLD_ISSET(env->dbenv->verbose, DB_VERB_DEADLOCK))
463 __db_msg(env, "%lu lockers", (u_long)count);
468 if ((ret = __os_calloc(env, (size_t)count,
470 UNLOCK_LOCKERS(env, region);
474 if ((ret = __os_calloc(env,
476 UNLOCK_LOCKERS(env, region);
477 __os_free(env, bitmap);
481 if ((ret = __os_calloc(env,
483 UNLOCK_LOCKERS(env, region);
484 __os_free(env, bitmap);
485 __os_free(env, tmpmap);
495 DB_ASSERT(env, id < count);
529 LOCK_DD(env, region);
534 UNLOCK_DD(env, region);
599 if (__lock_expired(env,
602 MUTEX_UNLOCK(env, lp->mtx_lock);
655 LOCK_DD(env, region);
659 UNLOCK_DD(env, region);
739 UNLOCK_LOCKERS(env, region);
750 __os_free(env, tmpmap);
757 __dd_find(env, bmp, idmap, nlockers, nalloc, deadp)
758 ENV *env;
772 if ((ret = __os_malloc(env,
800 if (__os_realloc(env,
823 __dd_abort(env, info, statusp)
824 ENV *env;
837 lt = env->lk_handle;
843 LOCK_LOCKERS(env, region);
887 LOCK_DD(env, region);
890 UNLOCK_DD(env, region);
893 MUTEX_UNLOCK(env, lockp->mtx_lock);
898 out: UNLOCK_LOCKERS(env, region);
905 __dd_debug(env, idmap, bitmap, nlockers, nalloc)
906 ENV *env;
915 __db_msg(env, "Waitsfor array\nWaiter:\tWaiting on:");
920 __db_msgadd(env, &mb, /* Waiter. */
924 __db_msgadd(env,
926 __db_msgadd(env, &mb, " %lu", (u_long)idmap[i].last_lock);
927 DB_MSGBUF_FLUSH(env, &mb);