Lines Matching refs:rp
33 #define MASTER_ONLY(rep, rp) do { \
38 eid, rp, "rep_process_message", 0); \
44 #define CLIENT_ONLY(rep, rp) do { \
60 eid, rp, "rep_process_message", 0); \
79 ret = __rep_skip_msg(env, rep, eid, rp->rectype);\
95 ret = __rep_skip_msg(env, rep, eid, rp->rectype); \
112 LOG_COMPARE(&rp->lsn, &rep->last_lsn) > 0))) { \
115 ret = __rep_skip_msg(env, rep, eid, rp->rectype); \
156 __rep_control_args *rp, tmprp;
242 rp = &tmprp;
248 REP_PRINT_MESSAGE(env, eid, rp, "rep_process_message", 0);
253 if (rp->rep_version < DB_REPVERSION) {
254 if (rp->rep_version < DB_REPVERSION_MIN) {
257 (u_long)rp->rep_version, DB_REPVERSION_MIN);
263 (u_long)rp->rectype, (u_long)rp->rep_version));
264 rp->rectype = __rep_msg_from_old(rp->rep_version, rp->rectype);
265 DB_ASSERT(env, rp->rectype != REP_INVALID);
272 (u_long)rp->rectype, (u_long)rp->rep_version));
273 } else if (rp->rep_version > DB_REPVERSION) {
276 (u_long)rp->rep_version, DB_REPVERSION);
281 if (rp->log_version < DB_LOGVERSION) {
282 if (rp->log_version < DB_LOGVERSION_MIN) {
285 (u_long)rp->log_version, DB_LOGVERSION_MIN);
291 (u_long)rp->rectype, (u_long)rp->log_version));
292 } else if (rp->log_version > DB_LOGVERSION) {
295 (u_long)rp->log_version, DB_LOGVERSION);
311 if (F_ISSET(rp, REPCTL_PERM))
320 if (F_ISSET(rep, REP_F_CLIENT) && REP_MSG_REQ(rp->rectype)) {
343 (F_ISSET(rp, REPCTL_LEASE) || rp->rectype == REP_LEASE_GRANT)) {
358 if (rp->gen < gen && rp->rectype != REP_ALIVE_REQ &&
359 rp->rectype != REP_NEWCLIENT && rp->rectype != REP_MASTER_REQ &&
360 rp->rectype != REP_DUPMASTER && rp->rectype != REP_VOTE1) {
365 if (F_ISSET(rp, REPCTL_PERM))
370 if (rp->gen > gen) {
388 else if (rp->rectype != REP_DUPMASTER)
402 if (rp->rectype == REP_ALIVE ||
403 rp->rectype == REP_VOTE1 || rp->rectype == REP_VOTE2) {
407 (u_long)gen, (u_long)rp->gen));
409 gen = rep->gen = rp->gen;
415 if (rp->rectype == REP_ALIVE)
419 } else if (rp->rectype != REP_NEWMASTER) {
439 if (F_ISSET(rp, REPCTL_GROUP_ESTD)) {
457 switch (rp->rectype) {
463 if (rp->rep_version < DB_REPVERSION_47)
525 ret = __rep_allreq(env, rp, eid);
530 CLIENT_ONLY(rep, rp);
531 ret = __rep_bulk_log(env, ip, rp, rec, savetime, ret_lsnp);
537 CLIENT_ONLY(rep, rp);
538 ret = __rep_bulk_page(env, ip, eid, rp, rec);
549 CLIENT_ONLY(rep, rp);
559 CLIENT_ONLY(rep, rp);
568 MASTER_ONLY(rep, rp);
569 ret = __rep_lease_grant(env, rp, rec, eid);
574 CLIENT_ONLY(rep, rp);
575 ret = __rep_log(env, ip, rp, rec, savetime, ret_lsnp);
579 if (F_ISSET(rp, REPCTL_INIT))
581 ret = __rep_logreq(env, rp, rec, eid);
619 DB_EID_BROADCAST, REP_NEWSITE, &rp->lsn, rec, 0, 0);
695 REP_ALIVE, &rp->lsn, &data_dbt, 0, 0);
716 if (F_ISSET(rep, REP_F_CLIENT) && rp->gen < gen) {
732 REP_ALIVE, &rp->lsn, &data_dbt, 0, 0);
737 CLIENT_ONLY(rep, rp);
739 ip, rp, rec, ret_lsnp, NULL, &last_lsn);
764 __rep_new_master(env, rp, eid)) == DB_REP_NEWMASTER)
765 ret = __rep_fire_newmaster(env, rp->gen, eid);
772 CLIENT_ONLY(rep, rp);
773 ret = __rep_page(env, ip, eid, rp, rec);
781 CLIENT_ONLY(rep, rp);
782 ret = __rep_page_fail(env, ip, eid, rp, rec);
787 ret = __rep_page_req(env, ip, eid, rp, rec);
795 CLIENT_ONLY(rep, rp);
805 cmp = LOG_COMPARE(&rp->lsn, &lp->ready_lsn);
828 if (LOG_COMPARE(&rp->lsn, &rep->ckp_lsn) > 0)
829 rep->ckp_lsn = rp->lsn;
843 CLIENT_ONLY(rep, rp);
844 ret = __rep_update_setup(env, eid, rp, rec);
850 MASTER_ONLY(rep, rp);
854 ret = __rep_update_req(env, rp, eid);
859 cmp = LOG_COMPARE(&lp->verify_lsn, &rp->lsn);
866 env, rep, eid, rp->rectype);
870 CLIENT_ONLY(rep, rp);
871 ret = __rep_verify(env, rp, rec, eid, savetime);
877 CLIENT_ONLY(rep, rp);
878 ret = __rep_verify_fail(env, rp, eid);
882 ret = __rep_verify_req(env, rp, eid);
889 ret = __rep_vote1(env, rp, rec, eid);
895 ret = __rep_vote2(env, rp, rec, eid);
900 (u_long)rp->rectype);
913 lsn = rp->lsn;
926 if (ret == 0 && F_ISSET(rp, REPCTL_PERM)) {
928 *ret_lsnp = rp->lsn;
950 __rep_apply(env, ip, rp, rec, ret_lsnp, is_dupp, last_lsnp)
953 __rep_control_args *rp;
981 timespecset(&msg_time, rp->msg_sec, rp->msg_nsec);
1001 cmp = LOG_COMPARE(&rp->lsn, &lp->ready_lsn);
1042 (u_long)rp->lsn.file, (u_long)rp->lsn.offset));
1053 rp, rec, &max_ts, &max_lsn)) != 0)
1074 rp = (__rep_control_args *)control_dbt.data;
1075 timespecset(&msg_time, rp->msg_sec, rp->msg_nsec);
1078 rp, rec, &max_ts, &max_lsn)) != 0)
1119 __rep_loggap_req(env, rep, &rp->lsn, 0)) != 0)
1136 key_dbt.data = rp;
1137 key_dbt.size = sizeof(*rp);
1157 LOG_COMPARE(&rp->lsn, &lp->waiting_lsn) < 0)
1158 lp->waiting_lsn = rp->lsn;
1161 (ret = __rep_loggap_req(env, rep, &rp->lsn, 0) != 0))
1168 if (ret == 0 && F_ISSET(rp, REPCTL_PERM)) {
1169 max_lsn = rp->lsn;
1178 if (F_ISSET(rp, REPCTL_PERM))
1187 F_ISSET(rp, REPCTL_LEASE) &&
1247 ((cmp <= 0 && F_ISSET(rp, REPCTL_LOG_END)) ||
1248 (cmp == 0 && !F_ISSET(rp, REPCTL_RESEND)))) {
1300 (u_long)rp->lsn.file, (u_long)rp->lsn.offset));
1309 if (ret == 0 && rp->rectype == REP_NEWFILE && lp->db_log_autoremove)
1608 __rep_newfile(env, rp, rec)
1610 __rep_control_args *rp;
1631 if (rp->lsn.file + 1 > lp->ready_lsn.file) {
1635 (u_long) rp->log_version));
1636 nf_args.version = rp->log_version;
1637 } else if (rp->rep_version < DB_REPVERSION_47)
1644 (u_long)rp->lsn.file + 1, (u_long)nf_args.version));
1681 __rep_do_ckp(env, rec, rp)
1684 __rep_control_args *rp;
1724 ret = __txn_updateckp(env, &rp->lsn);
1782 __rep_control_args *rp;
1823 rp = (__rep_control_args *)lsn_dbt.data;
1824 lp->waiting_lsn = rp->lsn;
1834 * Given a record in 'rp', process it. In the case of a NEWFILE, that means
1840 __rep_process_rec(env, ip, rp, rec, ret_tsp, ret_lsnp)
1843 __rep_control_args *rp;
1861 if (rp->rectype == REP_NEWFILE) {
1862 ret = __rep_newfile(env, rp, rec);
1869 timespecset(&msg_time, rp->msg_sec, rp->msg_nsec);
1890 if ((ret = __log_rep_put(env, &rp->lsn, rec, 0)) != 0)
1894 *ret_lsnp = rp->lsn;
1922 rec, &rp->lsn, DB_TXN_APPLY, NULL);
1948 (u_long)rp->lsn.file, (u_long)rp->lsn.offset);
1957 rep->max_prep_lsn = rp->lsn;
1974 key_dbt.data = rp;
1975 key_dbt.size = sizeof(*rp);
1984 *ret_lsnp = rp->lsn;
1999 if ((ret = __rep_do_ckp(env, rec, rp)) == 0)
2000 ret = __log_rep_put(env, &rp->lsn, rec,
2017 if (ret == 0 && F_ISSET(rp, REPCTL_PERM))
2018 *ret_lsnp = rp->lsn;
2020 F_ISSET(rp, REPCTL_LEASE))
2027 if (ret == 0 && F_ISSET(rp, REPCTL_FLUSH))