Lines Matching refs:repth
59 __rep_bulk_message(env, bulk, repth, lsn, dbt, flags)
62 REP_THROTTLE *repth;
134 * call to rep_send_throttle changed the repth->type to the
142 if (repth != NULL) {
144 bulk->eid, repth, REP_THROTTLE_ONLY, flags)) != 0) {
148 if (repth->type == typemore) {
1478 * will throttle - breaking out of their loop, if the repth->type field
1491 __rep_send_throttle(env, eid, repth, flags, ctlflags)
1494 REP_THROTTLE *repth;
1502 check_limit = repth->gbytes != 0 || repth->bytes != 0;
1513 if (repth->type == REP_LOG)
1515 if (repth->type == REP_PAGE)
1526 size = repth->data_dbt->size + sizeof(__rep_control_args);
1528 while (repth->bytes <= size) {
1529 if (repth->gbytes > 0) {
1530 repth->bytes += GIGABYTE;
1531 --(repth->gbytes);
1539 repth->type = typemore;
1542 repth->bytes -= size;
1551 send: if ((repth->type == typemore || !LF_ISSET(REP_THROTTLE_ONLY)) &&
1552 (__rep_send_message(env, eid, repth->type,
1553 &repth->lsn, repth->data_dbt, (REPCTL_RESEND | ctlflags), 0) != 0))