Lines Matching refs:rep
33 REP *rep;
45 rep = db_rep->region;
61 use_bulk = FLD_ISSET(rep->config, REP_C_BULK);
68 repth.gbytes = rep->gbytes;
69 repth.bytes = rep->bytes;
81 if (ret == DB_NOTFOUND && F_ISSET(rep, REP_F_MASTER))
114 ret = __rep_chk_newfile(env, logc, rep, rp, eid);
123 if (ret == DB_NOTFOUND && F_ISSET(rep, REP_F_MASTER)) {
147 if (rep->version < DB_REPVERSION_47)
169 (F_ISSET(rep, REP_F_MASTER) ||
170 rep->stat.st_startup_complete)) ?
228 REP *rep;
233 rep = db_rep->region;
245 __rep_logready(env, rep, savetime, &last_lsn)) != 0)
270 master = rep->master_id;
282 MUTEX_LOCK(env, rep->mtx_clientdb);
299 MUTEX_UNLOCK(env, rep->mtx_clientdb);
308 lp->wait_ts = rep->max_gap;
309 ret = __rep_loggap_req(env, rep, &lsn, REP_GAP_FORCE);
310 MUTEX_UNLOCK(env, rep->mtx_clientdb);
334 REP *rep;
338 rep = db_rep->region;
347 ret = __rep_logready(env, rep, savetime, &last_lsn);
375 REP *rep;
388 rep = db_rep->region;
439 ret = __rep_chk_newfile(env, logc, rep, rp, eid);
447 if (F_ISSET(rep, REP_F_MASTER)) {
473 use_bulk = FLD_ISSET(rep->config, REP_C_BULK);
479 repth.gbytes = rep->gbytes;
480 repth.bytes = rep->bytes;
493 if (ret == DB_NOTFOUND && F_ISSET(rep, REP_F_MASTER))
503 if (rep->version < DB_REPVERSION_47)
565 __rep_loggap_req(env, rep, lsnp, gapflags)
567 REP *rep;
616 if (F_ISSET(rep, REP_F_RECOVER_LOG)) {
618 &rep->last_lsn) <= 0);
619 lp->max_wait_lsn = rep->last_lsn;
628 if (rep->version < DB_REPVERSION_47)
654 if (rep->master_id != DB_EID_INVALID) {
655 STAT(rep->stat.st_log_requested++);
656 if (F_ISSET(rep, REP_F_RECOVER_LOG))
658 (void)__rep_send_message(env, rep->master_id,
675 __rep_logready(env, rep, savetime, last_lsnp)
677 REP *rep;
688 ZERO_LSN(rep->first_lsn);
690 if (rep->originfo != NULL) {
691 __os_free(env, rep->originfo);
692 rep->originfo = NULL;
695 F_CLR(rep, REP_F_RECOVER_LOG);
725 __rep_chk_newfile(env, logc, rep, rp, eid)
728 REP *rep;
784 if (F_ISSET(rep, REP_F_MASTER)) {
797 if (rep->version < DB_REPVERSION_47)