Lines Matching defs:repth
35 REP_THROTTLE repth;
66 memset(&repth, 0, sizeof(repth));
68 repth.gbytes = rep->gbytes;
69 repth.bytes = rep->bytes;
70 oldfilelsn = repth.lsn = rp->lsn;
71 repth.type = REP_LOG;
72 repth.data_dbt = &data_dbt;
95 ret = __logc_get(logc, &repth.lsn, &data_dbt, flags);
103 if (ret == 0 && repth.lsn.file != 1 && flags == DB_FIRST) {
105 REP_VERIFY_FAIL, &repth.lsn, NULL, 0, 0);
121 ret = __logc_get(logc, &repth.lsn,
137 ret == 0 && repth.type != REP_LOG_MORE && end_flag == 0;
138 ret = __logc_get(logc, &repth.lsn, &data_dbt, DB_NEXT)) {
143 if (repth.lsn.file != oldfilelsn.file) {
168 end_flag = (LOG_COMPARE(&repth.lsn, &log_end) >= 0 &&
178 ret = __rep_bulk_message(env, &bulk, &repth,
179 &repth.lsn, &data_dbt, (REPCTL_RESEND | end_flag));
182 eid, &repth, 0, end_flag);
189 oldfilelsn = repth.lsn;
377 REP_THROTTLE repth;
477 memset(&repth, 0, sizeof(repth));
479 repth.gbytes = rep->gbytes;
480 repth.bytes = rep->bytes;
481 repth.type = REP_LOG;
482 repth.data_dbt = &data_dbt;
485 repth.type == REP_LOG) {
487 __logc_get(logc, &repth.lsn, &data_dbt, DB_NEXT)) != 0) {
497 if (LOG_COMPARE(&repth.lsn, &lr_args.endlsn) >= 0)
499 if (repth.lsn.file != oldfilelsn.file) {
522 ret = __rep_bulk_message(env, &bulk, &repth,
523 &repth.lsn, &data_dbt, REPCTL_RESEND);
525 ret = __rep_send_throttle(env, eid, &repth, 0, 0);
536 oldfilelsn = repth.lsn;