Lines Matching refs:env
29 #define CDB_LOCKING_INIT(env, dbc) \
36 if (CDB_LOCKING(env)) { \
38 return (__db_wrlock_err(env)); \
41 (ret = __lock_get(env, \
46 #define CDB_LOCKING_DONE(env, dbc) \
50 env, &(dbc)->mylock, DB_LOCK_IWRITE, 0);
66 ENV *env;
70 env = dbp->env;
86 MUTEX_LOCK(env, dbp->mutex);
89 DB_ASSERT(env, F_ISSET(opd, DBC_ACTIVE));
93 DB_ASSERT(env, F_ISSET(dbc, DBC_ACTIVE));
97 MUTEX_UNLOCK(env, dbp->mutex);
108 if (CDB_LOCKING(env)) {
128 MUTEX_LOCK(env, dbp->mutex);
136 MUTEX_UNLOCK(env, dbp->mutex);
156 ENV *env;
160 env = dbp->env;
163 MUTEX_LOCK(env, dbp->mutex);
165 MUTEX_UNLOCK(env, dbp->mutex);
169 __os_free(env, dbc->my_rskey.data);
171 __os_free(env, dbc->my_rkey.data);
173 __os_free(env, dbc->my_rdata.data);
181 if (LOCKING_ON(env) &&
183 (t_ret = __lock_id_free(env, dbc->lref)) != 0 && ret == 0)
186 __os_free(env, dbc);
202 ENV *env;
205 env = dbc->env;
232 return (__db_unknown_type(env, "__dbc_count", dbc->dbtype));
250 ENV *env;
254 env = dbp->env;
264 CDB_LOCKING_INIT(env, dbc);
325 done: CDB_LOCKING_DONE(env, dbc);
386 ENV *env;
391 env = dbp->env;
427 ret = __db_unknown_type(env,
441 if (CDB_LOCKING(env) && !F_ISSET(dbc_n, DBC_OPD) &&
442 (ret = __lock_get(env, dbc_n->locker, 0,
527 ENV *env;
548 env = dbp->env;
583 CDB_LOCKING_INIT(env, dbc_arg);
740 ret = __db_unknown_flag(env, "__dbc_get", flags);
842 DB_ASSERT(env, cp_n->opd == NULL);
909 CDB_LOCKING_DONE(env, dbc_arg);
929 ENV *env;
944 env = dbp->env;
968 CDB_LOCKING_INIT(env, dbc_arg);
1038 env, (u_int)s_count, sizeof(DBT), &all_skeys)) != 0)
1048 DB_ASSERT(env, flags == DB_CURRENT || flags == DB_KEYFIRST ||
1097 DB_ASSERT(env, flags != DB_CURRENT);
1143 ret = __db_rec_toobig(env, size, re_len);
1158 __os_realloc(env, re_len, &newdata.data)) != 0)
1178 DB_ASSERT(env, skeyp - all_skeys < s_count);
1299 if (CDB_LOCKING(env)) {
1300 DB_ASSERT(env, sdbc->mylock.off == LOCK_INVALID);
1358 __os_ufree(env, oldpkey.data);
1360 __db_errx(env, "%s%s",
1425 DB_ASSERT(env, flags != DB_CURRENT);
1448 DB_ASSERT(env, skeyp - all_skeys < s_count);
1550 __os_free(env, newdata.data);
1552 __os_ufree(env, olddata.data);
1554 CDB_LOCKING_DONE(env, dbc_arg);
1565 FREE_IF_NEEDED(env, tskeyp);
1567 FREE_IF_NEEDED(env, skeyp);
1570 __os_free(env, all_skeys);
1590 ENV *env;
1596 env = dbp->env;
1644 FREE_IF_NEEDED(env, toldskeyp);
1653 if (CDB_LOCKING(env)) {
1654 DB_ASSERT(env,
1673 FREE_IF_NEEDED(env, toldskeyp);
1677 FREE_IF_NEEDED(env, toldskeyp);
1678 FREE_IF_NEEDED(env, &oldskey);
1710 __db_errx(dbp->env,
1841 DB_ASSERT(dbc->env, F_ISSET(dbc->dbp, DB_AM_SECONDARY));
2067 __dbt_userfree(sdbp->env, NULL, pkey, NULL);
2068 if ((ret = __dbt_usercopy(sdbp->env, pkey)) != 0)
2140 ENV *env;
2147 env = sdbp->env;
2194 perr: __os_ufree(env, primary_key.data);
2200 } else if ((ret = __db_retcopy(env, data, &oob,
2213 return (__db_retcopy(env, pkey, &oob,
2221 __db_wrlock_err(env)
2222 ENV *env;
2224 __db_errx(env, "Write attempted on read-only cursor");
2245 ENV *env;
2250 env = pdbp->env;
2286 if (CDB_LOCKING(env)) {
2287 DB_ASSERT(env, pdbc->mylock.off == LOCK_INVALID);
2328 ENV *env;
2333 env = dbp->env;
2385 if (CDB_LOCKING(env)) {
2386 DB_ASSERT(env, sdbc->mylock.off == LOCK_INVALID);
2413 FREE_IF_NEEDED(env, tskeyp);
2428 FREE_IF_NEEDED(env, &skey);
2434 FREE_IF_NEEDED(env, &skey);
2461 ENV *env;
2466 env = dbp->env;
2500 if (!LF_ISSET(DB_FOREIGN_ABORT) && CDB_LOCKING(env) &&
2501 !F_ISSET(env->dbenv, DB_ENV_CDB_ALLDB)) {
2523 if (CDB_LOCKING(env) && F_ISSET(env->dbenv, DB_ENV_CDB_ALLDB)){
2524 DB_ASSERT(env, sdbc->mylock.off == LOCK_INVALID);
2527 DB_ASSERT(env,
2583 __db_err(env, ret,
2591 __db_err(env, ret,
2602 __db_err(env, ret,
2640 MUTEX_LOCK(pdbp->env, pdbp->mutex);
2646 MUTEX_UNLOCK(pdbp->env, pdbp->mutex);
2665 ENV *env;
2693 env = pdbp->env;
2696 MUTEX_LOCK(env, pdbp->mutex);
2697 DB_ASSERT(env, sdbp->s_refcnt != 0);
2705 MUTEX_UNLOCK(env, pdbp->mutex);
2717 ret = __txn_closeevent(env, txn, closeme);
2735 ENV *env;
2739 env = pdbp->env;
2742 MUTEX_LOCK(env, pdbp->mutex);
2743 DB_ASSERT(env, sdbp->s_refcnt != 0);
2748 MUTEX_UNLOCK(env, pdbp->mutex);
2755 ret = __txn_closeevent(env, txn, sdbp);
2768 ENV *env;
2771 env = pdbp->env;
2774 MUTEX_LOCK(env, pdbp->mutex);
2779 MUTEX_UNLOCK(env, pdbp->mutex);
2798 ENV *env;
2803 env = dbp->env;
2805 DB_ASSERT(env, F_ISSET(partial, DB_DBT_PARTIAL));
2812 if ((ret = __os_malloc(env, nbytes, &buf)) != 0)
2889 ENV *env;
2891 env = sdbp->env;
2897 DB_ASSERT(env,