Lines Matching refs:rp
24 __rep_allreq(env, rp, eid)
26 __rep_control_args *rp;
70 oldfilelsn = repth.lsn = rp->lsn;
86 flags = IS_ZERO_LSN(rp->lsn) ||
87 IS_INIT_LSN(rp->lsn) ? DB_FIRST : DB_SET;
114 ret = __rep_chk_newfile(env, logc, rep, rp, eid);
216 __rep_log(env, ip, rp, rec, savetime, ret_lsnp)
219 __rep_control_args *rp;
237 ret = __rep_apply(env, ip, rp, rec, ret_lsnp, &is_dup, &last_lsn);
269 if (rp->rectype == REP_LOG_MORE) {
284 if (LOG_COMPARE(&rp->lsn, &lsn) > 0)
285 lsn = rp->lsn;
324 __rep_bulk_log(env, ip, rp, rec, savetime, ret_lsnp)
327 __rep_control_args *rp;
340 ret = __log_rep_split(env, ip, rp, rec, ret_lsnp, &last_lsn);
365 __rep_logreq(env, rp, rec, eid)
367 __rep_control_args *rp;
394 if (rp->rep_version < DB_REPVERSION_47)
401 (u_long) rp->lsn.file, (u_long)rp->lsn.offset,
421 oldfilelsn = lsn = rp->lsn;
432 if (LOG_COMPARE(&firstlsn, &rp->lsn) > 0) {
435 REP_VERIFY_FAIL, &rp->lsn, NULL, 0, 0);
439 ret = __rep_chk_newfile(env, logc, rep, rp, eid);
450 (u_long)rp->lsn.file,
451 (u_long)rp->lsn.offset);
725 __rep_chk_newfile(env, logc, rep, rp, eid)
729 __rep_control_args *rp;
748 if (endlsn.file > rp->lsn.file) {
757 endlsn.file = rp->lsn.file + 1;
765 (u_long)rp->lsn.file,
766 (u_long)rp->lsn.offset));
787 REP_VERIFY_FAIL, &rp->lsn,