Lines Matching refs:env
35 ENV *env;
38 env = dbenv->env;
40 if ((ret = __os_calloc(env, 1, sizeof(DB_REP), &db_rep)) != 0)
58 if ((ret = __repmgr_env_create(env, db_rep)) != 0) {
59 __os_free(env, db_rep);
64 env->rep_handle = db_rep;
78 ENV *env;
80 env = dbenv->env;
82 if (env->rep_handle != NULL) {
84 __repmgr_env_destroy(env, env->rep_handle);
86 __os_free(env, env->rep_handle);
87 env->rep_handle = NULL;
104 ENV *env;
108 env = dbenv->env;
116 return (__db_ferr(env, "DB_ENV->rep_get_config", 0));
118 db_rep = env->rep_handle;
120 env, db_rep->region, "DB_ENV->rep_get_config", DB_INIT_REP);
123 __rep_config_map(env, &which, &mapped);
124 if (REP_ON(env)) {
154 ENV *env;
161 env = dbenv->env;
162 db_rep = env->rep_handle;
171 env, db_rep->region, "DB_ENV->rep_set_config", DB_INIT_REP);
174 return (__db_ferr(env, "DB_ENV->rep_set_config", 0));
177 __rep_config_map(env, &which, &mapped);
179 if (REP_ON(env)) {
180 ENV_ENTER(env, ip);
189 __db_errx(env,
194 __db_errx(env,
201 MUTEX_LOCK(env, rep->mtx_clientdb);
202 REP_SYSTEM_LOCK(env);
213 dblp = env->lg_handle;
218 REP_SYSTEM_UNLOCK(env);
237 ret = __rep_send_bulk(env, &bulk, 0);
239 MUTEX_UNLOCK(env, rep->mtx_clientdb);
241 ENV_LEAVE(env, ip);
252 __rep_config_map(env, inflagsp, outflagsp)
253 ENV *env;
256 COMPQUIET(env, NULL);
323 ENV *env;
332 env = dbenv->env;
335 env, rep_handle, "DB_ENV->rep_start", DB_INIT_REP);
337 db_rep = env->rep_handle;
339 infop = env->reginfo;
348 __db_errx(env,
355 __db_errx(env,
364 if (IS_USING_LEASES(env) && rep->lease_timeout == 0) {
365 __db_errx(env,
370 ENV_ENTER(env, ip);
376 if ((ret = __log_flush(env, NULL)) != 0)
379 REP_SYSTEM_LOCK(env);
390 RPRINT(env, DB_VERB_REP_MISC,
391 (env, "Thread already in lockout"));
392 REP_SYSTEM_UNLOCK(env);
394 } else if ((ret = __rep_lockout_msg(env, rep, 0)) != 0)
406 if ((ret = __rep_lockout_api(env, rep)) != 0)
411 dblp = env->lg_handle;
432 if ((ret = __rep_preclose(env)) != 0)
442 if (IS_USING_LEASES(env) &&
444 __db_errx(env,
450 __rep_elect_done(env, rep, 0);
455 RPRINT(env, DB_VERB_REP_MISC, (env,
458 if ((ret = __rep_write_gen(env, rep->gen)) != 0)
466 if (IS_USING_LEASES(env) &&
472 if ((ret = __rep_islease_granted(env))) {
473 __db_errx(env,
490 if ((ret = __rep_lease_table_alloc(env,
506 RPRINT(env, DB_VERB_REP_MISC, (env,
522 RPRINT(env, DB_VERB_REP_MISC, (env,
525 if ((ret = __env_init_rec(env, DB_LOGVERSION)) != 0)
530 REP_SYSTEM_UNLOCK(env);
531 LOG_SYSTEM_LOCK(env);
533 LOG_SYSTEM_UNLOCK(env);
541 (void)__rep_send_message(env,
551 region = env->tx_handle->reginfo.primary;
553 (t_ret = __rep_restore_prepared(env)) != 0 &&
557 if ((t_ret = __dbreg_mark_restored(env)) != 0 &&
561 ret = __dbreg_invalidate_files(env, 0);
563 env, 0)) != 0 && ret == 0)
566 if ((t_ret = __txn_recycle_id(env)) != 0 && ret == 0)
568 REP_SYSTEM_LOCK(env);
571 REP_SYSTEM_UNLOCK(env);
585 if ((ret = __log_get_oldversion(env, &oldvers)) != 0)
587 RPRINT(env, DB_VERB_REP_MISC, (env,
590 __log_set_version(env, oldvers);
591 oldvers = __rep_conv_vers(env, oldvers);
593 env, oldvers != DB_REPVERSION_INVALID);
604 if (IS_USING_LEASES(env) &&
606 if ((ret = __rep_lease_expire(env, 1)) != 0)
628 REP_SYSTEM_UNLOCK(env);
638 if ((ret = __rep_abort_prepared(env)) != 0)
651 MUTEX_LOCK(env, rep->mtx_clientdb);
654 MUTEX_UNLOCK(env, rep->mtx_clientdb);
660 REP_SYSTEM_LOCK(env);
666 REP_SYSTEM_UNLOCK(env);
679 * private env, set our gen number down to 0.
687 if (F_ISSET(env, ENV_PRIVATE))
689 if ((ret = __dbt_usercopy(env, dbt)) != 0)
691 (void)__rep_send_message(env,
694 (void)__rep_send_message(env,
706 errlock: REP_SYSTEM_LOCK(env);
710 REP_SYSTEM_UNLOCK(env);
714 REP_SYSTEM_LOCK(env);
716 REP_SYSTEM_UNLOCK(env);
719 __rep_fire_event(env, pending_event, NULL);
720 __dbt_userfree(env, dbt, NULL, NULL);
721 ENV_LEAVE(env, ip);
739 __rep_client_dbinit(env, startup, which)
740 ENV *env;
753 dbenv = env->dbenv;
754 db_rep = env->rep_handle;
769 ENV_GET_THREAD_INFO(env, ip);
792 (F_ISSET(env, ENV_THREAD) ? DB_THREAD : 0);
859 __rep_abort_prepared(env)
860 ENV *env;
872 mgr = env->tx_handle;
874 dblp = env->lg_handle;
882 if ((ret = __txn_recover(env,
889 env->rep_handle->region->op_cnt--;
890 env->rep_handle->region->max_prep_lsn = lp->lsn;
910 __rep_restore_prepared(env)
911 ENV *env;
925 db_rep = env->rep_handle;
928 RPRINT(env, DB_VERB_REP_MISC,
929 (env, "restore_prep: No prepares. Skip."));
939 if ((ret = __log_cursor(env, &logc)) != 0)
949 __db_errx(env, "First record not found");
957 RPRINT(env, DB_VERB_REP_MISC,
958 (env, "restore_prep: Prepare resolved. Skip"));
973 if ((ret = __txn_getckp(env, &lsn)) == 0) {
975 __db_errx(env,
982 env, rec.data, &ckp_args)) == 0) {
984 __os_free(env, ckp_args);
987 __db_errx(env,
994 __db_errx(env,
1005 __db_errx(env, "Attempt to get first log record failed");
1018 LOGCOPY_32(env, &low_txn,
1037 __db_errx(env, "Final log record not found");
1042 LOGCOPY_32(env, &hi_txn,
1054 if ((ret = __db_txnlist_init(env,
1068 F_SET(env->lg_handle, DBLOG_RECOVER);
1072 LOGCOPY_32(env, &rectype, rec.data);
1081 env, rec.data, ®op_args)) != 0)
1085 __os_free(env, regop_args);
1087 ret = __db_txnlist_find(env,
1090 ret = __db_txnlist_add(env, txninfo,
1102 env, rec.data, &prep_args)) != 0)
1104 ret = __db_txnlist_find(env, txninfo,
1108 ret = __db_txnlist_add(env, txninfo,
1112 __rep_process_txn(env, &rec)) == 0) {
1122 ret = __txn_restore_txn(env,
1127 __os_free(env, prep_args);
1140 F_CLR(env->lg_handle, DBLOG_RECOVER);
1143 __db_txnlist_end(env, txninfo);
1162 ENV *env;
1165 env = dbenv->env;
1166 db_rep = env->rep_handle;
1169 env, db_rep->region, "DB_ENV->rep_get_limit", DB_INIT_REP);
1171 if (REP_ON(env)) {
1173 ENV_ENTER(env, ip);
1174 REP_SYSTEM_LOCK(env);
1179 REP_SYSTEM_UNLOCK(env);
1180 ENV_LEAVE(env, ip);
1205 ENV *env;
1208 env = dbenv->env;
1209 db_rep = env->rep_handle;
1212 env, db_rep->region, "DB_ENV->rep_set_limit", DB_INIT_REP);
1219 if (REP_ON(env)) {
1221 ENV_ENTER(env, ip);
1222 REP_SYSTEM_LOCK(env);
1225 REP_SYSTEM_UNLOCK(env);
1226 ENV_LEAVE(env, ip);
1244 ENV *env;
1247 env = dbenv->env;
1248 db_rep = env->rep_handle;
1251 env, db_rep->region, "DB_ENV->rep_set_nsites", DB_INIT_REP);
1253 if (REP_ON(env)) {
1256 __db_errx(env,
1275 ENV *env;
1278 env = dbenv->env;
1279 db_rep = env->rep_handle;
1283 if (REP_ON(env)) {
1301 ENV *env;
1304 env = dbenv->env;
1305 db_rep = env->rep_handle;
1307 if (REP_ON(env)) {
1324 ENV *env;
1327 env = dbenv->env;
1328 db_rep = env->rep_handle;
1330 if (REP_ON(env)) {
1348 ENV *env;
1352 env = dbenv->env;
1353 db_rep = env->rep_handle;
1359 if (REP_ON(env))
1365 if (REP_ON(env))
1371 if (REP_ON(env))
1377 if (REP_ON(env) && F_ISSET(rep, REP_F_START_CALLED)) {
1379 __db_errx(env,
1383 if (REP_ON(env))
1406 __db_errx(env,
1425 ENV *env;
1428 env = dbenv->env;
1429 db_rep = env->rep_handle;
1434 *timeout = REP_ON(env) ?
1438 *timeout = REP_ON(env) ?
1442 *timeout = REP_ON(env) ?
1446 *timeout = REP_ON(env) ?
1461 __db_errx(env,
1484 ENV *env;
1487 env = dbenv->env;
1488 db_rep = env->rep_handle;
1491 env, db_rep->region, "DB_ENV->rep_get_request", DB_INIT_REP);
1493 if (REP_ON(env)) {
1495 ENV_ENTER(env, ip);
1499 REP_SYSTEM_LOCK(env);
1504 REP_SYSTEM_UNLOCK(env);
1505 ENV_LEAVE(env, ip);
1532 ENV *env;
1536 env = dbenv->env;
1537 db_rep = env->rep_handle;
1540 env, db_rep->region, "DB_ENV->rep_set_request", DB_INIT_REP);
1543 __db_errx(env,
1547 if (REP_ON(env)) {
1549 ENV_ENTER(env, ip);
1553 REP_SYSTEM_LOCK(env);
1556 REP_SYSTEM_UNLOCK(env);
1558 MUTEX_LOCK(env, rep->mtx_clientdb);
1559 dblp = env->lg_handle;
1563 MUTEX_UNLOCK(env, rep->mtx_clientdb);
1564 ENV_LEAVE(env, ip);
1590 ENV *env;
1593 env = dbenv->env;
1596 __db_errx(env,
1602 __db_errx(env,
1607 db_rep = env->rep_handle;
1610 if (REP_ON(env)) {
1612 ENV_ENTER(env, ip);
1613 REP_SYSTEM_LOCK(env);
1615 REP_SYSTEM_UNLOCK(env);
1616 ENV_LEAVE(env, ip);
1631 ENV *env;
1634 env = dbenv->env;
1635 db_rep = env->rep_handle;
1637 if (REP_ON(env)) {
1659 ENV *env;
1663 env = dbenv->env;
1664 db_rep = env->rep_handle;
1668 env, db_rep->region, "DB_ENV->rep_set_clockskew", DB_INIT_REP);
1685 __db_errx(env,
1693 __db_errx(env,
1697 if (REP_ON(env)) {
1700 __db_errx(env,
1704 ENV_ENTER(env, ip);
1705 REP_SYSTEM_LOCK(env);
1708 REP_SYSTEM_UNLOCK(env);
1709 ENV_LEAVE(env, ip);
1732 ENV *env;
1735 env = dbenv->env;
1738 env, rep_handle, "DB_ENV->rep_flush", DB_INIT_REP);
1739 ENV_ENTER(env, ip);
1741 if ((ret = __log_cursor(env, &logc)) != 0)
1750 (void)__rep_send_message(env,
1755 ENV_LEAVE(env, ip);
1775 ENV *env;
1781 env = dbenv->env;
1786 env, rep_handle, "DB_ENV->rep_sync", DB_INIT_REP);
1788 dblp = env->lg_handle;
1790 db_rep = env->rep_handle;
1794 ENV_ENTER(env, ip);
1800 MUTEX_LOCK(env, rep->mtx_clientdb);
1802 MUTEX_UNLOCK(env, rep->mtx_clientdb);
1803 REP_SYSTEM_LOCK(env);
1806 REP_SYSTEM_UNLOCK(env);
1807 (void)__rep_send_message(env, DB_EID_BROADCAST,
1817 REP_SYSTEM_UNLOCK(env);
1821 DB_ASSERT(env,
1822 !IS_USING_LEASES(env) || __rep_islease_granted(env) == 0);
1833 REP_SYSTEM_UNLOCK(env);
1836 REP_SYSTEM_UNLOCK(env);
1844 DB_ASSERT(env, F_ISSET(rep, REP_F_RECOVER_UPDATE));
1848 DB_ASSERT(env, F_ISSET(rep, REP_F_RECOVER_VERIFY));
1852 (void)__rep_send_message(env, master, type, &lsn, NULL, 0, repflags);
1854 out: ENV_LEAVE(env, ip);
1864 __rep_conv_vers(env, log_ver)
1865 ENV *env;
1868 COMPQUIET(env, NULL);