Lines Matching refs:env
64 if ((ret = __memp_fcreate((D)->env, &(D)->mpf)) != 0) \
78 __os_closehandle((D)->env, (F))) != 0) { \
99 __fop_lock_handle(env, dbp, locker, mode, elockp, flags)
100 ENV *env;
112 if (!LOCKING_ON(env) ||
120 if (IS_RECOVERING(env))
121 return (elockp == NULL ? 0 : __ENV_LPUT(env, *elockp));
130 DB_TEST_SUBLOCKS(env, flags);
132 ret = __lock_get(env, locker,
141 if ((ret = __lock_vec(env,
213 ENV *env;
223 env = dbp->env;
240 if (LOCKING_ON(env) &&
244 if ((ret = __lock_id(env, NULL, &dbp->locker)) != 0)
257 if ((ret = __db_appname(env,
283 __db_errx(env, "__fop_file_setup: Retry limit (%d) exceeded",
288 GET_ENVLOCK(env, locker, &elock);
310 ret = __os_exists(env, real_name, NULL);
331 __os_open(env, real_name, 0, oflags, 0, &fhp)) != 0)
349 ret = __fop_read_meta(env, real_name, mbuf,
370 ret = __db_meta_setup(env, dbp,
380 if ((ret = __fop_lock_handle(env,
382 if ((ret = __ENV_LPUT(env, elock)) != 0)
402 DB_ASSERT(env, !LF_ISSET(DB_FCNTL_LOCKING));
404 if ((ret = __os_closehandle(env, fhp)) != 0)
408 if ((ret = __fop_lock_handle(env,
436 __os_open(env, real_name, 0, 0, 0, &fhp);
440 __ENV_LPUT(env, dbp->handle_lock)) != 0) {
452 __fop_read_meta(env, real_name, mbuf,
456 (ret = __db_meta_setup(env, dbp, real_name,
479 __os_closehandle(env, fhp)) != 0)
503 ret = __ENV_LPUT(env, dbp->handle_lock);
530 * the environment lock, while for on-disk files, we drop the env lock
534 (ret = __ENV_LPUT(env, elock)) != 0)
537 create: if (txn != NULL && IS_REP_CLIENT(env) &&
539 __db_errx(env,
548 if ((ret = __db_backup_name(env, name, txn, &tmpname)) != 0)
550 if (TXN_ON(env) && txn != NULL &&
551 (ret = __txn_begin(env, NULL, txn, &stxn, 0)) != 0)
553 if ((ret = __fop_create(env,
561 if (!TXN_ON(env) && ret == EEXIST) {
562 __os_free(env, tmpname);
564 __os_yield(env, 1, 0);
573 if ((ret = __db_appname(env,
584 __os_fileid(env, real_tmpname, 1, dbp->fileid)) != 0)
606 GET_ENVLOCK(env, locker, &elock);
610 __txn_remrem(env, txn, real_name);
614 __os_exists(env, real_name, NULL) == 0) {
619 (void)__fop_remove(env,
621 (void)__ENV_LPUT(env, dbp->handle_lock);
633 if (name != NULL && (ret = __fop_lock_handle(env,
636 if (tmpname != NULL && tmpname != name && (ret = __fop_rename(env,
653 errmsg: __db_err(env, ret, "%s", name);
659 (void)__fop_remove(env,
662 (void)__ENV_LPUT(env, dbp->handle_lock);
663 (void)__ENV_LPUT(env, elock);
665 (void)__lock_id_free(env, dbp->locker);
676 __os_free(env, tmpname);
678 __os_free(env, real_name);
680 __os_free(env, real_tmpname);
696 ENV *env;
700 env = dbp->env;
708 if ((ret = __os_ioinfo(env, name, fhp, NULL, NULL, &iopsize)) != 0) {
709 __db_err(env, ret, "%s", name);
757 ENV *env;
762 env = dbp->env;
813 if ((ret = __fop_lock_handle(env, dbp,
863 (void)__ENV_LPUT(env, dbp->handle_lock);
878 __txn_remlock(env,
882 if ((t_ret = __txn_lockevent(env, txn, dbp,
907 __txn_closeevent(env, txn, mdbp)) != 0 && ret == 0)
930 ENV *env;
936 env = dbp->env;
943 retry: if (LOCKING_ON(env)) {
947 if ((ret = __lock_id(env, NULL, &dbp->locker)) != 0)
963 DB_ASSERT(env, LF_ISSET(DB_FCNTL_LOCKING) || fhp == NULL);
970 GET_ENVLOCK(env, dbp->locker, &elock);
975 ret = __os_strdup(env, name, &dbp->dname);
977 ret = __os_open(env, name, 0, DB_OSO_RDONLY, 0, &fhp);
984 else if ((ret = __fop_read_meta(env,
986 ret = __db_meta_setup(env, dbp,
997 if ((ret = __fop_lock_handle(env,
1004 (void)__os_closehandle(env, fhp);
1010 else if ((ret = __fop_lock_handle(env,
1015 (void)__lock_put(env, &dbp->handle_lock);
1023 } else if ((ret = __ENV_LPUT(env, elock)) != 0)
1029 err: (void)__ENV_LPUT(env, elock);
1032 (void)__os_closehandle(env, fhp);
1054 __fop_read_meta(env, name, buf, size, fhp, errok, nbytesp)
1055 ENV *env;
1074 ret = __os_read(env, fhp, buf, size, &nr);
1080 __db_err(env, ret, "%s", name);
1086 __db_errx(env,
1113 ENV *env;
1118 env = dbp->env;
1123 DB_ASSERT(env, txn != NULL);
1130 if (TXN_ON(env) &&
1131 (ret = __txn_begin(env, NULL, txn, &stxn, 0)) != 0)
1135 if ((ret = __db_backup_name(env, new, stxn, &back)) != 0)
1138 if ((ret = __db_create_internal(&tmpdbp, env, 0)) != 0)
1163 __os_free(env, back);
1182 ENV *env;
1186 env = dbp->env;
1196 if ((ret = __db_appname(env,
1200 if ((ret = __db_appname(env,
1211 GET_ENVLOCK(env, dbp->locker, &elock);
1213 __os_exists(env, real_new, NULL);
1217 __db_errx(env, "rename: file %s exists", real_new);
1221 ret = __memp_nameop(env,
1224 err: if ((t_ret = __ENV_LPUT(env, elock)) != 0 && ret == 0)
1227 __os_free(env, real_old);
1229 __os_free(env, real_new);
1242 ENV *env;
1247 env = dbp->env;
1267 if (LOCKING_ON(env) && (ret =
1268 __lock_id(env, (u_int32_t *)dbp->fileid, NULL)) != 0)
1272 __os_unique_id(env, p32);
1278 if (DBENV_LOGGING(env) &&
1294 if (DBENV_LOGGING(env) &&
1305 if ((ret = __crdel_inmem_create_log(env, txn,
1329 ENV_GET_THREAD_INFO(dbp->env, ip);
1336 ret = __db_meta_setup(dbp->env, dbp, name, metap, flags, 1);
1353 ENV *env;
1359 env = dbp->env;
1362 if ((ret = __db_appname(env,
1366 if ((ret = __fop_create(env,
1371 __os_fileid(env, realname, 1, ((DBMETA *)mbuf)->uid)) != 0)
1375 if ((ret = __fop_write(env, txn, name,
1382 __os_free(env, realname);
1402 ENV_GET_THREAD_INFO(dbp->env, ip);
1444 ENV *env;
1450 env = dbp->env;
1451 DB_ASSERT(env, txn != NULL);
1452 DB_ASSERT(env, old != NULL);
1460 __db_appname(env, DB_APP_DATA, new, 0, NULL, &realnew)) != 0)
1464 retry: GET_ENVLOCK(env, locker, &elock);
1465 if (__os_exists(env, realnew, NULL) == 0) {
1472 if ((ret = __os_open(env, realnew, 0, 0, 0, &fhp)) != 0)
1474 if ((ret = __fop_read_meta(env,
1476 (ret = __db_meta_setup(env,
1481 ret = __os_closehandle(env, fhp);
1512 if ((ret = __fop_lock_handle(env,
1518 if ((ret = __fop_lock_handle(env, tmpdbp,
1522 __lock_put(env, &tmpdbp->handle_lock)) != 0)
1530 ret = __fop_lock_handle(env,
1538 (void)__lock_put(env, &tmpdbp->handle_lock);
1544 (void)__lock_put(env, &tmpdbp->handle_lock);
1555 if ((ret = __fop_rename(env,
1558 if ((ret = __fop_rename(env,
1561 if ((ret = __fop_lock_handle(env,
1586 if ((t_ret = __fop_file_remove_log(env,
1592 if ((ret = __db_appname(env,
1596 if ((ret = __txn_remevent(env, parent, realold, NULL, 0)) != 0)
1602 (void)__ENV_LPUT(env, elock);
1605 (t_ret = __os_closehandle(env, fhp)) != 0 && ret == 0)
1609 __os_free(env, realnew);
1611 __os_free(env, realold);
1627 ENV *env;
1630 env = olddbp->env;
1633 if ((ret = __db_create_internal(&tmpdbp, env, 0)) != 0)
1637 GET_ENVLOCK(env, locker, &elock);
1657 if ((ret = __fop_lock_handle(env,
1663 if ((ret = __fop_lock_handle(env, tmpdbp,
1668 (void)__lock_put(env, &tmpdbp->handle_lock);
1670 (void)__ENV_LPUT(env, elock);
1673 (void)__lock_put(env, &tmpdbp->handle_lock);
1682 if (LOGGING_ON(env)
1692 env, txn, &lsn, 0, &n1_dbt, &n2_dbt, &fid_dbt)) != 0)
1699 env, txn, &lsn, 0, &n2_dbt, &n1_dbt, &fid_dbt)) != 0)
1710 if ((ret = __memp_nameop(env,
1713 __txn_remrem(env, parent, new);
1717 env, olddbp->fileid, new, old, new, 1)) != 0)
1720 env, backdbp->fileid, old, back, old, 1)) != 0)
1723 if ((ret = __fop_lock_handle(env,
1734 DB_ASSERT(env, txn != NULL);
1743 err: (void)__ENV_LPUT(env, elock);