Lines Matching defs:rep
40 REP *rep;
46 rep = db_rep->region;
51 if (!F_ISSET(rep, REP_F_RECOVER_VERIFY))
69 MUTEX_LOCK(env, rep->mtx_clientdb);
71 MUTEX_UNLOCK(env, rep->mtx_clientdb);
85 if ((ret = __rep_log_backup(env, rep, logc, &lsn)) == 0) {
86 MUTEX_LOCK(env, rep->mtx_clientdb);
89 lp->wait_ts = rep->request_gap;
90 MUTEX_UNLOCK(env, rep->mtx_clientdb);
99 STAT(rep->stat.st_outdated++);
101 if (FLD_ISSET(rep->config, REP_C_NOAUTOINIT))
104 F_CLR(rep, REP_F_RECOVER_VERIFY);
105 F_SET(rep, REP_F_RECOVER_UPDATE);
106 ZERO_LSN(rep->first_lsn);
107 ZERO_LSN(rep->ckp_lsn);
139 REP *rep;
145 rep = db_rep->region;
154 if (F_ISSET(rep, REP_F_RECOVER_MASK) &&
155 !F_ISSET(rep, REP_F_RECOVER_LOG | REP_F_RECOVER_VERIFY))
157 MUTEX_LOCK(env, rep->mtx_clientdb);
168 STAT(rep->stat.st_outdated++);
175 if (!FLD_ISSET(rep->config, REP_C_NOAUTOINIT) &&
176 (F_ISSET(rep, REP_F_RECOVER_LOG) &&
177 LOG_COMPARE(&rep->first_lsn, &rp->lsn) <= 0 &&
178 LOG_COMPARE(&rep->last_lsn, &rp->lsn) >= 0)) {
182 if (F_ISSET(rep, REP_F_READY_MSG))
188 if ((ret = __rep_lockout_msg(env, rep, 1)) != 0)
195 if (F_ISSET(rep, REP_F_READY_API | REP_F_READY_OP)) {
199 __rep_init_cleanup(env, rep, DB_FORCE)) != 0) {
204 F_CLR(rep, REP_F_RECOVER_MASK);
206 F_CLR(rep, REP_F_READY_MSG);
218 if (((F_ISSET(rep, REP_F_RECOVER_VERIFY)) &&
220 (F_ISSET(rep, REP_F_RECOVER_LOG) &&
221 LOG_COMPARE(&rep->first_lsn, &rp->lsn) <= 0 &&
222 LOG_COMPARE(&rep->last_lsn, &rp->lsn) >= 0) ||
223 (F_ISSET(rep, REP_F_RECOVER_MASK) == 0 &&
231 if (FLD_ISSET(rep->config, REP_C_NOAUTOINIT)) {
239 F_CLR(rep, REP_F_RECOVER_VERIFY);
240 F_SET(rep, REP_F_RECOVER_UPDATE);
241 ZERO_LSN(rep->first_lsn);
242 ZERO_LSN(rep->ckp_lsn);
243 lp->wait_ts = rep->request_gap;
245 MUTEX_UNLOCK(env, rep->mtx_clientdb);
253 F_CLR(rep, REP_F_READY_MSG);
255 MUTEX_UNLOCK(env, rep->mtx_clientdb);
275 REP *rep;
281 rep = db_rep->region;
303 if (F_ISSET(rep, REP_F_CLIENT)) {
329 REP *rep;
336 rep = db_rep->region;
344 if (F_ISSET(rep, REP_F_RECOVER_LOG)) {
379 DB_ASSERT(env, rep->op_cnt == 0);
380 DB_ASSERT(env, rep->msg_th == 1);
385 if (rep->version >= DB_REPVERSION_44) {
459 REP *rep;
465 rep = db_rep->region;
477 MUTEX_LOCK(env, rep->mtx_clientdb);
480 MUTEX_UNLOCK(env, rep->mtx_clientdb);
484 MUTEX_UNLOCK(env, rep->mtx_clientdb);
492 if (F_ISSET(rep, REP_F_READY_MSG) ||
493 (!F_ISSET(rep, REP_F_RECOVER_LOG) &&
494 F_ISSET(rep, REP_F_READY_API | REP_F_READY_OP))) {
498 STAT(rep->stat.st_msgs_recover++);
505 if ((ret = __rep_lockout_msg(env, rep, 1)) != 0)
511 if ((ret = __rep_lockout_api(env, rep)) != 0)
520 F_CLR(rep, REP_F_READY_API | REP_F_READY_MSG | REP_F_READY_OP);
529 MUTEX_LOCK(env, rep->mtx_clientdb);
534 lp->wait_ts = rep->request_gap;
546 MUTEX_UNLOCK(env, rep->mtx_clientdb);
551 MUTEX_UNLOCK(env, rep->mtx_clientdb);
553 MUTEX_LOCK(env, rep->mtx_clientdb);
557 rep->stat.st_log_queued = 0;
558 F_CLR(rep, REP_F_NOARCHIVE | REP_F_RECOVER_MASK | REP_F_READY_MSG);
572 master = rep->master_id;
575 MUTEX_UNLOCK(env, rep->mtx_clientdb);
589 lp->wait_ts = rep->max_gap;
590 MUTEX_UNLOCK(env, rep->mtx_clientdb);
595 errunlock2: MUTEX_UNLOCK(env, rep->mtx_clientdb);
611 __rep_log_backup(env, rep, logc, lsn)
613 REP *rep;
634 if (rep->version >= DB_REPVERSION_44 &&