Lines Matching refs:env
55 ENV *env;
58 env = dbenv->env;
72 if ((ret = __db_fchk(env, "DB_ENV->open", flags, OKFLAGS)) != 0)
75 env, "DB_ENV->open", flags, DB_INIT_CDB, ~OKFLAGS_CDB)) != 0)
79 __db_errx(env,
83 if ((ret = __db_fcchk(env, "DB_ENV->open", flags,
88 env, "registration requires transaction support");
94 __db_errx(env,
99 __db_errx(env,
105 env, "replication requires transaction support");
110 if ((ret = __db_fcchk(env,
113 if ((ret = __db_fcchk(env,
117 __db_errx(env, "recovery requires the create flag");
122 env, "recovery requires transaction support");
134 __db_errx(env,
158 if (F_ISSET(env, ENV_THREAD)) {
159 __db_errx(env,
182 ENV *env;
188 env = dbenv->env;
209 if ((ret = __envreg_register(env, ®ister_recovery)) != 0)
213 __db_errx(env,
235 if ((ret = __rep_reset_init(env)) != 0 ||
236 (ret = __env_remove_env(env)) != 0 ||
238 if ((ret = __env_remove_env(env)) != 0 ||
246 F_SET(env, ENV_LOCKDOWN);
248 F_SET(env, ENV_PRIVATE);
250 F_SET(env, ENV_RECOVER_FATAL);
252 F_SET(env, ENV_SYSTEM_MEM);
254 F_SET(env, ENV_THREAD);
289 if ((ret = __env_attach(env, &init_flags, create_ok, 1)) != 0)
318 F_SET(env, ENV_CDB);
329 env->open_flags = flags;
336 F_SET(env, ENV_OPEN_CALLED);
341 infop = env->reginfo;
343 __env_thread_init(env, F_ISSET(infop, REGION_CREATE) ? 1 : 0)) != 0)
346 ENV_ENTER(env, ip);
358 if ((ret = __mutex_open(env, create_ok)) != 0)
365 if ((ret = __env_ref_increment(env)) != 0)
371 if ((ret = __mutex_alloc(env,
373 (ret = __mutex_alloc(env,
374 MTX_ENV_HANDLE, DB_MUTEX_PROCESS_ONLY, &env->mtx_env)) != 0)
381 if (LF_ISSET(DB_INIT_REP) && (ret = __rep_open(env)) != 0)
384 rep_check = IS_ENV_REPLICATED(env) ? 1 : 0;
385 if (rep_check && (ret = __env_rep_enter(env, 0)) != 0)
389 if ((ret = __memp_open(env, create_ok)) != 0)
406 TAILQ_INIT(&env->dblist);
407 if ((ret = __mutex_alloc(env, MTX_ENV_DBLIST,
408 DB_MUTEX_PROCESS_ONLY, &env->mtx_dblist)) != 0)
413 env, DB_FTYPE_SET, __db_pgin, __db_pgout)) != 0)
427 (ret = __crypto_region_init(env)) != 0)
430 env, MTX_TWISTER, DB_MUTEX_PROCESS_ONLY, &env->mtx_mt)) != 0)
440 if ((ret = __log_open(env, create_ok)) != 0)
443 if ((ret = __lock_open(env, create_ok)) != 0)
447 if ((ret = __txn_open(env, create_ok)) != 0)
454 if ((ret = __env_init_rec(env, DB_LOGVERSION)) != 0)
460 (ret = __db_apprec(env, ip, NULL, NULL, 1,
474 if (TXN_ON(env) &&
478 (ret = __txn_reset(env)) != 0)
482 if ((ret = __env_turn_on(env)) != 0)
486 ret = __env_db_rep_exit(env);
493 ENV_LEAVE(env, ip);
502 infop = env->reginfo;
504 ret = __env_panic(env, ret);
508 (void)__env_remove_env(env);
522 if (ret == 0 && (t_ret = __envreg_xunlock(env)) != 0)
525 (void)__envreg_unregister(env, 1);
543 ENV *env;
546 env = dbenv->env;
553 if ((ret = __db_fchk(env, "DB_ENV->remove", flags, OKFLAGS)) != 0)
556 ENV_ILLEGAL_AFTER_OPEN(env, "DB_ENV->remove");
565 if ((ret = __env_turn_off(env, flags)) == 0 || LF_ISSET(DB_FORCE))
566 ret = __env_remove_env(env);
587 ENV *env;
591 env = dbenv->env;
606 env, "DB_HOME", &home, sizeof(home_buf))) != 0)
612 if (home != NULL && (ret = __os_strdup(env, home, &env->db_home)) != 0)
616 env->open_flags = flags;
619 env->db_mode = mode == 0 ? DB_MODE_660 : mode;
622 if ((ret = __env_read_db_config(env)) != 0)
629 if (dbenv->db_tmp_dir == NULL && (ret = __os_tmpdir(env, flags)) != 0)
647 ENV *env;
650 env = dbenv->env;
658 (t_ret = __db_ferr(env, "DB_ENV->close", 0)) != 0 && ret == 0)
665 if (PANIC_ISSET(env)) {
667 (void)__file_handle_cleanup(env);
670 if (IS_ENV_REPLICATED(env))
671 (void)__repmgr_close(env);
673 PANIC_CHECK(env);
676 ENV_ENTER(env, ip);
678 rep_check = IS_ENV_REPLICATED(env) ? 1 : 0;
687 if ((t_ret = __repmgr_close(env)) != 0 && ret == 0)
690 if ((t_ret = __env_rep_enter(env, 0)) != 0 && ret == 0)
712 ENV *env;
716 env = dbenv->env;
723 if (TXN_ON(env) && (t_ret = __txn_preclose(env)) != 0 && ret == 0)
727 if ((t_ret = __rep_env_close(env)) != 0 && ret == 0)
743 if ((t_ret = __crypto_env_close(env)) != 0 && ret == 0)
749 (void)__envreg_unregister(env, 0);
754 if ((t_ret = __file_handle_cleanup(env)) != 0 && ret == 0)
759 __os_free(env, dbenv->db_log_dir);
762 __os_free(env, dbenv->db_tmp_dir);
766 __os_free(env, *p);
767 __os_free(env, dbenv->db_data_dir);
772 __os_free(env, dbenv->intermediate_dir_mode);
773 if (env->db_home != NULL) {
774 __os_free(env, env->db_home);
775 env->db_home = NULL;
796 ENV *env;
799 env = dbenv->env;
816 if (TXN_ON(env) &&
817 (t_ret = __txn_env_refresh(env)) != 0 && ret == 0)
820 if (LOGGING_ON(env) &&
821 (t_ret = __log_env_refresh(env)) != 0 && ret == 0)
828 if (LOCKING_ON(env)) {
829 if (!F_ISSET(env, ENV_THREAD) &&
830 env->env_lref != NULL && (t_ret =
831 __lock_id_free(env, env->env_lref)) != 0 && ret == 0)
833 env->env_lref = NULL;
835 if ((t_ret = __lock_env_refresh(env)) != 0 && ret == 0)
840 if ((t_ret = __mutex_free(env, &dbenv->mtx_db_env)) != 0 && ret == 0)
842 if ((t_ret = __mutex_free(env, &env->mtx_env)) != 0 && ret == 0)
854 if (env->db_ref != 0) {
855 __db_errx(env,
857 TAILQ_FOREACH(ldbp, &env->dblist, dblistlinks)
858 __db_errx(env, "Open database handle: %s%s%s",
865 TAILQ_INIT(&env->dblist);
866 if ((t_ret = __mutex_free(env, &env->mtx_dblist)) != 0 && ret == 0)
868 if ((t_ret = __mutex_free(env, &env->mtx_mt)) != 0 && ret == 0)
871 if (env->mt != NULL) {
872 __os_free(env, env->mt);
873 env->mt = NULL;
876 if (MPOOL_ON(env)) {
885 if (F_ISSET(env, ENV_PRIVATE) &&
886 (t_ret = __memp_sync_int(env, NULL, 0,
891 if ((t_ret = __memp_env_refresh(env)) != 0 && ret == 0)
906 if (rep_check && (t_ret = __env_db_rep_exit(env)) != 0 && ret == 0)
914 if (REP_ON(env) && (t_ret = __rep_env_refresh(env)) != 0 && ret == 0)
922 if (env->reginfo != NULL &&
923 (t_ret = __crypto_env_refresh(env)) != 0 && ret == 0)
928 * Mark the thread as out of the env before we get rid of the handles
931 if (env->thr_hashtab != NULL &&
932 (t_ret = __env_set_state(env, &ip, THREAD_OUT)) != 0 && ret == 0)
960 if ((t_ret = __env_ref_decrement(env)) != 0 && ret == 0)
964 if (MUTEX_ON(env) &&
965 (t_ret = __mutex_env_refresh(env)) != 0 && ret == 0)
969 if (env->reginfo != NULL) {
970 if (F_ISSET(env, ENV_PRIVATE)) {
971 __env_thread_destroy(env);
972 t_ret = __env_detach(env, 1);
974 t_ret = __env_detach(env, 0);
981 * Don't free env->reginfo or set the reference to NULL,
986 if (env->mutex_iq != NULL) {
987 __os_free(env, env->mutex_iq);
988 env->mutex_iq = NULL;
991 if (env->recover_dtab.int_dispatch != NULL) {
992 __os_free(env, env->recover_dtab.int_dispatch);
993 env->recover_dtab.int_size = 0;
994 env->recover_dtab.int_dispatch = NULL;
996 if (env->recover_dtab.ext_dispatch != NULL) {
997 __os_free(env, env->recover_dtab.ext_dispatch);
998 env->recover_dtab.ext_size = 0;
999 env->recover_dtab.ext_dispatch = NULL;
1013 __file_handle_cleanup(env)
1014 ENV *env;
1018 if (TAILQ_FIRST(&env->fdlist) == NULL)
1021 __db_errx(env, "File handles still open at environment close");
1022 while ((fhp = TAILQ_FIRST(&env->fdlist)) != NULL) {
1023 __db_errx(env, "Open file handle: %s", fhp->name);
1024 (void)__os_closehandle(env, fhp);
1040 ENV *env;
1042 env = dbenv->env;
1044 ENV_ILLEGAL_BEFORE_OPEN(env, "DB_ENV->get_open_flags");
1046 *flagsp = env->open_flags;