Lines Matching defs:lp
150 LOG *lp;
196 lp = dblp->reginfo.primary;
494 lsn = lp->lsn;
594 lp = dblp->reginfo.primary;
596 lsn = lp->lsn;
703 lsn = lp->lsn;
805 cmp = LOG_COMPARE(&rp->lsn, &lp->ready_lsn);
834 (u_long)lp->ready_lsn.file, (u_long)lp->ready_lsn.offset,
859 cmp = LOG_COMPARE(&lp->verify_lsn, &rp->lsn);
965 LOG *lp;
996 lp = dblp->reginfo.primary;
999 LOG_COMPARE(&lp->ready_lsn, &rep->first_lsn) < 0)
1000 lp->ready_lsn = rep->first_lsn;
1001 cmp = LOG_COMPARE(&rp->lsn, &lp->ready_lsn);
1060 __os_gettime(env, &lp->rcvd_ts, 1);
1061 ZERO_LSN(lp->max_wait_lsn);
1064 LOG_COMPARE(&lp->ready_lsn, &lp->waiting_lsn) == 0) {
1095 lp->rcvd_ts = lp->last_ts;
1096 lp->wait_ts = rep->request_gap;
1098 __os_gettime(env, &lp->rcvd_ts, 1);
1109 if (!IS_ZERO_LSN(lp->waiting_lsn) &&
1110 LOG_COMPARE(&lp->ready_lsn, &lp->waiting_lsn) != 0) {
1122 lp->wait_ts = rep->request_gap;
1123 ZERO_LSN(lp->max_wait_lsn);
1141 __os_gettime(env, &lp->last_ts, 1);
1156 if (IS_ZERO_LSN(lp->waiting_lsn) ||
1157 LOG_COMPARE(&rp->lsn, &lp->waiting_lsn) < 0)
1158 lp->waiting_lsn = rp->lsn;
1179 max_lsn = lp->max_perm_lsn;
1189 if (timespeccmp(&msg_time, &lp->max_lease_ts, >))
1192 max_ts = lp->max_lease_ts;
1198 if (ret == 0 && LOG_COMPARE(&lp->ready_lsn, &lp->waiting_lsn) == 0)
1211 LOG_COMPARE(&lp->ready_lsn, &rep->last_lsn) >= 0) {
1233 DB_ASSERT(env, LOG_COMPARE(&max_lsn, &lp->max_perm_lsn) >= 0);
1234 lp->max_perm_lsn = max_lsn;
1266 LOG_COMPARE(&lp->ready_lsn, &rep->ckp_lsn) >= 0) {
1281 else if (timespeccmp(&max_ts, &lp->max_lease_ts, >))
1282 lp->max_lease_ts = max_ts;
1309 if (ret == 0 && rp->rectype == REP_NEWFILE && lp->db_log_autoremove)
1616 LOG *lp;
1622 lp = dblp->reginfo.primary;
1631 if (rp->lsn.file + 1 > lp->ready_lsn.file) {
1650 * log records because lp->ready_lsn is not getting
1667 lp->ready_lsn = tmplsn;
1781 LOG *lp;
1786 lp = dblp->reginfo.primary;
1814 ZERO_LSN(lp->waiting_lsn);
1824 lp->waiting_lsn = rp->lsn;
2053 LOG *lp;
2061 lp = dblp->reginfo.primary;
2074 lsn = lp->verify_lsn;
2114 LOG *lp;
2119 lp = dblp->reginfo.primary;
2121 timespecsub(&now, &lp->rcvd_ts);
2122 req = timespeccmp(&now, &lp->wait_ts, >=);
2127 timespecadd(&lp->wait_ts, &lp->wait_ts);
2128 if (timespeccmp(&lp->wait_ts, &rep->max_gap, >))
2129 lp->wait_ts = rep->max_gap;
2130 __os_gettime(env, &lp->rcvd_ts, 1);